【发布时间】：2018-02-06 07:27:36
【问题描述】：
我正在尝试使用 Kafka Connect JMS Source Connect（通过 datamountaineer）连接到 Solace JMS，但我一直在 smfclient4 获得未授权。我确定用户名和密码是正确的。日志如下。
[2018-01-10 07:52:49,859] INFO Connecting to host 'orig=tcp://solace-ip, scheme=tcp://, host=solace-ip' (host 1 of 1, smfclient 2, attempt 1 of 1, this_host_attempt: 1 of 1) (com.solacesystems.jcsmp.protocol.impl.TcpClientChannel:2337)
[2018-01-10 07:52:50,031] INFO Connected to host 'orig=tcp://solace-ip, scheme=tcp://, host=solace-ip' (smfclient 2) (com.solacesystems.jcsmp.protocol.impl.TcpClientChannel:2341)
[2018-01-10 07:52:50,222] INFO Channel Closed (smfclient 2) (com.solacesystems.jcsmp.protocol.impl.TcpClientChannel:460)
[2018-01-10 07:52:50,240] INFO Connecting to host 'orig=tcp://solace-ip, scheme=tcp://, host=solace-ip' (host 1 of 1, smfclient 4, attempt 1 of 2147483647, this_host_attempt: 1 of 1) (com.solacesystems.jcsmp.protocol.impl.TcpClientChannel:2337)
[2018-01-10 07:52:50,591] INFO (Client name: client-dns.c/3570/#00320002 Local addr: client-ip:52016 Remote addr: solace-ip:55003) - Error Response (401) - Unauthorized (com.solacesystems.jcsmp.protocol.impl.TcpChannel:226)
[2018-01-10 07:52:50,595] INFO Connection attempt failed to host 'solace-ip' ConnectException ((Client name: client-dns.c/3570/#00320002 Local addr: client-ip:52016 Remote addr: solace-ip:55003) - ) com.solacesystems.jcsmp.JCSMPErrorResponseException: 401: Unauthorized [Subcode:1] ((Client name: client-dns.c/3570/#00320002 Local addr: client-ip:52016 Remote addr: solace-ip:55003) - ) (com.solacesystems.jcsmp.protocol.impl.TcpClientChannel:2377)
Kafka Connect 配置如下。我需要将用户名：密码添加到 connect.jms.url。如果没有，我会获得未经身份验证的身份验证。
connector.class: "com.datamountaineer.streamreactor.connect.jms.source.JMSSourceConnector"
connect.jms.initial.context.factory: "com.solacesystems.jndi.SolJNDIInitialContextFactory"
connect.jms.initial.context.extra.params: "SOLACE_JMS_VPN=my_vpn"
connect.jms.connection.factory: "MY.CF"
connect.jms.url: "smf://username:password@solace-ip"
connect.jms.username: "username@my_vpn"
connect.jms.kcql: "insert into kafka_topic select * from solaceQ WITHTYPE QUEUE"
我尝试标记datamountaineer，但找不到datamountaineer标记。
关于这个问题的任何线索？除此之外，smfclient 2、4、6、8 是什么意思？
非常感谢！
【问题讨论】：
标签： apache-kafka-connect solace