飼い葉桶なしでjava apiを使ってカフカトピックを作成する

Question

kafka 0.10.1.xのzookeeper依存関係なしでkafkaトピックを作成する方法は？ トピックが作成されたスレッドを見ましたが、zookeeper、zkクライアントなどを使用しました。私はJavaのみを使用したいので、scalaの依存関係はすでにkafka 0.10がzookeeperを使用していないためです。

Answer 1

はい、ZooKeeperに接続せずにカフカのトピックを作成することは可能です。

この機能はKafka 0.10.1のブローカで使用できますが、AdminClient（ブローカ機能を使用するクライアントコード）はKafka 0.11にのみ追加されています。

がKafkaAdminClient.createTopics()を参照してください：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/admin/KafkaAdminClient.html#createTopics-java.util.Collection-org.apache.kafka.clients.admin.CreateTopicsOptions-

Answer 2

機能は残業レガシーものに代わる新しい管理クライアントAPIを0.11.0.0ため、クライアント側で使用可能です。 ここで簡単な使用例を見つけることができます：https://github.com/ppatierno/kafka-playground/blob/master/src/main/java/org/apache/kafka/playground/CreateTopic.java