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

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

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

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

连接器正常工作;

  1. {
  2. "name": "PostgresConnector",
  3. "connector": {
  4. "state": "RUNNING",
  5. "worker_id": "127.0.0.1:8083"
  6. },
  7. "tasks": [
  8. {
  9. "state": "RUNNING",
  10. "id": 0,
  11. "worker_id": "127.0.0.1:8083"
  12. }
  13. ],
  14. "type": "source"
  15. }

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

  1. name=PostgresConnector
  2. connector.class=io.debezium.connector.postgresql.PostgresConnector
  3. database.dbname=mydb
  4. database.user=mydb
  5. tasks.max=1
  6. database.server.name=postgres_server
  7. database.port=5432
  8. table.whitelist=public.mytable
  9. value.converter.schema.registry.url=http://localhost:8081
  10. database.hostname=master
  11. database.password=
  12. value.converter=io.confluent.connect.avro.AvroConverter
  13. key.converter.schema.registry.url=http://localhost:8081

应创建一个主题。

7uhlpewt

7uhlpewt1#

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

相关问题