Kafka新老版本命令行参数对比详解

新老版本Kafka启动方式（两者一致）：

bin/zookeeper-server-start.sh config/zookeeper.properties    # 启动内置zk
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties   # 使用守护进程启动
bin/kafka-server-start.sh onfig/server.properties    # 前台启动Kafka
bin/kafka-server-start.sh -daemon config/server.properties      # daemon方式启动Kafka

（1）新版本Kafka命令行参数（kafka_2.11-2.3.0 为例)：

##创建topic
./kafka-topics.sh --create --bootstrap-server k1.cn:9092 --replication-factor 1 --partitions 1 --topic xxoo
#查看topic
./kafka-topics.sh --list --bootstrap-server k1.cn:9092
#topic 描述
./kafka-topics.sh --describe --zookeeper k1.cn:2181  --topic xxoo
#producer(控制台向topic生产数据)
./kafka-console-producer.sh --broker-list k1.cn:9092 --topic xxoo
>this is a message
>this is another message
##consumer(控制台消费topic的数据2)
./kafka-console-consumer.sh --bootstrap-server k1.cn:9092 --topic xxoo --from-beginning
this is a message
this is another message
##查看某一个topic对应的消息数量
./kafka-run-class.sh  kafka.tools.GetOffsetShell --broker-list k1.cn:9092 --topic xxoo --time -1
##新版本的消费者组名和它要消费的那个topic的offset信息就会被记录在broker服务器上,老版本存在zookeeper上
./kafka-consumer-groups.sh --bootstrap-server k1.cn:9092 --list
##删除消费组
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.11:9092 --delete --group py-test
##查看消费组的的列表
./kafka-consumer-groups.sh  --list  --bootstrap-server 192.168.100.11:9092
或者
./kafka-consumer-groups.sh --bootstrap-server k1.cn:9092 xxoo --list
## 查看特定消费组的情况
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.11:9092 --group py-test --describe

（2）旧版本Kafka命令行参数（kafka_2.11-2.0.0 为例)

./kafka-topics.sh --list --zookeeper k1.cn:2181
## topic描述
./kafka-topics.sh --describe --zookeeper k1.cn:2181  --topic xxoo
## 创建topic
./kafka-topics.sh --create --zookeeper k1.cn:2181 --replication-factor 1 --partitions 1 --topic xxoo
##consumer(控制台消费topic的数据2)
./kafka-console-consumer.sh --bootstrap-server k1.cn:9092 --topic xxoo --from-beginning
###生产数据
./kafka-console-producer.sh --broker-list k1.cn:9092 --topic xxoo
##查看某一个topic对应的消息数
./kafka-run-class.sh  kafka.tools.GetOffsetShell --broker-list k1.cn:9092 --topic xxoo --time -1

文章【Kafka新老版本命令行参数对比详解】为一一网络技术博客发布