我有一个与我们正面临的kafka问题有关的问题 . 在运行我的kafka经纪人较长时间后, 生产环境 者开始向错误的分区领导发送发送请求,错误的领导者拒绝该消息(这是可接受的) . 但制作人永远不会更新其关于当前正确领导者的元数据 . 有帮助吗?我正在使用kafka 0.9.0.1

以下是我的日志文件中的错误消息:

ERROR [ReplicaFetcherThread-18-2],分区[topic1,2]到代理2的错误:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:此服务器不承载此主题分区 . (kafka.server.ReplicaFetcherThread)