在将Apache与Java高级消费者一起使用时,有时会出现以下错误:
with池-1-线程-4自动提交偏移量{my_topic-2=偏移量和元数据{offset=53847,元数据=‘}}组my_consumer_group失败:偏移提交失败,但有可检索的异常。您应该重试提交抵消。潜在的错误是:这不是正确的协调器。
每当发生此错误时,使用者偏移量将重置为较早的值,并且已经使用的记录将再次被消耗。
我的卡夫卡版本0.11.0.0。我有三个卡夫卡经纪人。我的主题的分区数为3个,用于使用者偏移量的分区数为50个(默认值)。消费者补偿的复制因子为2。
这是0.11.0.0中的错误吗?还是我错过了任何配置?
谢谢。
发布于 2019-01-17 14:21:02
这是Kafka版本0.11.0.0中的一个bug,后来在0.11.0.1版本中得到了修复。
下面的票证跟踪bug,
https://stackoverflow.com/questions/45879245
复制相似问题