date: 2020-06-05title: kafka常用指令 #标题
tags: kafka #标签
categories: MQ # 分类

用于记录下kafka的常用命令。

  1. # 显示topic列表
  2. bin/kafka-topics.sh --zookeeper zk1:2181,zk2:2181,zk3:2181  --list  
  3. 也可以从一个节点上查看。下面简写查看一个节点。
  5. # 创建一个topic，并指定topic属性（副本数、分区数等）
  6. bin/kafka-topics.sh --create --zookeeper zk1:2181 --replication-factor 1 --partitions 3 --topic test
  7. # --partitions（分区）应等于或大于消费者，--replication-factor（副本数）不能大于kafka集群内主机节点
  9. # 查看某个topic的状态
  10. bin/kafka-topics.sh   --zookeeper   zk1:2181    --topic   test   --describe
  12. # 生产消息
  13. bin/kafka-console-producer.sh --broker-list kafka1:9092 --topic  test    
  15. # 消费消息
  16. bin/kafka-console-consumer.sh --bootstrap-server PLAINTEXT://kafka1:9092 --topic  test
  20. # 查看实时消息，如果从头看可在后面加   --from-beginning  
  21. kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
  23. # 删除topic
  24. bin/kafka-topics.sh --delete --zookeeper zk1:2181  --topic   test