Kafka：是否可以通过 java 客户端创建具有指定复制因子的主题
Kafka: Is it possible to create topic with specified replication factor by java client
来自Kafka的官方文档，下面说来自4.7 Replication
you can set this replication factor on a topic-by-topic basis
但是从其 java 客户端的 javadoc 中，我找不到任何 API 与具有复制因子的 createTopic 相关。是否只能通过它提供的 shell 脚本才能实现？
您可以使用 kafka.admin 包中的 AdminUtils.createTopic() 方法 - https://github.com/apache/kafka/blob/97e61d4ae2feaf0551e75fa8cdd041f49f42a9a5/core/src/main/scala/kafka/admin/AdminUtils.scala#L409-L418
来自Kafka的官方文档，下面说来自4.7 Replication
you can set this replication factor on a topic-by-topic basis
但是从其 java 客户端的 javadoc 中，我找不到任何 API 与具有复制因子的 createTopic 相关。是否只能通过它提供的 shell 脚本才能实现？
您可以使用 kafka.admin 包中的 AdminUtils.createTopic() 方法 - https://github.com/apache/kafka/blob/97e61d4ae2feaf0551e75fa8cdd041f49f42a9a5/core/src/main/scala/kafka/admin/AdminUtils.scala#L409-L418