Kafka在产生新话题时复制已删除的话题



我使用KafkaAdminClient在我的Java项目中删除Kafka主题。我删除我的主题,然后生成一个新主题的消息。卡夫卡又创造了我以前的话题。卡夫卡server.log

我在消费者实例上有"allow.auto.create.topics" : "false"配置。

必须在代理的配置中发送auto.create.topics.enable=false。这也取决于你的制作人是如何实现的。在Kafka流的情况下,此属性不应用。

我刚刚遇到了同样的问题,下面是我在我的情况下解决它的方法:

  1. 您不再有任何活动订阅该主题,因此您应该在删除之前取消订阅。
  2. 你必须关闭为该主题生成消息的生产者。

显然,如果你不这样做,Kafka会保留一些与主题的连接,并且不会让它被删除。

最新更新