Strimzi教程部署Debezium MySQL连接器报配置错误如何解决？

先解决配置缺失的400报错 #

• 先确认配置校验错误的具体字段：执行kubectl -n kafka logs <Kafka Connect Pod名称> | grep "Invalid configuration value"，直接定位缺失的必填项，不要只依赖CR返回的模糊提示。
• 如果你用凭证文件引用的配置方式，必须提前完成以下操作：给Kafka Connect集群创建包含MySQL账号密码的Secret，并且在KafkaConnect CR的spec.externalConfiguration.volumes里挂载了这个Secret到/opt/kafka/external-configuration/connector-config路径，否则Kafka Connect无法解析${file:}格式的变量，会判定database.user和database.password为空。
• 如果你直接用明文配置，先删除旧的连接器再重新创建，避免更新缓存问题：
  1. 执行kubectl -n kafka delete kctr inventory-connector
  2. 替换配置里的database.user和database.password为明文：

     database.user: "debezium"
     database.password: "dbz"
     

  3. 重新apply配置文件，检查状态。
• 部分版本的Debezium MySQL连接器还需要额外填写必填项，比如database.allowPublicKeyRetrieval: "true"，如果日志提示缺少相关配置，补上即可。

数据库连接地址问题说明 #

教程里的IP填写规则是针对「MySQL跑在minikube宿主机上」的场景，Kafka Connect运行在minikube内部，访问宿主机服务需要用宿主机在minikube网络中的网关地址，不同minikube驱动的网关地址不同：

• Docker驱动的minikube本身运行在一个Docker容器内，要访问宿主机上的MySQL容器，不要填minikube ip返回的地址（那是minikube容器本身的IP），也不要填localhost（对于Kafka Connect Pod来说，localhost指向Pod本身），正确的获取方式是执行docker inspect minikube | grep Gateway，拿到的网关地址就是宿主机在minikube网络中的地址，填到database.hostname即可。
• 确认你的MySQL容器端口绑定到了0.0.0.0，而不是127.0.0.1：执行docker port <MySQL容器名>，如果返回结果是127.0.0.1:3306->3306/tcp，说明只有宿主机本地能访问，minikube内部无法连接，需要重新启动MySQL容器，把端口绑定规则改为0.0.0.0:3306->3306/tcp。

连通性验证 #

配置校验通过后，进入Kafka Connect Pod验证数据库连通性：

kubectl -n kafka exec -it <Kafka Connect Pod名> -- bash
# 执行连通性测试
telnet <你填的database.hostname> 3306
# 也可以用mysql客户端直接登录验证
mysql -h <database.hostname> -u debezium -pdbz

如果能正常连接，说明地址配置正确，连接器就能正常运行。

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