0

我有一个要求,我需要以编程方式创建和删除 Kafka 主题。org.springframework.cloud.stream.binding.BinderAwareChannelResolver. resolveDestination(String channelName)可以创建主题,但不推荐使用。此外,我知道无法以编程方式删除 Kafka 主题。

欢迎任何实现这一目标的建议!

4

1 回答 1

1

您可以使用 anAdminClient创建和删除主题。Spring Boot 将自动配置 a KafkaAdmin,您可以使用它kafkaAdmin.getConfigurationProperties()来创建一个管理客户端AdminClient.create(props)(或者您可以只使用自己的属性)。

于 2020-08-24T14:26:42.957 回答