AWS RDS Failover takes long time or requires manual intervention

## Bug report

**What Debezium connector do you use and what version?**

`2.7.4`

---

**What is the connector configuration?**

```
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"errors.log.include.messages": "true",
"topic.creation.default.partitions": "-1",
"schema.refresh.mode": "columns_diff_exclude_unchanged_toast",
"producer.override.interceptor.classes": "io.debezium.tracing.DebeziumTracingProducerInterceptor",
"heartbeat.action.query": "CREATE TABLE IF NOT EXISTS heartbeat (id SERIAL PRIMARY KEY, ts TIMESTAMP WITH TIME ZONE);\nINSERT INTO heartbeat (id, ts) VALUES (1, NOW()) ON CONFLICT(id) DO UPDATE SET ts=EXCLUDED.ts;\n",
"topic.creation.default.replication.factor": "-1",
"interval.handling.mode": "string",
"errors.log.enable": "true",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"database.dbname": "...",
"database.user": "...",
"heartbeat.interval.ms": "60000",
"plugin.name": "pgoutput",
"topic.creation.enable": "true",
"key.converter.schemas.enable": "false",
"database.password": "...",
"value.converter.schemas.enable": "true",
"errors.tolerance": "all",
"slot.name": "...",
"tasks.max": "1",
"decimal.handling.mode": "string",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"publication.autocreate.mode": "filtered",
"producer.override.compression.type": "snappy",
"database.port": "...",
"database.hostname": "..."
```

---

**What is the captured database version and mode of deployment?**

_E.g. on-premises, with a specific cloud provider, etc._

`AWS RDS Postgres 17.5 with Multi A-Z`

---

**What behavior do you expect?**

During a database failover, the Debezium connector experiences a prolonged recovery period, typically taking around 20 minutes to resume normal operation. In some cases, manual intervention is required, and the Kafka Connect connector must be restarted to successfully reattach to the replication slots.

Notably, this behavior occurs without any visible errors or failure states reported by the connector, making it difficult to detect and diagnose automatically.

---

**What behavior do you see?**

It is expected that the failover is reliable and takes much less time, only a few minutes to fully recover.

---

**Do you see the same behaviour using the latest released Debezium version?**

_Ideally, also verify with the latest Alpha/Beta/CR version._

We also tried other versions such as `2.5.1`

---

**Do you have the connector logs, ideally from start till finish?**

