什么是Kafka经纪人日志中此错误的含义?
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了什么是Kafka经纪人日志中此错误的含义?相关的知识,希望对你有一定的参考价值。
答案
这是卡夫卡的一个已知问题。它与https://issues.apache.org/jira/browse/KAFKA-7190和https://issues.apache.org/jira/browse/KAFKA-6817有关。
另一答案
这是一个已知的错误,将通过https://cwiki.apache.org/confluence/display/KAFKA/KIP-360%3A+Improve+handling+of+unknown+producer解决
你不能做太多,但需要等待修复。
问题是,Kafka Streams从重新分区主题中主动删除数据(cf https://issues.apache.org/jira/browse/KAFKA-6150),因此增加保留时间无济于事 - 实际上,Kafka Streams已经使用retention.ms=MAX_VALUE
配置了重新分区主题。
你唯一能做的就是为重新分配主题增加主题配置segment.bytes
和segment.ms
配置。使段更大可以减少事务生成器状态丢失的可能性,因为活动段不受活动数据清除的影响,因此数据会保留更长时间。
以上是关于什么是Kafka经纪人日志中此错误的含义?的主要内容,如果未能解决你的问题,请参考以下文章
日志中经常看到的Kafka FETCH_SESSION_ID_NOT_FOUND