React式kafka:为不存在的主题创建流时没有错误

rryofs0p  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(321)

我们最近换成了React型Kafka。在为主题创建流时,如果主题存在,kafka似乎不会抛出任何错误。为什么会这样?
我知道主题的存在可以用 AdminUtils.topicExists(zkClient, topicName) . 有没有办法强迫被动Kafka在创建流之前检查主题本身是否存在?

mklgxw1f

mklgxw1f1#

这可以在kafka代理设置中配置。相关配置为 auto.create.topics.enable 默认情况下这是真的。如果主题不存在,将其设置为false会导致底层apachekafka客户机抛出错误,而不是自动创建新主题。
更多信息请参见文档。

相关问题