Spring 云流以编程方式创建和删除主题

Spring cloud stream create and delete topics programmatically

我有一个要求,需要以编程方式创建和删除 Kafka 主题。 org.springframework.cloud.stream.binding.BinderAwareChannelResolverresolveDestination(String channelName) 可以创建主题,但已弃用。 另外,据我所知,无法以编程方式删除 Kafka 主题。

欢迎提出任何实现这一目标的建议!

您可以使用 AdminClient 创建和删除主题。 Spring 启动将 auto-configure 一个 KafkaAdmin 并且你可以使用 kafkaAdmin.getConfigurationProperties() 来创建一个带有 AdminClient.create(props) 的管理客户端(或者你可以只使用你自己的属性)。