我使用KafkaAdminClient在我的Java项目中删除Kafka主题。我删除我的主题,然后生成一个新主题的消息。卡夫卡又创造了我以前的话题。卡夫卡server.log
我在消费者实例上有"allow.auto.create.topics" : "false"
配置。
必须在代理的配置中发送auto.create.topics.enable=false
。这也取决于你的制作人是如何实现的。在Kafka流的情况下,此属性不应用。
我刚刚遇到了同样的问题,下面是我在我的情况下解决它的方法:
- 您不再有任何活动订阅该主题,因此您应该在删除之前取消订阅。
- 你必须关闭为该主题生成消息的生产者。
显然,如果你不这样做,Kafka会保留一些与主题的连接,并且不会让它被删除。