java - 如何在 Kafka Admin API 中添加每个主题配置？

Question

List<NewTopic> newKafkaTopicsList = new List<NewTopic>;
NewTopic newTopic = new NewTopic("topicName", getPartitionCount(), 
getReplicationFactor());
newKafkaTopicsList.add(newTopic)

下面是用于创建接受的主题的 adminClient api

List<NewTopic> 

由具有构造函数的 kafka adminClient 提供

NewTopic(java.lang.String name, int numPartitions, short replicationFactor)

和配置方法

configs(java.util.Map<java.lang.String,java.lang.String> configs)

有人可以解释如何将 Map 传递给 Configs 方法吗？

CreateTopicsResult  createTopicsResult = adminClient.createTopics(newKafkaTopicsList);

Answer 1

例如

Map<String, String> configMap = new HashMap<>();
configMap.put("cleanup.policy", "compact");

参见Topic configs更多选择

调用.configs(configMap);