kafka 常用命令与问题（持续更新）

wuliuwang

　　搜了一圈百度，好多都是低版本的操作、特在这汇总一下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选项没有了，是用上面写的命令。