java spring-boot kafka 创建topic
Map<String, Object> configs = new HashMap<>();
configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,
"10.200.4.92:9092,10.200.4.93:9092,10.200.4.94:9092");
KafkaAdmin admin = new KafkaAdmin(configs);
NewTopic newTopic = new NewTopic("foo2", 1, (short) 1);
AdminClient adminClient = AdminClient.create(admin.getConfig());
List<NewTopic> topicList = Arrays.asList(newTopic);
adminClient.createTopics(topicList);
adminClient.close(10, TimeUnit.SECONDS);