【问题标题】:PostgresConnector: No topics discovered on this connectorPostgresConnector:在此连接器上未发现任何主题
【发布时间】:2019-09-29 07:37:51
【问题描述】:

我正在运行 ladoop/fast-data-dev 并使用来自 Debezium 的 PostgresConnector。我已配置连接器,但未创建任何主题。

在此连接器上未发现任何主题是错误。

Docker-compose 集群:

  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

期望创建一个主题。

【问题讨论】:

    标签: postgresql docker apache-kafka debezium


    【解决方案1】:

    所以,错误出现在接收器中。主题需命名为postgres_server.public.mytable

    【讨论】:

      猜你喜欢
      • 2020-09-01
      • 1970-01-01
      • 1970-01-01
      • 2019-02-15
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-10-05
      • 2016-05-20
      相关资源
      最近更新 更多