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

wztqucjr  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(490)

我有一个要求,我需要创建和删除Kafka主题编程。 org.springframework.cloud.stream.binding.BinderAwareChannelResolver . resolveDestination(String channelName) 无法创建主题,但已弃用。而且,我知道没有办法以编程方式删除Kafka的主题。
欢迎提出任何实现这一目标的建议!

vdgimpew

vdgimpew1#

你可以使用 AdminClient 创建和删除主题。spring boot将自动配置 KafkaAdmin 你可以用 kafkaAdmin.getConfigurationProperties() 使用创建管理客户端 AdminClient.create(props) (或者你可以使用你自己的财产)。

相关问题