Kafak通过命令行测试发送和消费数据

Kafka安装：https://blog.csdn.net/qq_15267341/article/details/90144607

---

下面具体测试一下：

---

首先切换到kafka目录下的bin目录下，然后执行下面的命令

---

创建主题

./kafka-topics.sh --create --zookeeper hadoop002:2181 --topic xuguozhu --partitions 3 --replication-factor 3

---

查看某个主题

./kafka-topics.sh --describe --topic xuhaitao --zookeeper hadoop002:2181

---

列举所有主题

./kafka-topics.sh --list --zookeeper hadoop003:2181

---

往某个主题发送数据

./kafka-console-producer.sh --broker-list hadoop002:9092 --topic xuhaitao

---

消费某个主题的数据

./kafka-console-consumer.sh --bootstrap-server hadoop002:9092 --topic xuhaitao --from-beginning

---

 

 

FR:徐海涛（hunk Xu） QQ技术交流群：386476712