_You might be asked later to provide [DEBUG/TRACE](https://debezium.io/documentation/reference/stable/operations/logging.html) level log._

```
Starting Kafka Connect with configuration:
##############################
##############################
# This file is automatically generated by the Strimzi Cluster Operator
# Any changes to this file will be ignored and overwritten!
##############################
##############################

##########
# Bootstrap servers
##########
bootstrap.servers=

##########
# Config providers
##########
# Configuration providers configured by the user and by Strimzi
config.providers=secrets,strimzienv,strimzifile,strimzidir
config.providers.strimzienv.class=org.apache.kafka.common.config.provider.EnvVarConfigProvider
config.providers.strimzienv.param.allowlist.pattern=.*
config.providers.strimzifile.class=org.apache.kafka.common.config.provider.FileConfigProvider
config.providers.strimzidir.class=org.apache.kafka.common.config.provider.DirectoryConfigProvider
config.providers.strimzidir.param.allowed.paths=/opt/kafka

##########
# Provided configurations
##########
offset.storage.topic=kafka-connect-offsets
value.converter=org.apache.kafka.connect.json.JsonConverter
config.storage.topic=kafka-connect-configs
key.converter=org.apache.kafka.connect.json.JsonConverter
group.id=kafka-connect
status.storage.topic=kafka-connect-status
config.providers.secrets.class=io.strimzi.kafka.KubernetesSecretConfigProvider
config.storage.replication.factor=-1
offset.storage.replication.factor=-1
status.storage.replication.factor=-1
consumer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.v2_6.TracingConsumerInterceptor
producer.interceptor.classes=io.opentelemetry.instrumentation.kafkaclients.v2_6.TracingProducerInterceptor

##########
# REST Listeners
##########
rest.advertised.host.name =
rest.advertised.port =

##########
# Plugins
##########
plugin.path=/opt/kafka/plugins

##########
# Additional information
##########
consumer.client.rack=${strimzidir:/opt/kafka/init:rack.id}

##########
# Kafka Security protocol
##########
security.protocol=PLAINTEXT
producer.security.protocol=PLAINTEXT
consumer.security.protocol=PLAINTEXT
admin.security.protocol=PLAINTEXT

+ exec /usr/bin/tini -w -e 143 -- /opt/kafka/bin/connect-distributed.sh /tmp/strimzi-connect.properties
2026-04-16 13:07:15.849 | main | INFO | io.prometheus.jmx.JavaAgent | Starting ...
2026-04-16 13:07:16.085 | main | INFO | io.prometheus.jmx.JavaAgent | HTTP enabled [true]
2026-04-16 13:07:16.086 | main | INFO | io.prometheus.jmx.JavaAgent | HTTP host:port [:]
2026-04-16 13:07:16.086 | main | INFO | io.prometheus.jmx.JavaAgent | OpenTelemetry enabled [false]
2026-04-16 13:07:16.124 | main | INFO | io.prometheus.jmx.JavaAgent | Running ...
2026-04-16 13:07:16,158 INFO Initializing OpenTelemetry tracing with service name kafka-connect (io.strimzi.tracing.agent.OpenTelemetryTracing) [main]
2026-04-16 13:07:16,508 INFO Kafka Connect worker initializing ... (org.apache.kafka.connect.cli.AbstractConnectCli) [main]
2026-04-16 13:07:16,509 INFO WorkerInfo values:
jvm.args = -Xms128M, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -XX:MaxInlineLevel=15, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote=true, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/opt/kafka, -Dlog4j.configuration=file:/opt/kafka/custom-config/log4j2.properties, -Dsun.net.inetaddr.ttl=5, -Dsun.net.inetaddr.negative.ttl=0, -javaagent:/opt/prometheus-jmx-exporter/jmx_prometheus_javaagent-1.1.0.jar=9404:/opt/kafka/custom-config/metrics-config.json, -javaagent:/opt/kafka/libs/tracing-agent-0.46.0.jar=opentelemetry
jvm.spec = Red Hat, Inc., OpenJDK 64-Bit Server VM, 17.0.15, 17.0.15+6-LTS
jvm.classpath =
os.spec = Linux, aarch64, 6.12.68-92.122.amzn2023.aarch64
os.vcpus = 8
(org.apache.kafka.connect.runtime.WorkerInfo) [main]
2026-04-16 13:07:16,510 INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.AbstractConnectCli) [main]
2026-04-16 13:07:16,535 INFO Loading plugin from: /opt/kafka/plugins/smts-plugins (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,700 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/smts-plugins/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,714 INFO Loading plugin from: /opt/kafka/plugins/jcustenborder-kafka-connect-transform-common (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,740 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/jcustenborder-kafka-connect-transform-common/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,740 INFO Loading plugin from: /opt/kafka/plugins/ably-kafka-connect-ably (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,748 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/ably-kafka-connect-ably/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,749 INFO Loading plugin from: /opt/kafka/plugins/opensearch-connector-for-apache-kafka (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,797 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/opensearch-connector-for-apache-kafka/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,798 INFO Loading plugin from: /opt/kafka/plugins/debezium-connector-postgres (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,812 INFO Using up-to-date JsonConverter implementation (io.debezium.converters.CloudEventsConverter) [main]
2026-04-16 13:07:16,866 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-connector-postgres/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,869 INFO Loading plugin from: /opt/kafka/plugins/debezium-interceptor (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,875 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/debezium-interceptor/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,876 INFO Loading plugin from: /opt/kafka/plugins/confluentinc-kafka-connect-avro-converter (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,886 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/confluentinc-kafka-connect-avro-converter/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,887 INFO Loading plugin from: /opt/kafka/plugins/confluentinc-connect-transforms (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:16,895 INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/kafka/plugins/confluentinc-connect-transforms/} (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:17,605 ERROR Failed to discover Transformation in /opt/kafka/plugins/jcustenborder-kafka-connect-transform-common: Unable to instantiate TimestampNow: Failed to invoke plugin constructor (org.apache.kafka.connect.runtime.isolation.ReflectionScanner) [main]
java.lang.reflect.InvocationTargetException
Caused by: java.lang.IllegalAccessError: failed to access class org.apache.kafka.common.utils.SystemTime from class com.github.jcustenborder.kafka.connect.transform.common.TimestampNow
2026-04-16 13:07:17,786 ERROR Failed to discover Transformation in /opt/kafka/plugins/jcustenborder-kafka-connect-transform-common: Unable to instantiate LowerCaseTopic: Failed to invoke plugin constructor (org.apache.kafka.connect.runtime.isolation.ReflectionScanner) [main]
java.lang.reflect.InvocationTargetException
Caused by: java.lang.IllegalAccessError: failed to access class org.apache.kafka.common.utils.SystemTime from class com.github.jcustenborder.kafka.connect.transform.common.LowerCaseTopic
2026-04-16 13:07:17,787 ERROR Failed to discover Transformation: Unable to instantiate AdjustPrecisionAndScale: Plugin class must have a no-args constructor (org.apache.kafka.connect.runtime.isolation.ReflectionScanner) [main]
2026-04-16 13:07:17,788 ERROR Failed to discover Transformation: Unable to instantiate HeaderToField: Plugin class must have a no-args constructor (org.apache.kafka.connect.runtime.isolation.ReflectionScanner) [main]
2026-04-16 13:07:17,788 ERROR Failed to discover Transformation: Unable to instantiate SetMaximumPrecision: Plugin class must have a no-args constructor (org.apache.kafka.connect.runtime.isolation.ReflectionScanner) [main]
2026-04-16 13:07:19,952 INFO Scanning plugins with ReflectionScanner took 3050 ms (org.apache.kafka.connect.runtime.isolation.PluginScanner) [main]
2026-04-16 13:07:19,955 WARN One or more plugins are missing ServiceLoader manifests (org.apache.kafka.connect.runtime.isolation.Plugins) [main]
2026-04-16 13:07:20,110 WARN The path /opt/kafka/init is not a directory (org.apache.kafka.common.config.provider.DirectoryConfigProvider) [main]
2026-04-16 13:07:20,166 INFO Kafka version: 3.9.0 (org.apache.kafka.common.utils.AppInfoParser) [main]
2026-04-16 13:07:20,166 INFO Kafka commitId: a60e31147e6b01ee (org.apache.kafka.common.utils.AppInfoParser) [main]
2026-04-16 13:07:20,444 INFO Kafka cluster ID: (org.apache.kafka.connect.runtime.WorkerConfig) [main]
2026-04-16 13:07:20,485 INFO Added connector for http:// (org.apache.kafka.connect.runtime.rest.RestServer) [main]
2026-04-16 13:07:20,485 INFO Initializing REST server (org.apache.kafka.connect.runtime.rest.RestServer) [main]
2026-04-16 13:07:20,517 INFO Started http_8083@49b99{HTTP/1.1, (http/1.1)}{:} (org.eclipse.jetty.server.AbstractConnector) [main]
2026-04-16 13:07:20,532 INFO Advertised URI: http:/// (org.apache.kafka.connect.runtime.rest.RestServer) [main]
2026-04-16 13:07:20,533 INFO REST server listening at http://:/, advertising URL http:/// (org.apache.kafka.connect.runtime.rest.RestServer) [main]
2026-04-16 13:07:20,533 INFO Setting up All Policy for ConnectorClientConfigOverride (org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy) [main]
2026-04-16 13:07:20,595 INFO Kafka Connect worker initialization took 4086ms (org.apache.kafka.connect.cli.AbstractConnectCli) [main]
2026-04-16 13:07:20,595 INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect) [main]
2026-04-16 13:07:20,597 INFO Herder starting (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder]
2026-04-16 13:07:20,598 INFO Worker starting (org.apache.kafka.connect.runtime.Worker) [DistributedHerder]
2026-04-16 13:07:20,598 INFO Starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder]
2026-04-16 13:07:21,028 INFO Finished reading offsets topic and starting KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore) [DistributedHerder]
2026-04-16 13:07:21,030 INFO Worker started (org.apache.kafka.connect.runtime.Worker) [DistributedHerder]
2026-04-16 13:07:21,041 INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer) [main]
2026-04-16 13:07:21,042 INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect) [main]
2026-04-16 13:07:21,707 INFO Successfully processed removal of connector '' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder]
2026-04-16 13:07:21,708 INFO Successfully processed removal of connector '' (org.apache.kafka.connect.storage.KafkaConfigBackingStore) [DistributedHerder]
2026-04-16 13:07:21,723 INFO Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder]
2026-04-16 13:07:21,723 INFO (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder]
2026-04-16 13:07:30,201 INFO Successfully joined group with generation Generation{generationId=1882, memberId='', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder]
2026-04-16 13:07:37,599 INFO SyncGroup failed: The group began another rebalance. Need to re-join the group. (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder]
2026-04-16 13:07:37,600 INFO (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder]
2026-04-16 13:07:40,201 INFO Successfully joined group with generation Generation{generationId=1883, memberId='', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator) [DistributedHerder]
2026-04-16 13:07:40,217 INFO Joined group at generation 1883 with protocol version 2 and got assignment: Assignment{error=0, leader=':-e00ca1a8-0819-4c8b-8356-3bc071c19af7', leaderUrl='http:///', offset=6227, connectorIds=[], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder]
2026-04-16 13:07:40,218 INFO Herder started (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder]
2026-04-16 13:07:40,221 INFO Finished reading to end of log and updated config snapshot, new config log offset: 6227 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder]
2026-04-16 13:07:40,221 INFO Starting connectors and tasks using config offset 6227 (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder]
2026-04-16 13:07:40,222 INFO Starting connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor]
2026-04-16 13:07:40,222 INFO Starting connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor]
2026-04-16 13:07:40,222 INFO Starting connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor]
2026-04-16 13:07:40,222 INFO Starting connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor]
2026-04-16 13:07:40,222 INFO Starting connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor]
2026-04-16 13:07:40,222 INFO Starting connector (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [StartAndStopExecutor]
2026-04-16 13:07:40,223 INFO Retrieving configuration from Secret in namespace (io.strimzi.kafka.AbstractKubernetesConfigProvider) [StartAndStopExecutor]
2026-04-16 13:07:40,521 INFO Creating connector of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,521 INFO Creating connector of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,521 INFO Creating connector of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,521 INFO Creating connector of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,521 INFO Creating connector of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,523 INFO Creating connector of type io.debezium.connector.postgresql.PostgresConnector (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,563 INFO Instantiated connector with version 2.5.1.Final (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,563 INFO Instantiated connector with version 2.5.1.Final (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,562 INFO Instantiated connector with version 2.5.1.Final (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,562 INFO Instantiated connector with version 2.5.1.Final (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,570 INFO Instantiated connector with version 2.5.1.Final (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,570 INFO Instantiated connector with version 2.5.1.Final (org.apache.kafka.connect.runtime.Worker) [StartAndStopExecutor]
2026-04-16 13:07:40,782 INFO Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder) [DistributedHerder]
2026-04-16 13:07:40,803 INFO Starting PostgresConnectorTask (io.debezium.connector.common.BaseSourceTask) [task-thread]
2026-04-16 13:07:41,055 INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [pool-thread]
2026-04-16 13:07:41,249 INFO No previous offsets found (io.debezium.connector.common.BaseSourceTask) [task-thread-leaderboards]
2026-04-16 13:07:41,251 INFO Found previous partition offset (io.debezium.connector.common.BaseSourceTask) [task-thread-annotations]
2026-04-16 13:07:41,251 INFO Found previous partition offset (io.debezium.connector.common.BaseSourceTask) [task-thread-profiles]
2026-04-16 13:07:41,252 INFO Found previous partition offset (io.debezium.connector.common.BaseSourceTask) [task-thread-communications]
2026-04-16 13:07:41,252 INFO Found previous partition offset (io.debezium.connector.common.BaseSourceTask) [task-thread-sessions]
2026-04-16 13:07:41,252 INFO Found previous partition offset (io.debezium.connector.common.BaseSourceTask) [task-thread-workflows]
2026-04-16 13:07:41,637 INFO user '' connected to database on PostgreSQL 17.5 on aarch64-unknown-linux-gnu (io.debezium.connector.postgresql.PostgresConnectorTask) [task-thread]
2026-04-16 13:07:41,678 INFO Obtained valid replication slot (io.debezium.connector.postgresql.connection.PostgresConnection) [task-thread]
2026-04-16 13:07:41,709 INFO Snapshots are not allowed as per configuration, starting streaming logical changes only (io.debezium.connector.postgresql.snapshot.NeverSnapshotter) [task-thread-leaderboards]
2026-04-16 13:07:41,737 INFO Metrics registered (io.debezium.pipeline.ChangeEventSourceCoordinator) [change-event-source-coordinator]
2026-04-16 13:07:41,743 INFO Previous snapshot has completed successfully, streaming logical changes from last known position (io.debezium.connector.postgresql.snapshot.InitialSnapshotter) [change-event-source-coordinator]
2026-04-16 13:07:41,743 INFO According to the connector configuration no snapshot will be executed (io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:41,748 INFO Connected metrics set to 'true' (io.debezium.pipeline.ChangeEventSourceCoordinator) [change-event-source-coordinator]
2026-04-16 13:07:41,870 INFO Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [change-event-source-coordinator]
2026-04-16 13:07:41,871 INFO Initializing PgOutput logical decoder publication (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [change-event-source-coordinator]
2026-04-16 13:07:41,957 INFO Updating Publication (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [change-event-source-coordinator]
2026-04-16 13:07:41,967 INFO Updating Replica Identity (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [change-event-source-coordinator]
2026-04-16 13:07:42,382 INFO Searching for WAL resume position (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:42,405 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:42,686 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:42,813 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:42,815 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:43,133 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:43,180 INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [change-event-source-coordinator]
2026-04-16 13:07:43,296 INFO The task will send records to topic for the first time. Checking whether topic exists (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [task-thread]
2026-04-16 13:07:43,304 INFO Topic already exists. (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask) [task-thread]
2026-04-16 13:07:48,909 INFO 25 records sent during previous 00:00:08.322 (io.debezium.connector.common.BaseSourceTask) [task-thread]
2026-04-16 13:07:56,428 INFO 4 records sent during previous 00:00:07.519 (io.debezium.connector.common.BaseSourceTask) [task-thread]
```

---

**How to reproduce the issue using our [tutorial](https://github.com/debezium/debezium-examples/tree/main/tutorial) deployment?**

Connect to an RDS database with a read replica and reboot it with failover