有时候,我们的开发人员填错了"topic"的名字,导致创建了一个新的主题,也不报错,消息都发到了这个错误的kafka主题上。 下游的消费者一直拿不到消息,排查了很久,才发现是名字错了。 我该如何禁止kafka自动创建主题(topic)呢?
在
server.properties
中配置:auto.create.topics.enable=false
每个节点都需要配置,然后重启即可。
配置参考:Kafka Broker配置
谢谢,有用。
你的答案