You need to enable JavaScript to run this app.
导航
常见问题
最近更新时间:2023.01.16 10:10:16首次发布时间:2023.01.16 10:10:16

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。