我执行以下命令,通过执行连接器k8s pod来获取连接器的状态。 curl http://localhost:8083/connectors/<connector-name>/status
下面是我得到的结果
{
"connector": {
"state": "UNASSIGNED",
"worker_id": "10.0.140.198:8083"
},
"name": "postgres-source-reportingdb",
"tasks": [
{
"id": 0,
"state": "FAILED",
"trace": "org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\n\tat io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:117)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: java.lang.RuntimeException: org.postgresql.util.PSQLException: This connection has been closed.\n\tat io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:435)\n\tat io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:152)\n\tat io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:63)\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:96)\n\t... 5 more\nCaused by: org.postgresql.util.PSQLException: This connection has been closed.\n\tat org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:857)\n\tat org.postgresql.jdbc.PgConnection.rollback(PgConnection.java:864)\n\tat io.debezium.relational.RelationalSnapshotChangeEventSource.rollbackTransaction(RelationalSnapshotChangeEventSource.java:432)\n\t... 8 more\n",
"worker_id": "10.0.97.148:8083"
}
],
"type": "source"
}
有人能解释这个错误的原因吗?
暂无答案!
目前还没有任何答案,快来回答吧!