org.postgresql.util.PSQLException: ERROR: syntax error

Question

我正在尝试将 debezium-connector-postgres 添加到我的 Kafka Connect。

首先我通过

验证了我的配置

PUT http://localhost:8083/connector-plugins/io.debezium.connector.postgresql.PostgresConnector/config/validate

{
    "name": "postgres-kafkaconnector",
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "tasks.max": "1",
    "database.hostname": "example.com",
    "database.port": "5432",
    "database.dbname": "my_db",
    "database.user": "xxx",
    "database.password": "xxx",
    "database.server.name": "my_db_server",
    "table.include.list": "public.products",
    "plugin.name": "pgoutput"
}

它returns这显示没有错误：

{
    "name": "io.debezium.connector.postgresql.PostgresConnector",
    "error_count": 0,
    ...

然后我尝试通过

添加此连接器

POST http://localhost:8083/connectors

{
    "name": "postgres-kafkaconnector",
    "config": {
        "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
        "tasks.max": "1",
        "database.hostname": "example.com",
        "database.port": "5432",
        "database.dbname": "my_db",
        "database.user": "xxx",
        "database.password": "xxx",
        "database.server.name": "my_db_server",
        "table.include.list": "public.products",
        "plugin.name": "pgoutput"
    }
}

连接器添加成功。

但是，当我运行

时出现错误

获取 http://localhost:8083/connectors/postgres-kafkaconnector/status

ERROR WorkerSourceTask{id=postgres-kafkaconnector-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
io.debezium.jdbc.JdbcConnectionException: ERROR: syntax error
    at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.initPublication(PostgresReplicationConnection.java:180)
    at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.createReplicationSlot(PostgresReplicationConnection.java:351)
    at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:136)
    at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130)
    at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:208)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
    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.postgresql.util.PSQLException: ERROR: syntax error
    at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2565)
    at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2297)
    at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:322)
    at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:481)
    at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:401)
    at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:322)
    at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:308)
    at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:284)
    at org.postgresql.jdbc.PgStatement.executeQuery(PgStatement.java:236)
    at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.initPublication(PostgresReplicationConnection.java:137)
    ... 11 more

我怎样才能看到完整的日志，尤其是那 11 行？我还检查了我的 Kubernetes pod 日志，它显示了相同的部分，但没有多出 11 行。

目前的错误内容不是很有用。任何进一步调试的帮助将不胜感激！

更新 1：

获取 http://localhost:8083/connectors

returns

[
    "postgres-kafkaconnector"
]

Answer 1

在我们使用 Postgres 9.6.12 之前，切换到 Postgres 13.6 之后。

使用相同的设置步骤，这次效果很好。

我最好的猜测可能是因为我使用的 debezium-connector-postgres 版本 1.8.1.Final 不能很好地与旧的 Postgres 9.6.12 兼容。

org.postgresql.util.PSQLException: ERROR: syntax error

org.postgresql.util.PSQLException: ERROR: syntax error

postgresql

apache-kafka

apache-kafka-connect

debezium

change-data-capture