Kafka:是否可以通过java客户端创建具有指定复制因子的主题?

Question

来自Kafka的官方文档，下面是4.7 Replication

您可以在每个主题的基础上设置此复制因子

但是从它的java客户端的javadoc中，我找不到任何与createTopic有复制因子的API。它是否只能通过它提供的shell脚本实现?

Answer 1

您可以使用kafka.admin包中的AdminUtils.createTopic()方法- https://github.com/apache/kafka/blob/97e61d4ae2feaf0551e75fa8cdd041f49f42a9a5/core/src/main/scala/kafka/admin/AdminUtils.scala#L409-L418