kafka常用指令
Posted cuiyuanhao
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka常用指令相关的知识，希望对你有一定的参考价值。
查看消费组详情:
./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常用指令的主要内容，如果未能解决你的问题，请参考以下文章