Apache PLC4X对接ProSys OPC UA模拟器与Apache Kafka故障排查请求

1. 验证OPC UA连接配置 #

• 检查Connect配置文件中plc4x.connection-string格式正确性，示例：opcua://<username>:<password>@<host>:<port>?securityPolicy=...&securityMode=...
  • 确保ProSys模拟器的端点URL、用户名/密码、安全策略/模式与配置完全匹配
  • 用PLC4X官方OPC UA客户端工具直接连接模拟器，确认能正常读取数据，排除连接层面问题

2. 检查Kafka Connect与集群连通性 #

• 确认bootstrap.servers配置的虚拟机Kafka地址（IP:端口）可访问：
  • 在Connect所在机器执行telnet <kafka-host> <kafka-port>或nc -zv <kafka-host> <kafka-port>测试网络连通
  • 检查Kafka集群listeners配置，确认未仅绑定localhost，允许外部连接

3. 校验数据映射与Topic配置 #

• 检查plc4x.topic指定的Topic是否存在，若需自动创建，确认Kafkaauto.create.topics.enable设为true
• 确保plc4x.tag-expressions中的标签路径与ProSys模拟器节点路径完全一致（区分大小写，注意节点ID格式如ns=2;s=MyTag）

4. 分析Connect日志定位错误 #

• 查看Kafka Connect日志（默认路径kafka/logs/connect.log），提取关键错误信息：
  • 若为Connection refused：排查OPC UA端点或Kafka集群的端口/防火墙设置
  • 若为Security token rejected：检查OPC UA安全策略、证书信任（ProSys是否需导入Connect证书）
  • 若为Topic authorization failed：确认Kafka ACL允许Connect用户写入目标Topic

5. 检查版本兼容性 #

• 确保PLC4X Kafka Connect插件版本与Kafka集群版本兼容（推荐PLC4X ≥0.12.0，Kafka ≥2.8.0）
• 避免跨大版本混合使用组件（如Kafka 3.x搭配PLC4X 0.10.x）

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