1、给指定topic发送消息
./kafka-console-producer.sh --broker-list 192.168.20.152:9092 --topic --topic warning-data-overstep-topic
2、监听指定topic
./kafka-console-consumer.sh --bootstrap-server 192.168.20.152:9092 --from-beginning --topic warning-data-overstep-topic
评论 (0)