首页 文章

Kafka - 消费者偏移自动重置

提问于
浏览
0

使用Apache Kafka和Java API高级消费者时,我有时会收到以下错误,

WARNpool-1-thread-4自动提交偏移量{my_topic-2 = OffsetAndMetadata {offset = 53847,metadata =''}}组my_consumer_group失败:偏移提交失败并出现可重试异常 . 您应该重试提交偏移量 . 潜在的错误是:这不是正确的协调员 .

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

我的Kafka版本0.11.0.0 . 我有3个 Kafka 经纪人 . 我的主题的分区数为3.消费者偏移的分区数为50(默认值) . 消费者抵消的复制因子是2 .

这是0.11.0.0中的错误吗?或者我错过任何配置?

谢谢 .

1 回答

相关问题