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