java - 创建 Kafka 主题 :- replication factor larger than available brokers 时出错

Question

我正在尝试使用以下代码通过 AdminCommand 创建一个 kafka 主题 Source

 ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.MODULE$);
    AdminUtils.createTopic(zkClient, "pa_reliancepoc_telecom_usageevent", 10, 2, new Properties());

但出现以下异常

Exception in thread "main" kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0
at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:155)

但是，我可以使用 shell 命令创建主题。

Answer 1

在你的代码中，

 AdminUtils.createTopic(zkClient, "pa_reliancepoc_telecom_usageevent", 10, 2, new Properties());

第四个参数是复制因子。因此，您尝试创建一个名称为 pa_reliancepoc_telecom_usageevent 的主题，分区 count of 10 和 replication of 2。因此，在创建主题时，两个 kafka broker 应该可用。如果少于两个可用，那么您将得到以下异常。

Exception in thread "main" kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0
at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:155)

确保您正在运行具有两个代理节点的kafka 集群，并且这两个节点在创建主题时应该处于 Activity 状态。

要在集群中运行 kafka，请参阅 this link 中的步骤 6