Spring 云流以编程方式创建和删除主题
Spring cloud stream create and delete topics programmatically
我有一个要求,需要以编程方式创建和删除 Kafka 主题。 org.springframework.cloud.stream.binding.BinderAwareChannelResolver
。 resolveDestination(String channelName)
可以创建主题,但已弃用。
另外,据我所知,无法以编程方式删除 Kafka 主题。
欢迎提出任何实现这一目标的建议!
您可以使用 AdminClient
创建和删除主题。
Spring 启动将 auto-configure 一个 KafkaAdmin
并且你可以使用 kafkaAdmin.getConfigurationProperties()
来创建一个带有 AdminClient.create(props)
的管理客户端(或者你可以只使用你自己的属性)。
我有一个要求,需要以编程方式创建和删除 Kafka 主题。 org.springframework.cloud.stream.binding.BinderAwareChannelResolver
。 resolveDestination(String channelName)
可以创建主题,但已弃用。
另外,据我所知,无法以编程方式删除 Kafka 主题。
欢迎提出任何实现这一目标的建议!
您可以使用 AdminClient
创建和删除主题。
Spring 启动将 auto-configure 一个 KafkaAdmin
并且你可以使用 kafkaAdmin.getConfigurationProperties()
来创建一个带有 AdminClient.create(props)
的管理客户端(或者你可以只使用你自己的属性)。