postgresconnector:在此连接器上找不到主题

atmip9wb  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(413)

我正在运行ladoop/fast数据开发,并使用debezium的postgresconnector。我已配置连接器,但未创建任何主题。
此连接器上未发现主题是错误。
docker组合群集:

kafka-cluster:
    image: landoop/fast-data-dev:latest
    environment:
      ADV_HOST: 127.0.0.1         # Change to 192.168.99.100 if using Docker Toolbox
      RUNTESTS: 0                 # Disable Running tests so the cluster starts faster
    env_file:
      - ./.env
    ports:
      - 2181:2181                 # Zookeeper
      - 3030:3030                 # Landoop UI
      - 8081-8083:8081-8083       # REST Proxy, Schema Registry, Kafka Connect ports
      - 9581-9585:9581-9585       # JMX Ports
      - 9092:9092                 # Kafka Broker

连接器正常工作;

{
    "name": "PostgresConnector",
    "connector": {
        "state": "RUNNING",
        "worker_id": "127.0.0.1:8083"
    },
    "tasks": [
        {
            "state": "RUNNING",
            "id": 0,
            "worker_id": "127.0.0.1:8083"
        }
    ],
    "type": "source"
}

下面是我用于连接器的配置:

name=PostgresConnector
connector.class=io.debezium.connector.postgresql.PostgresConnector
database.dbname=mydb
database.user=mydb
tasks.max=1
database.server.name=postgres_server
database.port=5432
table.whitelist=public.mytable
value.converter.schema.registry.url=http://localhost:8081
database.hostname=master
database.password=
value.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://localhost:8081

应创建一个主题。

7uhlpewt

7uhlpewt1#

所以,错误就在Flume里。主题需要命名 postgres_server.public.mytable

相关问题