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