Kafka 命令行操作

1）查看当前服务器中的所有 topic
[hadoop@hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --list
2）创建 topic
[hadoop@hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 
--create --replication-factor 3 --partitions 1 --topic first
选项说明：
--topic 定义 topic 名
--replication-factor 定义副本数
--partitions 定义分区数
3）删除 topic
[hadoop@hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 
--delete --topic first
需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除或者直接重启。
4）发送消息
[hadoop@hadoop102 kafka]$ bin/kafka-console-producer.sh 
--broker-list hadoop102:9092 --topic first
>hello world
>hadoop hadoop
5）消费消息
[hadoop@hadoop103 kafka]$ bin/kafka-console-consumer.sh 
--zookeeper hadoop102:2181 --from-beginning --topic first
--from-beginning：会把 first 主题中以往所有的数据都读取出来。根据业务场景选 择是否增加该配置。
6）查看某个 Topic 的详情
[hadoop@hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 
--describe --topic first