luws created KAFKA-12729:
----------------------------
Summary: controller leader keep disconnected and block the cluster
Key: KAFKA-12729
URL: https://issues.apache.org/jira/browse/KAFKA-12729
Project: Kafka
Issue Type: Bug
Components: controller, KafkaConnect
Affects Versions: 2.1.1
Reporter: luws
kafka version. 2.12-2.1.1
after zk flash disconnected
then broker6 become the controller leader
but the other broker can't connect to the broker6 until we restart the broker6
then the cluster become recover.
bandwidth is normal
!image-2021-04-29-11-24-22-704.png!
!image-2021-04-29-11-27-12-924.png!
!image-2021-04-29-11-27-35-679.png!
!image-2021-04-29-11-25-41-208.png!
!image-2021-04-29-11-26-34-894.png!
{code:java}
//代码占位符
Connection to 6 was disconnected before the response was read at
org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:100)
at
kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:99)
at
kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:192)
at
kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:274)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:132)
at
kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:131)
at scala.Option.foreach(Option.scala:257) at
kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:131)
at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:113)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:82){code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
