使用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 回答
这是Kafka版本0.11.0.0中的一个错误,后来在版本0.11.0.1中得到修复 .
以下故障单跟踪错误,
https://issues.apache.org/jira/browse/KAFKA-5600