博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
kafka 常用命令与问题(持续更新)
阅读量:5886 次
发布时间:2019-06-19

本文共 1108 字,大约阅读时间需要 3 分钟。

搜了一圈百度,好多都是低版本的操作、特在这汇总一下2.0版本的一些命令,也和低版本做对比。

常用命令:

1、启动命令:

前台启动./bin/kafka-server-start.sh ./config/server.properties后台启动./bin/kafka-server-start.sh ./config/server.properties 1>/dev/null 2>&1 &

2、topic 提供者和消费者启动

消费者启动./kafka-console-consumer.sh --bootstrap-server  10.1.90.29:9092 --topic test --from-beginning提供者启动./kafka-console-producer.sh --broker-list localhost:9092 --topic test

3、创建topic命令:

cd bin目录下./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-queue

4、查看topic主体list

./kafka-topics.sh --zookeeper localhost:2181 --list

持续更新中

问题汇总如下:

问题1:

^[[A[2018-09-28 15:52:55,577] WARN [Consumer clientId=consumer-1, groupId=console-consumer-7862] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

这种问题是因为kafka配置的问题,配置文件的ip,比如你配置的10.1.90.29 ,但是你却使用的localhost启动,就是有问题,一直报警告。

问题2:

报错:zookeeper is not a recognized option启动./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning新版本并不是用这个的了,zookeeper选项没有了,是用上面写的命令。

转载于:https://blog.51cto.com/shangdc/2287309

你可能感兴趣的文章
银河台的文字语言转换自动广播做的不错啊
查看>>
jQuery打造智能提示插件
查看>>
操作系统常识相关
查看>>
蓝牙HID协议笔记【转】
查看>>
Linux 创建子进程执行任务
查看>>
Java8-Stream-No.02
查看>>
iOS开发-UITextView实现PlaceHolder的方式
查看>>
【HTML5初探之多媒体元素】视频播放HTML5、Flash谁才是王道?
查看>>
Play with docker 1.12
查看>>
sql server中意向锁的作用
查看>>
一起Polyfill系列:让Date识别ISO 8601日期时间格式
查看>>
mysql基础知识
查看>>
提高mysql查询效率的六种方法
查看>>
Jsp Session
查看>>
mysql替换某个字段中的某个字符
查看>>
关于写blog这件事
查看>>
Linux中的其他命令
查看>>
轻松简单搭建Linux下的C#开发环境<转>
查看>>
一个类型初始值设定项引发异常
查看>>
将现有MySQL数据库改为大小写不敏感
查看>>