我们最近换成了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客户机抛出错误,而不是自动创建新主题。更多信息请参见文档。