[Java] kafka create topic

728x90

public static void create(String name) {
   AdminClient client = AdminClient.create(properties());
   NewTopic topic = new NewTopic(
      name,
      (int)conf().get("partition"),
      Short.parseShort(String.valueOf(conf().get("replication.factor"))));

   client.createTopics(Collections.singleton(topic));
   client.close();
}

https://stackoverflow.com/questions/64077406/why-is-adminclient-not-failing-when-creating-a-topic-with-kafka-cluster-not-runn

Why is AdminClient not failing when creating a topic with Kafka cluster not running?

https://stackoverflow.com/questions/56539335/how-to-configure-kafka-topic-retention-policy-during-creation-with-spring

How to configure kafka topic retention policy during creation with Spring?

https://stackoverflow.com/questions/27036923/how-to-create-a-topic-in-kafka-through-java/70729733#70729733

How to create a Topic in Kafka through Java

 

728x90

저작자표시비영리

'공부' 카테고리의 다른 글

[Java] MySQL get column name  (0)	2022.01.16
[Spring] Profile  (0)	2022.01.14
[Java] kafka create topic  (0)	2022.01.14
[Java] StringEscapeUtils.escapeJava(str);  (0)	2022.01.14
[Oracle] char, varchar, varchar2  (0)	2022.01.14
[Spring Boot] How to fully disable swagger-ui in spring-boot?(/swagger-ui.html should return 404)  (0)	2022.01.12