postgresql - Debezium Postgres 连接器注册期间出现 400 错误请求

Question

按照本教程中所述配置 Kafka 和 debezium 连接后，每当我这样做时：

这是我创建的连接器。

curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '{"name": "postgres-order-debezium-connector","config":{"connector.class": "io.debezium.connector.postgresql.PostgresConnector","database.hostname": "localhost","database.port": "5432","database.user": "postgres","database.password": "postgres","database.server.id": "184054","database.server.name": "postgres-order-service","database.whitelist": "public.order-service","database.history.kafka.bootstrap.servers": "bitnami-kafka-server:9092","database.history.kafka.topic": "schema-changes.order-service"}}'

我得到了以下回应。

    {
        "error_code": 400,
        "message": "Connector configuration is invalid and contains the following 1 error(s):
                    A value is required You can also find the above list of errors at the endpoint 
                    /{connectorType}/config/validate"
    }

我已经将Zookeeper、Kafka、Postgres和debezium connect作为 docker 容器运行，配置如下。

动物园管理员

    docker run -d -it -p 2181:2181 --name bitnami-zookeeper --network local-app-tier
            -e ALLOW_ANONYMOUS_LOGIN=yes 
            bitnami/zookeeper:latest

阿帕奇卡夫卡

    docker run -d -it -p 9092:9092 --name bitnami-kafka-server --network local-app-tier 
            -e ALLOW_PLAINTEXT_LISTENER=yes 
            -e KAFKA_CFG_ZOOKEEPER_CONNECT=bitnami-zookeeper:2181 
            bitnami/kafka:latest

Debezium 连接（我也尝试过 1.1 版）

    docker run -it -p 8083:8083 --name debezium-postgres-connect --network local-app-tier
        -e GROUP_ID=1
        -e CONFIG_STORAGE_TOPIC=debe_postgres_configs
        -e OFFSET_STORAGE_TOPIC=debe_postgres_offsets
        -e STATUS_STORAGE_TOPIC=debe_postgres_statuses
        -e BOOTSTRAP_SERVERS=bitnami-kafka-server:9092
        --link local-postgres:local-postgres
        debezium/connect:latest

Postgres 码头工人

    docker run -it -p 5432:5432 --network local-app-tier --name local-postgres -e
    POSTGRES_PASSWORD=1234 -d postgres

我也尝试过使用 debezium postgres 图像

我的配置可能做错了什么？

标签： postgresqlapache-kafkadebezium