kafka常用指令

标签：tor   host   producer   enable   常用指令   生产   bootstra   create   ==   

查看消费组详情:

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group

查看topic详情：

./bin/kafka-topics.sh --topic mytopic --describe --bootstrap-server localhost:9092

创建topic：

bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic mytopic --partitions 10 --replication-factor 3

查看topic详情：

bin/kafka-topics.sh --zookeeper localhost:2181 --desc --topic mytopic 

修改partition数量：

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --partitions 10

删除topic：

server.properties ==> delete.topic.enable=true
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic mytopic 

创建终端生产者：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic 

创建终端消费者：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic mytopic 

kafka常用指令

标签：tor   host   producer   enable   常用指令   生产   bootstra   create   ==   

原文地址：https://www.cnblogs.com/cuiyuanhao/p/13410418.html