apache-kafka - 反应式 Kafka：为不存在的主题创建流时没有错误

Question

我们最近切换到 Reactive Kafka。如果在为主题创建流时主题存在，kafka 似乎不会抛出任何错误。为什么会这样？

我知道一个主题的存在可以用AdminUtils.topicExists(zkClient, topicName). 有没有办法强制响应式 kafka 在创建流之前检查主题是否存在？

Answer 1

这可以在 Kafka Broker 设置中进行配置。相关配置为auto.create.topics.enable，默认为 true。将其设置为 false 应该会导致底层 Apache Kafka 客户端在主题不存在时抛出错误，而不是自动创建新主题。

有关更多信息，请参阅文档。