debezium postgres连接器状态出错

mcvgt66p  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(1367)

我执行以下命令,通过执行连接器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"
}

有人能解释这个错误的原因吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题