kafka 常用命令与问题（持续更新）
搜了一圈百度，好多都是低版本的操作、特在这汇总一下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-server10.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：
^[ WARN 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选项没有了，是用上面写的命令。
页:
[1]