[KAFKA-12729] controller leader keep disconnected and block the cluster

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 2.1.1
• Component/s: connect, controller
• Assignee: Unassigned
• Reporter: luws
• Created: 29/Apr/21 03:30
• Updated: 29/Apr/21 03:36

Description

kafka version. 2.12-2.1.1

after zk flash disconnected 

then broker6 become the controller leader

but the other brokers can't connect to the broker6 until we restart the broker6 then the cluster become recover.

 

bandwidth is normal

 

 

 

//代码占位符
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)