调用consumer.offsetsForTimes返回map的key有值,value为null。 很奇怪,一样的代码在本地可以,但是发布到生产环境就不行。 kafka版本为kafka_2.11-1.1.0kafka客户端jar包版本为kafka-clients-1.1.0.jar
好奇你原因找到了吗
你的答案