apache-kafka - Spring Cloud Stream 以编程方式创建和删除主题

Question

我有一个要求，我需要以编程方式创建和删除 Kafka 主题。org.springframework.cloud.stream.binding.BinderAwareChannelResolver. resolveDestination(String channelName)可以创建主题，但不推荐使用。此外，我知道无法以编程方式删除 Kafka 主题。

欢迎任何实现这一目标的建议！

Answer 1

您可以使用 anAdminClient创建和删除主题。Spring Boot 将自动配置 a KafkaAdmin，您可以使用它kafkaAdmin.getConfigurationProperties()来创建一个管理客户端AdminClient.create(props)（或者您可以只使用自己的属性）。