我无法让kafka connect jdbc与 Kafka 0.10.1
在 HDInsight Cluster
. 以下是我迄今为止经历的步骤:
我克隆了回购然后跑了 mvn install
在与依赖项(不是快照)斗争之后,我得到了jar。
把它移到./libs,我就能看到 io.confluent.connect.jdbc.JdbcSourceConnector
& io.confluent.connect.jdbc.JdbcSinkConnector
打的时候 GET /connector-plugins
.
我创建了一个到azuresqlserver的源连接器&一个主题。
我收到以下错误一旦创建了源连接器:
[2018-02-14 15:46:16,960]启动连接器azure源连接器测试时出错(org.apache.kafka.connect.runtime.worker)connector:108)java.lang.nosuchfielderror:系统位于io.confluent.connect.jdbc.source.jdbcsourceconnectorconfig.(jdbcsourceconnectorconfig)。java:184)在io.confluent.connect.jdbc.jdbcsourceconnector.start(jdbcsourceconnector。java:69)在org.apache.kafka.connect.runtime.workerconnector.dostart(workerconnector。java:100)在org.apache.kafka.connect.runtime.workerconnector.start(workerconnector。java:125)在org.apache.kafka.connect.runtime.workerconnector.transitionto(workerconnector。java:182)在org.apache.kafka.connect.runtime.worker.startconnector(worker。java:165)在org.apache.kafka.connect.runtime.distributed.distributedherder.startconnector(distributedherder。java:773)在org.apache.kafka.connect.runtime.distributed.distributedherder.startwork(distributedherder。java:747)位于org.apache.kafka.connect.runtime.distributed.distributedherder.handlerebalancecompleted(distributedherder。java:708)在org.apache.kafka.connect.runtime.distributed.distributedherder.tick(distributedherder。java:204)在org.apache.kafka.connect.runtime.distributed.distributedherder.run(distributedherder。java:174)在java.lang.thread.run(线程。java:748)
我尝试了kafka connect jdbc的不同版本/分支,但所有的尝试都以相同的错误结束。
这个问题也有同样的问题,所以我试图强制构建使用 connect-api-0.10.1.2.6.2.3-1.jar
通过 systemPath
在 pom.xml
但是如果构建成功了,它仍然有同样的问题。
你知道吗?
暂无答案!
目前还没有任何答案,快来回答吧!