1、建立topic

• 使用 kafka-topics.sh指令碼

  kafka-topics.sh --create --partitions 3 --replication-factor 2 --topic test --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
  

2、查詢所有的topic

• 使用 kafka-topics.sh指令碼

  kafka-topics.sh --list --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
  

3、檢視topic的描述資訊

• 使用 kafka-topics.sh指令碼

  kafka-topics.sh --describe --topic test --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
  

4、刪除topic

• 使用 kafka-topics.sh指令碼

  kafka-topics.sh --delete --topic test --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
  

5、模擬生產者寫入資料到topic中

• 使用 kafka-console-producer.sh

  指令碼

  kafka-console-producer.sh --broker-list hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic test 
  

6、模擬消費者拉取topic中的資料

• 使用 kafka-console-consumer.sh 指令碼

  kafka-console-consumer.sh --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --topic test --from-beginning
  或者
  kafka-console-consumer.sh --bootstrap-server hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic test --from-beginning