使用 debezium 连接器的多个 postgres 连接

Question

当我使用 debezium 连接器创建 kafka 连接器时，会产生四个数据库连接。其中三个保持空闲，而一个用作实际的复制槽。我找不到有关预期数据库连接数的任何信息。

这是我 post 到 /connectors

的配置

{
  "name": "my.source.connector",
  "config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "tasks.max": 1,
    "plugin.name": "pgoutput",
    "heartbeat.interval.ms": "0",
    "slot.name": "slotty_slot",
    "database.hostname": "localhost",
    "database.port": "5432",
    "database.user": "debezium",
    "database.password": "************",
    "database.dbname": "my_database",
    "database.server.name": "server_name",
    "topic.creation.default.replication.factor": "1",
    "topic.creation.default.partitions": "20"
  }
}

四连是否正常？还是应该是一个？

Answer 1

此问题已由 DBZ-5074 修复。您应该注意到即将发布的 1.9.3.Final 或将于今年晚些时候发布的 Debezium 2.0 版本对此进行了改进。

使用 debezium 连接器的多个 postgres 连接

Multiple postgres connections with debezium connector

postgresql

apache-kafka

apache-kafka-connect

debezium