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

【问题标题】：Kafka: Is it possible to create topic with specified replication factor by java clientKafka：是否可以通过 java 客户端创建具有指定复制因子的主题
【发布时间】：2017-04-05 21:39:08
【问题描述】：

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

您可以逐个主题设置此复制因子

但是从其 java 客户端的javadoc 中，我找不到任何与具有复制因子的createTopic 相关的API。只有它提供的shell脚本才有可能吗？

【问题讨论】：

标签： apache-kafka

【解决方案1】：

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

【讨论】：

谢谢，看来 scala 客户端可以做到。但是来自kafka doc，它说“从0.8.2版本开始，我们鼓励所有新开发使用新的Java生产者。”所以我很感兴趣是否有相应的java客户端API可以做到这一点
恐怕还没有用于创建主题的纯 Java API，但实际上您也可以使用来自 Java 的 AdminUtils。虽然代码看起来有点难看。但是肯定可以为此编写一个 Java 友好的包装器
谢谢，有没有像 javadoc 这样的 scala 客户端 API 文档？或者我应该直接从源代码中找到它们...
看起来这个 API 还没有 scaladoc，所以你可能只需要查看 Kafka 源来弄清楚如何使用这个 Admin APIs
谢谢，scaladoc可以通过./gradlew scaladoc命令生成，结果在源代码./core/build/docs/scaladoc