我有一个要求,我需要以编程方式创建和删除 Kafka 主题。org.springframework.cloud.stream.binding.BinderAwareChannelResolver
. resolveDestination(String channelName)
可以创建主题,但不推荐使用。此外,我知道无法以编程方式删除 Kafka 主题。
欢迎任何实现这一目标的建议!
我有一个要求,我需要以编程方式创建和删除 Kafka 主题。org.springframework.cloud.stream.binding.BinderAwareChannelResolver
. resolveDestination(String channelName)
可以创建主题,但不推荐使用。此外,我知道无法以编程方式删除 Kafka 主题。
欢迎任何实现这一目标的建议!