问题描述
我有一个要求，我需要以编程方式创建和删除Kafka主题。 org.springframework.cloud.stream.binding.BinderAwareChannelResolver。 resolveDestination(String channelName)可以创建一个主题，但已弃用。
另外，我也无法以编程方式删除Kafka主题。
欢迎提出任何实现建议！
解决方法
您可以使用AdminClient创建和删除主题。
Spring Boot将自动配置KafkaAdmin，您可以使用kafkaAdmin.getConfigurationProperties()和AdminClient.create(props)创建一个管理客户端（或者您可以只使用自己的属性）。