我们最近切换到 Reactive Kafka。如果在为主题创建流时主题存在，kafka 似乎不会抛出任何错误。为什么会这样？
我知道一个主题的存在可以用AdminUtils.topicExists(zkClient, topicName). 有没有办法强制响应式 kafka 在创建流之前检查主题是否存在？
问问题
275 次
1 回答
0
这可以在 Kafka Broker 设置中进行配置。相关配置为auto.create.topics.enable，默认为 true。将其设置为 false 应该会导致底层 Apache Kafka 客户端在主题不存在时抛出错误，而不是自动创建新主题。
有关更多信息，请参阅文档。
于 2017-09-18T22:50:22.793 回答