版本:0.8.2.0
auto.offset.reset = largest
在新建topic时,若先启动consumer,再启动producer推消息,正常; 若prodcuer先启动,并且往topic里推消息,再启动consumer消费时,发现之前推送的消息并没有按预期的消费。
这个问题是kafka本身的bug,附上jira地址:
本文共 217 字,大约阅读时间需要 1 分钟。
版本:0.8.2.0
auto.offset.reset = largest
在新建topic时,若先启动consumer,再启动producer推消息,正常; 若prodcuer先启动,并且往topic里推消息,再启动consumer消费时,发现之前推送的消息并没有按预期的消费。
这个问题是kafka本身的bug,附上jira地址:
转载于:https://my.oschina.net/zjoschina/blog/552390