个人网站引导页源码_昆明凡科建站公司_推广方式营销方案_德州seo优化

---

1、主题命令

查看当前服务器中的所有 topic：

kafka-topics.sh --bootstrap-server node01:9092 --list 

创建topic：

kafka-topics.sh --bootstrap-server node01:9092 --create --topic topicB --partitions 1 --replication-factor 3

查看主题的详情 ：

kafka-topics.sh --bootstrap-server node01:9092 --describe --topic topicB 

2、生产者命令行操作

向主题发送消息：

kafka-console-producer.sh --bootstrap-server node01:9092 --topic topicB

3、消费者命令行操作

接收主题最新消息：

kafka-console-consumer.sh --bootstrap-server node01:9092 --topic topicB

接收主题所有消息（包括历史消息）：

kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic topicB