如何使用spring-kafka库动态创建和删除Topics?谢谢。
我尝试的是AdminClient。但我需要某种包装器,它可以帮助我通过使用spring-kafka来实现这一点,而无需创建自定义类并对其进行测试。
spring-kafka已经有了一个用于创建Topic的a。但是对于删除,我不知道。
发布于 2021-07-02 01:50:40
您可以使用AdminClient来执行此类操作。
https://kafka.apache.org/27/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.html
https://stackoverflow.com/questions/68213880
复制相似问题