如何使用spring-kafka库动态创建和删除主题



如何使用spring-kafka库动态创建和删除Topics?谢谢

我试过的是AdminClient。但我需要某种包装器,它可以帮助我通过使用spring-kafka实现这一点,而无需创建自定义类并对其进行测试

CCD_ 5已经有一个来创建CCD_ 6。但对于deletetion,我不知道。

您可以使用AdminClient进行此类操作。

https://kafka.apache.org/27/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.html

最新更新