PostgresConnector: темы для этого соединителя не обнаружены - PullRequest
Новая
       16

PostgresConnector: темы для этого соединителя не обнаружены

0 голосов
/ 11 мая 2019

Я использую ladoop / fast-data-dev и использую PostgresConnector от Debezium.Я настроил соединитель, но темы не создаются.

В этом соединителе не обнаружено ни одной темы.

Docker-compose cluster: 

  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

Ожидается создание темы.

1 Ответ

0 голосов
/ 11 мая 2019

Итак, ошибка была в стоке.Тема должна была быть названа postgres_server.public.mytable

...