我们最近换成了React型Kafka。在为主题创建流时，如果主题存在，kafka似乎不会抛出任何错误。为什么会这样？我知道主题的存在可以用 AdminUtils.topicExists(zkClient, topicName) . 有没有办法强迫被动Kafka在创建流之前检查主题本身是否存在？
AdminUtils.topicExists(zkClient, topicName)
mklgxw1f1#
这可以在kafka代理设置中配置。相关配置为 auto.create.topics.enable 默认情况下这是真的。如果主题不存在，将其设置为false会导致底层apachekafka客户机抛出错误，而不是自动创建新主题。更多信息请参见文档。
auto.create.topics.enable
1条答案
按热度按时间mklgxw1f1#
这可以在kafka代理设置中配置。相关配置为
auto.create.topics.enable默认情况下这是真的。如果主题不存在，将其设置为false会导致底层apachekafka客户机抛出错误，而不是自动创建新主题。更多信息请参见文档。