Q1：TimeoutException

此报错表示超时，常见于网络不通，可通过 telnet 命令测试网络连通性。具体命令如下：

telnet {Kafka Broker 地址} 9092

如果无法连通，请检查 Kafka Client 所处环境与 EMR Kafka 集群的网络连通性，例如 Client 与 Broker 是否处于同一个 VPC（如果不在同一个 VPC，是否通过给 Broker 绑定公网 IP 等机制打通 Client 与 Broker 之间的网络），以及 Broker ECS 安全组规则配置中是否把 9092 端口开放给了 Client。
如果判断网络连通性没有问题，可以查看 Kafka Broker 机器上的日志，排查 Kafka 进程是否正常服务，是否有报错。

Q2：Leader is not available

常见于 Topic 创建中、服务升级中，如果持续报错可能是 Topic 未创建或者服务端问题。可以通过 kafka-topics.sh 脚本检查 Topic 状态，以及查看 Kafka Broker 机器上的日志，排查 Kafka 进程是否正常服务，是否有报错。

Q3：Leader is not elected

常见于 Topic 创建中和初始化时会短暂报该错误。如果持续报错，可能是因为没有创建 Topic。可以通过 kafka-topics.sh 脚本检查 Topic 状态，以及查看 Kafka Broker 机器上的日志，排查 Kafka 进程是否正常服务，是否有报错。

Q4：DisconnectedException

常见于网络问题导致的超时或者连接长期 idle 状态，服务端断开连接。可以参考上文中 TimeoutException 的排查方法，或者尝试重新连接 Kafka。