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