本文共 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