返回到文章

采纳

编辑于 2年前

kafka指定时间戳开始消费,返回偏移量(offset)为空

kafka

调用consumer.offsetsForTimes返回map的key有值,value为null。

很奇怪,一样的代码在本地可以,但是发布到生产环境就不行。

kafka版本为kafka_2.11-1.1.0
kafka客户端jar包版本为kafka-clients-1.1.0.jar