Kafka命令行操作
1）查看当前服务器中的所有topic
[bingo@hadoop101 kafka]$ bin/kafka-topics.sh --list --zookeeper hadoop101:2181
2）创建topic
[bingo@hadoop101 kafka]$ bin/kafka-topics.sh --create --zookeeper hadoop101: --replication-factor --partitions --topic first
选项说明：
--topic 定义topic名
--replication-factor 定义副本数
--partitions 定义分区数
3） 删除topic
[bingo@hadoop101 kafka]$ bin/kafka-topics.sh --delete --zookeeper hadoop101:2181 --topic first
需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。
4）发送消息
[bingo@hadoop101 kafka]$ bin/kafka-console-producer.sh --broker-list hadoop101:9092 --topic first
>hello world
>atguigu atguigu
5）消费消息
[bingo@hadoop102 kafka]$ bin/kafka-console-consumer.sh --zookeeper hadoop101:2181 --from-beginning --topic first
6）查看某个Topic的详情
[bingo@hadoop101 kafka]$ bin/kafka-topics.sh --topic first --describe --zookeeper hadoop101:2181