kafka启动命令:
kafka-console-consumer.sh --zookeeper mini1:2181 --from-beginning --topic orderMq
报错如下:
原因为:使用kafka版本1.2.2,启动消费者命令变为:
kafka-console-consumer.sh --bootstrap-server mini1:9092 --topic orderMq
kafka启动命令:
kafka-console-consumer.sh --zookeeper mini1:2181 --from-beginning --topic orderMq
报错如下:
原因为:使用kafka版本1.2.2,启动消费者命令变为:
kafka-console-consumer.sh --bootstrap-server mini1:9092 --topic orderMq