消费不到，报wal 异常

[jimmyddd]

ERROR msg:0x7f743b217fa8, failed to process since Consumer not ready, app:0x7f81f4008460 type:ask-ep, gtid:0x9d00a032a9f30762:0x460035732a901c4e

[2024-11-23 12:19:55,875] ERROR [TDengineSourceConnector|task-0] WorkerSourceTask{id=TDengineSourceConnector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:212)
java.lang.UnsatisfiedLinkError: com.taosdata.jdbc.tmq.TMQConnector.tmqCommitAllSync(J)I
at com.taosdata.jdbc.tmq.TMQConnector.tmqCommitAllSync(Native Method)
at com.taosdata.jdbc.tmq.TMQConnector.syncCommit(TMQConnector.java:152)
at com.taosdata.jdbc.tmq.JNIConsumer.commitSync(JNIConsumer.java:115)
at com.taosdata.jdbc.tmq.TaosConsumer.commitSync(TaosConsumer.java:125)
at com.taosdata.kafka.connect.source.TableExecutor.commitOffset(TableExecutor.java:174)
at com.taosdata.kafka.connect.source.TDengineSourceTask.poll(TDengineSourceTask.java:138)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:469)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:357)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)
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)
[2024-11-23 12:19:55,875] INFO [TDengineSourceConnector|task-0] Stop TDengine Source Task (com.taosdata.kafka.connect.source.TDengineSourceTask:189)
[2024-11-23 12:19:57,882] ERROR [TDengineSourceConnector|task-0] close consumer with this table success: st_telesignal_single_point (com.taosdata.kafka.connect.source.TableExecutor:268)
[2024-11-23 12:19:59,888] ERROR [TDengineSourceConnector|task-0] close consumer with this table success: st_telemetry_short_float (com.taosdata.kafka.connect.source.TableExecutor:268)
[2024-11-23 12:20:01,894] ERROR [TDengineSourceConnector|task-0] close consumer with this table success: st_telepulse (com.taosdata.kafka.connect.source.TableExecutor:268)
[2024-11-23 12:20:01,895] INFO [TDengineSourceConnector|task-0] Try closing connection jdbc:TAOS://taos-server1:6030 (com.taosdata.kafka.connect.db.CacheProcessor:92)
[2024-11-23 12:20:01,895] INFO [TDengineSourceConnector|task-0] [Producer clientId=connector-producer-TDengineSourceConnector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1346)
[2024-11-23 12:20:01,897] INFO [TDengineSourceConnector|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:684)
[2024-11-23 12:20:01,897] INFO [TDengineSourceConnector|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:688)
[2024-11-23 12:20:01,897] INFO [TDengineSourceConnector|task-0] Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter (org.apache.kafka.common.metrics.Metrics:688)
[2024-11-23 12:20:01,897] INFO [TDengineSourceConnector|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:694)
[2024-11-23 12:20:01,897] INFO [TDengineSourceConnector|task-0] App info kafka.producer for connector-producer-TDengineSourceConnector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:88)

kafka 连接日志“
[2024-11-23 13:06:53,129] ERROR [TDengineSourceConnector|task-0] WorkerSourceTask{id=TDengineSourceConnector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:212)
java.lang.UnsatisfiedLinkError: com.taosdata.jdbc.tmq.TMQConnector.tmqCommitAllSync(J)I
at com.taosdata.jdbc.tmq.TMQConnector.tmqCommitAllSync(Native Method)
at com.taosdata.jdbc.tmq.TMQConnector.syncCommit(TMQConnector.java:152)
at com.taosdata.jdbc.tmq.JNIConsumer.commitSync(JNIConsumer.java:115)
at com.taosdata.jdbc.tmq.TaosConsumer.commitSync(TaosConsumer.java:125)
at com.taosdata.kafka.connect.source.TableExecutor.commitOffset(TableExecutor.java:174)
at com.taosdata.kafka.connect.source.TDengineSourceTask.poll(TDengineSourceTask.java:138)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:469)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:357)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77)
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)
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)