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

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);

最佳答案

例如

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

有关更多选项，请参见Topic configs

致电.configs(configMap);

关于java - 如何在Kafka Admin API中添加每个主题的配置？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/50361117/