apache-kafka - Kafka 代理正常关闭，错误的元数据被传递到 Kafka 连接客户端

Question

为了维护服务器，20 个代理中的一个被正常关闭，但所有 kafka-connect 集群（接收器）都因以下 NPE 错误而死亡。所有主题的复制因子都大于2，有50个主题和200个分区。检查错误和Kafka库源代码，似乎是Connect客户端缓存了从代理接收到的包括代理节点ID集和分区信息集信息在内的元数据时发生的错误。

怎么会发生这种情况，以及将来如何处理呢？（Broker and Client版本为v2.3.1）

标签： apache-kafkaapache-kafka-connect

Answer 1

这是一个错误。Connect 集群不应受到代理关闭的负面影响，也不应引发 NPE。

请在https://issues.apache.org/jira/projects/KAFKA/issues/中开票。最好将堆栈跟踪粘贴为文本而不是图像。