我有一个要求，我需要创建和删除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)（或者你可以使用你自己的财产）。