如何解决Spring Cloud Stream以编程方式创建和删除主题
我有一个要求,我需要以编程方式创建和删除Kafka主题。 org.springframework.cloud.stream.binding.BinderAwareChannelResolver
。 resolveDestination(String channelName)
可以创建一个主题,但已弃用。
另外,我也无法以编程方式删除Kafka主题。
欢迎提出任何实现建议!
解决方法
您可以使用AdminClient
创建和删除主题。
Spring Boot将自动配置KafkaAdmin
,您可以使用kafkaAdmin.getConfigurationProperties()
和AdminClient.create(props)
创建一个管理客户端(或者您可以只使用自己的属性)。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。