这家伙太懒,什么都没留下
这种是老的消费者方式,用0.9版本以上的新的版本。
我也遇到这种情况. 发现如果配置完
sh kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
这样的方式都不行了,是么, 所有的都需要采用API 实现的方式 是么????