kafka常用命令

关于kafka的命令,网上很多,整理一下自己测试中较常用的,方便查看:

1、启动kafka

./bin/kafka-server-start.sh -daemon config/server.properties &

2、创建topic–test

./bin/kafka-topics.sh --create --zookeeper 10.10.67.102:2181, 10.10.67.104:2181, 10.10.67.106:2181 --replication-factor 3 --partitions 3 --topic test

3、列出已创建的topic列表

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

4、模拟客户端去发送消息

./bin/kafka-console-producer.sh --broker-list 10.10.67.102:9092, 10.10.67.104:9092, 10.10.67.106:9092 --topic test

5、模拟客户端去接受消息

./bin/kafka-console-consumer.sh --zookeeper 10.10.67.102:2181, 10.10.67.104:2181, 10.10.67.106:2181 --from-beginning --topic test

6、查看指定的主题

./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

版权声明:本文为zxy987872674原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。