Mongo Connect配置override.policy=ALL后仍无法覆盖属性报错是什么原因

问题排查与解决方案 #

• 未重启Kafka Connect服务导致配置未生效
  connector.client.config.override.policy 是Kafka Connect Worker节点的全局配置，修改connect-distributed.properties后必须重启所有运行中的Connect节点，新配置才会加载生效。重启前节点会一直使用默认的None覆盖策略，触发对应报错。
• 修改了非加载路径的配置文件
  确认修改的配置文件是当前Connect进程启动时实际加载的配置：如果运行的是分布式模式，需确认没有误改connect-standalone.properties文件；同时核对启动命令中指定的配置文件路径，避免修改了非加载路径下的无效配置。
• 分布式集群节点配置不一致
  多节点部署的Connect集群需要确保所有Worker节点的connect-distributed.properties都添加了对应配置，仅修改单节点配置时，请求路由到未修改的节点依然会触发报错。
• 配置项拼写错误
  确认connect-distributed.properties中配置的参数拼写完全正确：

connector.client.config.override.policy=ALL

修改完成后可调用Connect的REST接口GET /worker-config查看当前生效的Worker配置，确认该参数值已经变为ALL即可。

内容的提问来源于stack exchange，提问作者roman_