apache-kafka - 当代理之一强制关闭时，在 kafka 代理日志中看到 java.io.IOException

Question

我正在为 Kafka 进行故障转移设置，集群中有 2 个代理和单个 zookeeper。我正在创建复制因子为 2 的主题，该主题与集群中的代理数量相匹配。此外，偏移复制因子设置为 2，min.insync.replicas值设置为 1 和acks=all。当我强行停止其中一个代理并重新启动它时，我在该代理控制台上低于堆栈跟踪。

java.io.IOException: Client was shutdown before response was read
at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:109)
at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107)
at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196)
at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286)
at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133)
at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132)
at scala.Option.foreach(Option.scala:407)
at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132)
at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)

我在这里有一个与此类似的链接，但不确定它们之间的关系。需要知道这是这个已知问题并忽略它或需要处理它。

注意：故障转移方案工作得非常好。

标签： apache-kafka