使用Java创建Kafka主题（topic）

kafka 1.0.0

添加kafka-clients maven依赖

<dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
  <version>1.0.0</version>
</dependency>

使用AdminClient创建topic

public static void main(String[] args) {
    Properties config = new Properties();
    config.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9092");

    AdminClient admin = AdminClient.create(config);

    Map<String, String> configs = new HashMap<>();
    int partitions = 1;
    short replication = 1;

    CreateTopicsResult result = admin.createTopics(Arrays.asList(new NewTopic("mytopic", partitions, replication).configs(configs)));
}