[
https://issues.apache.org/jira/browse/KAFKA-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luws updated KAFKA-12729:
-------------------------
Attachment: image-2021-04-29-11-33-24-303.png
> 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
> Priority: Critical
> Attachments: image-2021-04-29-11-33-24-303.png,
> image-2021-04-29-11-33-53-048.png
>
>
> 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)
