本文介绍使用Kafka时可能遇到的问题及解决方法。

报错“ERROR: Wile executing topic command : Replication factor: 1 larger than available brokers: 0.”

问题分析:
  • Kafka服务异常,集群Broker退出进程。
  • Kafka服务的ZooKeeper地址错误。
解决方法:
  • 请结合日志排查问题。
  • 请您使用集群配置管理中Kafka组件的ZooKeeper连接地址。

报错“java.net.BindException: Address already in use (Bind failed)”

JMX端口被占用,您可以在命令行前手动指定一个JMX端口即可。示例如下。
JMX_PORT=10101 kafka-topics --zookeeper emr-header-1:2181/kafka-1.0.0 --list