使用console生产消息:
./bin/kafka-console-producer.sh --bootstrap-server 172.23.201.228:9092 --topic test
>hello
>message
>
使用下边的命令消费消息收不到:
./bin/kafka-console-consumer.sh --bootstrap-server 172.23.201.228:9092 --topic test --from-beginning
使用console生产消息:
./bin/kafka-console-producer.sh --bootstrap-server 172.23.201.228:9092 --topic test
>hello
>message
>
使用下边的命令消费消息收不到:
./bin/kafka-console-consumer.sh --bootstrap-server 172.23.201.228:9092 --topic test --from-beginning
你好像输入错误了吧
kafka接受消息命令(消费)
./bin/kafka-console-consumer.sh --bootstrap-server 172.23.201.228:9092 --topic test
kafka发送消息命令(生产消息)
./bin/kafka-console-producer.sh --broker-list 172.23.201.228:9092 --topic test
可是你的生产消息。。。。。。。。