我这边没有降低版本,最后发现是用于偏移量的__consumer_offsets这个topic不知道为什么没了。我手动创建后,重启可以用了。供你参考
我最终还是降低了版本,好像是CDH还是没有支持到0.10之后的版本
我也遇到了一模一样的问题,我是用的是CDH5.15,kafka装的3.1.0,同样也是可以生产,但是不能消费。切到别的机器上的原生kafka就正常了。
问下这个问题的产生原因你有继续探究吗,除了降低版本?
不过我们都通过monitor进行监控,不需要单独调用API进行特别管理的。