Kafka命令行操作

1)查看当前集群中已存在的主题topic

bin/kafka-topics.sh --zookeeper hd09:2181 --list

2)创建topic

bin/kafka-topics.sh --zookeeper hd09-01:2181 --create --replication-facto r 3 --partitions 1 --topic guan

--zookeeper 连接zk集群
--create 创建
--replication-factor 副本
--partitions 分区
--topic 主题名

3)删除主题

bin/kafka-topics.sh --zookeeper hd09-01:2181 --delete --topic guan 

4)发送消息
生产者启动:

bin/kafka-console-producer.sh --broker-list hd09-01:9092 --topic guan

消费者启动:

 bin/kafka-console-consumer.sh --bootstrap-server hd09-01:9092 --topic guan --from-beginning

5)查看主题详细信息

bin/kafka-topics.sh --zookeeper hd09-01:2181 --describe --topic guan