Дебезиум останавливается после начальной синхронизации

Question

Начальная синхронизация c работает как положено, но затем соединитель просто останавливается и не заботится о дальнейших изменениях таблицы. Не выдается никаких ошибок, и разъем по-прежнему помечен как активный и работающий.

База данных: Amazon Postgres v10.7

Конфигурация Debezium:

  "name": "postgres_cdc",
  "config": {
    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
    "database.hostname": "...",
    "database.port": "5432",
    "database.user": "...",
    "database.password": "...",
    "database.dbname": "...",
    "database.server.name": "...",
    "table.whitelist": "public.table1,public.table2,public.table3",
    "plugin.name": "pgoutput",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "value.converter.schemas.enable": "false",
    "transforms": "unwrap, route, extractId",
    "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
    "transforms.unwrap.drop.tombstones": false,
    "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.route.regex": "[^.]+\\.[^.]+\\.(.+)",
    "transforms.route.replacement": "postgres_$1",
    "transforms.extractId.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
    "transforms.extractId.field": "id"
  }
}

Любой мысли о том, в чем может быть проблема?

Редактировать:

Журнал ошибок:

ERROR WorkerSourceTask{id=postgres_cdc-0} Failed to flush, timed out while waiting for producer to flush outstanding 75687 messages (org.apache.kafka.connect.runtime.WorkerSourceTask)
ERROR WorkerSourceTask{id=postgres_cdc-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter)