RabbitMQ Source Connector配置异常：SSL连接触发java.io.IOException错误

部署RabbitMQ Source Connector时收到400 Bad Request错误，连接创建阶段反复出现java.io.IOException，具体细节如下：

配置信息 #

{
    "name": "rabbitmq-source-connector-test",
    "config": {
        "connector.class": "io.confluent.connect.rabbitmq.RabbitMQSourceConnector",
        "tasks.max": "1",
        "kafka.topic": "Rabbitmq.Event.Push.test",
        "rabbitmq.host": "xxxxx.myhost.net",
        "rabbitmq.port": "5671",
        "rabbitmq.username": "****",
        "rabbitmq.password": "****",
        "confluent.topic.bootstrap.servers": "xxxxxxxx.xxxxxxxxx.us-central1.gcp.confluent.cloud:9092",
        "confluent.topic.sasl.jaas.config": "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"****\" password=\"****\";",
        "confluent.topic.security.protocol": "SASL_SSL",
        "confluent.topic.sasl.mechanism": "PLAIN",
        "rabbitmq.security.protocol": "SSL",
        "rabbitmq.https.ssl.truststore.location": "/tmp/truststore.jks",
        "rabbitmq.https.ssl.truststore.password": "****",
        "rabbitmq.https.ssl.keystore.location": "/tmp/keystore.jks",
        "rabbitmq.https.ssl.keystore.password": "****",
        "rabbitmq.queue": "santosh.test"
    }
}

CURL请求返回错误 #

HTTP/1.1 400 Bad Request
content-length: 562
content-type: application/json
date: Thu, 05 Dec 2024 00:52:37 GMT
x-ratelimit-limit: 0
x-ratelimit-remaining: 0
x-ratelimit-reset: 0
via: 1.1 google
{"error_code":400,"message":"Connector configuration is invalid and contains the following 5 error(s):\nError java.io.IOException occurred during connection creation: null\nError java.io.IOException occurred during connection creation: null\nError java.io.IOException occurred during connection creation: null\nError java.io.IOException occurred during connection creation: null\nError java.io.IOException occurred during connection creation: null\nYou can also find the above list of errors at the endpoint <code>/connector-plugins/{connectorType}/config/validate</code>"}

环境补充信息 #

• 连接器运行在Kubernetes环境
• RabbitMQ插件版本为1.7.4
• 已确认端口5671处于开放状态

已执行的排查步骤 #

• 验证SSL配置（truststore和keystore的路径及密码）
• 检查网络与防火墙设置
• 通过/connector-plugins/{connectorType}/config/validate端点验证配置
• 查看RabbitMQ与Kafka日志以获取更多上下文

尽管执行了上述步骤，问题仍未解决，恳请提供解决思路或建议！

连接器Pod错误日志 #

Wed, Dec 4 2024 4:47:07 pm[2024-12-05 00:47:07,639] ERROR An unexpected connection driver error occured (com.rabbitmq.client.impl.ForgivingExceptionHandler) Wed, Dec 4 2024 4:47:07 pmjava.net.SocketException: Connection or outbound has been closed Wed, Dec 4 2024 4:47:07 pm at java.base/sun.security.ssl.SSLSocketOutputRecord.deliver(SSLSocketOutputRecord.java:291) Wed, Dec 4 2024 4:47:07 pm at java.base/sun.security.ssl.SSLSocketImpl$AppOutputStream.write(SSLSocketImpl.java:1308) Wed, Dec 4 2024 4:47:07 pm at java.base/java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) Wed, Dec 4 2024 4:47:07 pm at java.base/java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) Wed, Dec 4 2024 4:47:07 pm at java.base/java.io.DataOutputStream.flush(DataOutputStream.java:128) Wed, Dec 4 2024 4:47:07 pm at com.rabbitmq.client.impl.SocketFrameHandler.flush(SocketFrameHandler.java:197) Wed, Dec 4 2024 4:47:07 pm at com.rabbitmq.client.impl.AMQConnection.flush(AMQConnection.java:636) Wed, Dec 4 2024 4:47:07 pm at com.rabbitmq.client.impl.AMQCommand.transmit(AMQCommand.java:134) Wed, Dec 4 2024 4:47:07 pm at com.rabbitmq.client.impl.AMQChannel.quiescingTransmit(AMQChannel.java:455) Wed, Dec 4 2024 4:47:07 pm at com.rabbitmq.client.impl.AMQChannel.quiescingTransmit(AMQChannel.java:434) Wed, Dec 4 2024 4:47:07 pm at

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