我有一个要求,我需要创建和删除Kafka主题编程。 org.springframework.cloud.stream.binding.BinderAwareChannelResolver . resolveDestination(String channelName) 无法创建主题,但已弃用。而且,我知道没有办法以编程方式删除Kafka的主题。欢迎提出任何实现这一目标的建议!
org.springframework.cloud.stream.binding.BinderAwareChannelResolver
resolveDestination(String channelName)
vdgimpew1#
你可以使用 AdminClient 创建和删除主题。spring boot将自动配置 KafkaAdmin 你可以用 kafkaAdmin.getConfigurationProperties() 使用创建管理客户端 AdminClient.create(props) (或者你可以使用你自己的财产)。
AdminClient
KafkaAdmin
kafkaAdmin.getConfigurationProperties()
AdminClient.create(props)
1条答案
按热度按时间vdgimpew1#
你可以使用
AdminClient
创建和删除主题。spring boot将自动配置KafkaAdmin
你可以用kafkaAdmin.getConfigurationProperties()
使用创建管理客户端AdminClient.create(props)
(或者你可以使用你自己的财产)。