Kafka常用操作记录
经常用到的Kafka命令记录以下,方便查找。kafka的搭建可以参考这篇文章Kafka和zookeeper搭建
Topic操作
创建topic
1
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic test_topic
查看topic具体信息
1
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test_topic
查看所有的topic列表
1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
删除topic
1
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test_topic
修改topic副本数
1
bin/kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 8 --topic test_topic
消费组操作
显示所有消费组
1
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --all-groups --list
查看所有消费组详情
1
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --all-groups --describe
查看单独组的详细信息
1
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test_group --describe
删除消费组(前提是没有在消费的)
1
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test_group --delete
控制台生产消费
生产者发送消息
1
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic
然后控制台输入内容,回车即可
消费者消费消息
--from-beginning
是指从头进行消费,可能会打印大量东西在控制台上。1
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test_topic --from-beginning
本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 杂烩饭!
评论