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