首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >卡夫卡-消费者补偿自动复位

卡夫卡-消费者补偿自动复位
EN

Stack Overflow用户
提问于 2017-08-25 10:18:14
回答 1查看 3.6K关注 0票数 2

在将Apache与Java高级消费者一起使用时,有时会出现以下错误:

with池-1-线程-4自动提交偏移量{my_topic-2=偏移量和元数据{offset=53847,元数据=‘}}组my_consumer_group失败:偏移提交失败,但有可检索的异常。您应该重试提交抵消。潜在的错误是:这不是正确的协调器。

每当发生此错误时,使用者偏移量将重置为较早的值,并且已经使用的记录将再次被消耗。

我的卡夫卡版本0.11.0.0。我有三个卡夫卡经纪人。我的主题的分区数为3个,用于使用者偏移量的分区数为50个(默认值)。消费者补偿的复制因子为2。

这是0.11.0.0中的错误吗?还是我错过了任何配置?

谢谢。

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-01-17 14:21:02

这是Kafka版本0.11.0.0中的一个bug,后来在0.11.0.1版本中得到了修复。

下面的票证跟踪bug,

https://issues.apache.org/jira/browse/KAFKA-5600

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/45879245

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档