我们正在使用kafka connect mqsource是一个连接器,用于将数据从ibmq复制到apachekafka中。
我们目前使用的是mq版本7.5.0.8,但从自述文件中可以看出,它只支持ibm mq v8.0或更高版本。
如果我们使用这个代码库,我们将面临一些异常
{"name":"kafka-mq-connector", "connector":{"state":"RUNNING", "worker_id":"192.888.002.05:7070"}, "tasks":[{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException:com.ibm.msg.client.jms.DetailedJMSException: JMSCC0091: The provider factory for connection type 'com.ibm.msg.client.wmq' could not be loaded.\n\t
at com.mqkafka.kafkaconnector.MQReader.configure(MQReader.java:122).\n\t
at com.mqkafka.kafkaconnector.MQSourceTask.start(MQSourceTask.java:36).\n\t
at org.apache.kafka.connect.runtime.WorkerSourceTask.execut(WorkerSourceTask.java:157).\n\t
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170).\n\t
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214).\n\t
at
我不确定是兼容性问题还是其他问题。请您帮助修复需要使这个连接器的工作,提前感谢。
暂无答案!
目前还没有任何答案,快来回答吧!