【问题标题】:Failed to set ConnectorClientConfigOverridePolicy to All in Debezium mysql connector in docker无法在 docker 的 Debezium mysql 连接器中将 ConnectorClientConfigOverridePolicy 设置为 All
【发布时间】:2021-05-11 12:45:22
【问题描述】:

尝试通过添加 CONNECTOR_CLIENT_CONFIG_OVERRIDE_POLICY=All 来设置 ConnectorClientConfigOverridePolicy。在启动期间,debezium 连接器失败并显示 ma​​tches all=All。似乎,CONNECTOR_CLIENT_CONFIG_OVERRIDE_POLICY 重复值,而不是“All”,值是“all=All”

Stopping due to error   [org.apache.kafka.connect.cli.ConnectDistributed]
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements interface org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy and which name matches all=All

是错误还是我做错了什么?

使用 debezium docker 1.5

【问题讨论】:

    标签: apache-kafka-connect debezium


    【解决方案1】:

    这部分是错误,部分是错误配置。 环境变量应命名为CONNECT_CONNECTOR_CLIENT_CONFIG_OVERRIDE_POLICY=All

    但同时,处理所有名为 CONNECT_ 的环境变量的启动脚本不检查下划线,因此 CONNECTOR... 也匹配,这打破了进一步的逻辑。

    【讨论】:

      猜你喜欢
      • 2020-08-28
      • 2020-09-28
      • 2020-04-20
      • 2021-08-01
      • 1970-01-01
      • 2019-02-16
      • 2019-11-06
      • 2020-05-13
      • 2016-06-01
      相关资源
      最近更新 更多