JDBC连接IBM DB2 AS400失败求助（Kafka Connect配置场景）

这个java.sql.SQLException: The application requester cannot establish the connection错误是AS400 JDBC连接最常见的问题之一，咱们一步步来排查：

1. 先确认JDBC驱动是否被Kafka Connect正确加载 #

你提到jt400.jar放在/confluent-4.1.0/share/java/kafka-connect-jdbc\jt400.jar，这里有几个细节要注意：

• 如果是Linux/Unix环境，路径里的反斜杠\要改成正斜杠/，不然系统识别不了路径
• 检查Kafka Connect的worker配置（比如connect-distributed.properties或connect-standalone.properties）里的plugin.path是否包含/confluent-4.1.0/share/java/kafka-connect-jdbc——Connect只会加载指定插件目录下的jar包，如果这个路径没在plugin.path里，驱动就找不到
• 另外要确认jt400.jar的版本和你的IBM i（AS400）版本兼容，比如IBM i 7.3及以上建议用jt400 9.0+的版本，老驱动可能不支持新系统的安全协议或特性

2. 检查JDBC连接URL的正确性 #

你的连接URL是jdbc:as400://IP_ADDRESS:PORT;libraries=DATABASE;，这里有几个可能的坑：

• 端口问题：AS400 JDBC默认端口是446，如果你填了其他端口，要确认IBM i上的QSERVER服务（负责DRDA连接）确实监听这个端口，或者联系管理员确认端口配置
• libraries参数：这里的DATABASE应该是你要访问的IBM i库名（比如MYLIB），如果有多个库用逗号分隔（libraries=LIB1,LIB2）。另外可以尝试加上naming=system参数，指定用系统命名规则，避免和SQL命名规则冲突
• 冗余分号：URL末尾的分号可以去掉，有些驱动会对多余的分隔符敏感
• 可以试试把用户名密码直接放到URL里测试（临时排查用）：jdbc:as400://IP_ADDRESS:446;libraries=YOUR_LIB;user=USER_NAME;password=PASSWORD，看是否能绕过Connect配置的认证问题

3. 排查网络和权限问题 #

这是最容易忽略的点：

• 先用ping IP_ADDRESS确认Kafka Connect服务器能通IBM i，再用telnet IP_ADDRESS PORT或nc -zv IP_ADDRESS PORT测试端口是否开放——如果不通，说明防火墙（IBM i端或中间网络）拦截了DRDA端口，需要开放对应端口
• 用同一个用户名密码，通过其他工具（比如IBM i Access Client Solutions、DB2命令行）连接IBM i，确认是否能成功访问指定库：如果其他工具也连不上，那就是用户权限问题，需要检查IBM i上的用户profile是否有连接权限，以及库的读权限

4. 查看Kafka Connect日志获取详细错误信息 #

不要只看表面的错误提示，Connect的日志（默认在/confluent-4.1.0/logs/connect.log）里会有完整的错误栈，能帮你定位根本原因：

• 如果日志里有ClassNotFoundException: com.ibm.as400.access.AS400JDBCDriver，说明驱动没加载到，回到第一步检查路径和plugin配置
• 如果是Connection refused，就是网络/端口问题
• 如果是Invalid authorization specification，就是用户名密码或权限问题

参考配置示例 #

{
  "name": "SOURCE_NAME",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "tasks.max": "1",
    "topic.prefix": "TOPIC_NAME",
    "connection.url": "jdbc:as400://IP_ADDRESS:446;libraries=YOUR_TARGET_LIBRARY;naming=system",
    "connection.user": "USER_NAME",
    "connection.password": "PASSWORD",
    "key.converter": "io.confluent.connect.avro.AvroConverter",
    "key.converter.schema.registry.url": "http://localhost:8081",
    "value.converter": "io.confluent.connect.avro.AvroConverter",
    "value.converter.schema.registry.url": "http://localhost:8081",
    "mode": "incrementing",
    "incrementing.column.name": "YOUR_INCREMENT_ID_COLUMN"
  }
}

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