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

发表于: 2022-05-19   最后更新时间: 2022-05-19 15:08:30   1,027 游览

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

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

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

发表于 2022-05-19
添加评论

好奇你原因找到了吗

你的答案

查看kafka相关的其他问题或提一个您自己的问题