How to programmatically create a Kafka 2.3.0 topic in Java

Question

I want to create a topic in Kafka (2.12-2) with Java API , i tried the old codes but they don't work for me any one can help me ? i need to create a topic and then i would like to insert it into the producer and a consumer

this one didn't work for me maybe the reason is the version of Kafka api — medidriss, Jul 15 '19 at 10:50
there are multiple answer for each version under that post, have you tried everything? — Deadpool, Jul 15 '19 at 10:52

Giorgos Myrianthous · Accepted Answer · 2019-07-15T12:22:46.880

3

How about this one?

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

AdminClient adminClient = KafkaAdminClient.create(props);

CreateTopicsResult res = adminClient.createTopics(
        Stream.of("foo", "bar", "baz").map(
                name -> new NewTopic("my-topic-name", 3, (short) 1)
        ).collect(Collectors.toList())
);

res.all().get();

edited Jul 15 '19 at 12:22

answered Jul 15 '19 at 12:13

Giorgos Myrianthous

30,279
17
114
133

Properties props = new Properties(); after this i can't find put() method ?? – medidriss Jul 15 '19 at 13:40
@medidriss What do you mean? Have you imported `Properties`? – Giorgos Myrianthous Jul 15 '19 at 14:44
yeah , but i solve it by using Map for the config – medidriss Jul 15 '19 at 16:51
yes thank you @Giorgos Myrianthous – medidriss Jul 31 '19 at 08:54

How to programmatically create a Kafka 2.3.0 topic in Java

1 Answers1