当我尝试使用 Confluent-Kafka AdminClient Delete_topic 删除 Kafka 主题时,该主题暂时被删除,但几秒钟后会重新创建。
我尝试了Producer.flush() , Consumer.unsubscribe()以避免重新创建,但仍然无法弄清楚为什么要重新创建它。
但是,当我尝试在整个过程完成后使用单个 python 脚本手动删除同一主题时,它会被删除。
当我尝试使用 Confluent-Kafka AdminClient Delete_topic 删除 Kafka 主题时,该主题暂时被删除,但几秒钟后会重新创建。
我尝试了Producer.flush() , Consumer.unsubscribe()以避免重新创建,但仍然无法弄清楚为什么要重新创建它。
但是,当我尝试在整个过程完成后使用单个 python 脚本手动删除同一主题时,它会被删除。