У меня настроена отработка отказа для Kafka с двумя брокерами и одним 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)
У меня есть одна ссылка, похожая на эту здесь , но я не уверен, как они связаны. Необходимо знать, что это за известная проблема, и игнорировать ее или позаботиться о ней.
Примечание. Сценарий отработки отказа работает отлично.