Kafka连接tdengine失败

ERROR [TDengineSourceConnector|worker] [Worker clientId=connect-1, groupId=connect-cluster] Failed to start connector ‘TDengineSourceConnector’ (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1490)
org.apache.kafka.connect.errors.ConnectException: Failed to start connector: TDengineSourceConnector
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$startConnector$25(DistributedHerder.java:1461)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:334)
at org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:140)
at org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:117)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to transition connector TDengineSourceConnector to state STARTED
… 8 more
Caused by: java.lang.UnsatisfiedLinkError: no taos in java.library.path
at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1867)
at java.lang.Runtime.loadLibrary0(Runtime.java:870)
at java.lang.System.loadLibrary(System.java:1122)
at com.taosdata.jdbc.TSDBJNIConnector.(TSDBJNIConnector.java:34)
at com.taosdata.jdbc.TSDBDriver.connect(TSDBDriver.java:175)
at java.sql.DriverManager.getConnection(DriverManager.java:664)
at java.sql.DriverManager.getConnection(DriverManager.java:208)
at com.taosdata.kafka.connect.db.TSDBConnectionProvider.getConnection(TSDBConnectionProvider.java:35)
at com.taosdata.kafka.connect.source.MonitorThread.init(MonitorThread.java:51)
at com.taosdata.kafka.connect.source.MonitorThread.(MonitorThread.java:41)
at com.taosdata.kafka.connect.source.TDengineSourceConnector.start(TDengineSourceConnector.java:30)
at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:184)
at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:209)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:348)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:331)
… 7 more

kafka和tdengine部署在不同的机器上,出现这个报错

从以上错误信息看,应该是没有安装 TSDB 客户端导致的;

请在部署 Kafka 的环境中,安装 TSDB 客户端,可以从 TDengine 下载中心下载:

[2025-12-01 16:29:49,601] ERROR [TDengineSourceConnector|worker] [Worker clientId=connect-1, groupId=connect-cluster] Failed to start connector ‘TDengineSourceConnector’ (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1490)
org.apache.kafka.connect.errors.ConnectException: Failed to start connector: TDengineSourceConnector
at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$startConnector$25(DistributedHerder.java:1461)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:334)
at org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:140)
at org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:117)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to transition connector TDengineSourceConnector to state STARTED
… 8 more
Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.taosdata.jdbc.TSDBJNIConnector
at com.taosdata.jdbc.TSDBDriver.connect(TSDBDriver.java:175)
at java.sql.DriverManager.getConnection(DriverManager.java:664)
at java.sql.DriverManager.getConnection(DriverManager.java:208)
at com.taosdata.kafka.connect.db.TSDBConnectionProvider.getConnection(TSDBConnectionProvider.java:35)
at com.taosdata.kafka.connect.source.MonitorThread.init(MonitorThread.java:51)
at com.taosdata.kafka.connect.source.MonitorThread.(MonitorThread.java:41)
at com.taosdata.kafka.connect.source.TDengineSourceConnector.start(TDengineSourceConnector.java:30)
at org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:184)
at org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:209)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:348)
at org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:331)
… 7 more

目前的报错

td版本3.3.0.1 驱动版本1.1.6