使用Debezium连接器进行多个Postgres连接。

Question

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

以下是我发布到“/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"
  }
}

四个连接正常吗？还是应该只有一个？

- Avocado

Answer 1

这个问题已经通过DBZ-5074得到解决。你会在即将发布的1.9.3.Final或后续发布的Debezium 2.0版本中看到改进。

- Naros