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

问题描述

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

欢迎提出任何实现建议！

解决方法

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