2024-02-15 09:57:10,010 INFO   ||  55984 records sent during previous 01:59:55.851, last recorded offset of {server=core-ingest.update-signals} partition is {transaction_id=null, lsn_proc=413801017873624, messageType=UPDATE, lsn_commit=413801017796624, lsn=413801017873624, txId=406627465, ts_usec=1707991029929559}   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 09:57:55,806 INFO   ||  10.80.192.1 - - [15/Feb/2024:09:57:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 1   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 09:57:56,335 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 724 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 09:57:56,400 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 361 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 09:58:06,287 INFO   ||  [AdminClient clientId=connector-adminclient-airings-signal-connector-0] Node 1 disconnected.   [org.apache.kafka.clients.NetworkClient]
2024-02-15 09:58:55,807 INFO   ||  10.80.192.1 - - [15/Feb/2024:09:58:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 1   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 09:58:56,400 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 146 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 09:58:56,465 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 73 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 09:59:47,568 INFO   ||  [AdminClient clientId=1--shared-admin] Node 3 disconnected.   [org.apache.kafka.clients.NetworkClient]
2024-02-15 09:59:55,806 INFO   ||  10.80.192.1 - - [15/Feb/2024:09:59:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 1   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 09:59:56,466 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 12 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 09:59:56,531 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 6 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:00:55,806 INFO   ||  10.80.192.1 - - [15/Feb/2024:10:00:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 1   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 10:00:56,531 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 630 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:00:56,597 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 317 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:01:53,162 INFO   ||  [AdminClient clientId=connector-adminclient-airings-etc-connector-0] Node 3 disconnected.   [org.apache.kafka.clients.NetworkClient]
2024-02-15 10:01:55,806 INFO   ||  10.80.192.1 - - [15/Feb/2024:10:01:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 1   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 10:01:56,597 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 8 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:01:56,662 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 4 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:02:55,806 INFO   ||  10.80.192.1 - - [15/Feb/2024:10:02:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 1   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 10:02:56,662 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 68 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:02:56,728 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 34 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:03:06,591 INFO   ||  [AdminClient clientId=connector-adminclient-airings-signal-connector-0] Node 2 disconnected.   [org.apache.kafka.clients.NetworkClient]
2024-02-15 10:03:46,270 ERROR  Postgres|core-ingest.cdc|streaming  Producer failure   [io.debezium.pipeline.ErrorHandler]
org.postgresql.util.PSQLException: FATAL: terminating connection due to administrator command
	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713)
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401)
	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368)
	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498)
	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415)
	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)
	at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:134)
	at io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:694)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.probeConnectionIfNeeded(PostgresStreamingChangeEventSource.java:367)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:223)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:183)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:137)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
2024-02-15 10:03:46,271 WARN   Postgres|core-ingest.cdc|streaming  Retry 3 of 300 retries will be attempted   [io.debezium.pipeline.ErrorHandler]
2024-02-15 10:03:46,360 WARN   ||  Going to restart connector after 10 sec. after a retriable exception   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:03:46,363 INFO   Postgres|core-ingest.cdc|streaming  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2024-02-15 10:03:46,363 INFO   Postgres|core-ingest.cdc|streaming  Connected metrics set to 'false'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2024-02-15 10:03:46,364 INFO   ||  SignalProcessor stopped   [io.debezium.pipeline.signal.SignalProcessor]
2024-02-15 10:03:46,366 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2024-02-15 10:03:46,367 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2024-02-15 10:03:46,367 WARN   ||  WorkerSourceTask{id=airings-etc-connector-0} failed to poll records from SourceTask. Will retry operation.   [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask]
org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:63)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:186)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:137)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.postgresql.util.PSQLException: FATAL: terminating connection due to administrator command
	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713)
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401)
	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368)
	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498)
	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415)
	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)
	at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:134)
	at io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:694)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.probeConnectionIfNeeded(PostgresStreamingChangeEventSource.java:367)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:223)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:183)
	... 9 more
2024-02-15 10:03:46,368 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:03:51,688 ERROR  Postgres|core-ingest.update-signals|streaming  Producer failure   [io.debezium.pipeline.ErrorHandler]
org.postgresql.util.PSQLException: FATAL: terminating connection due to administrator command
	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713)
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401)
	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368)
	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498)
	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415)
	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)
	at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:134)
	at io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:694)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.probeConnectionIfNeeded(PostgresStreamingChangeEventSource.java:367)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:223)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:183)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:137)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
2024-02-15 10:03:51,688 WARN   Postgres|core-ingest.update-signals|streaming  Retry 1 of 300 retries will be attempted   [io.debezium.pipeline.ErrorHandler]
2024-02-15 10:03:51,719 WARN   ||  Going to restart connector after 10 sec. after a retriable exception   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:03:51,761 INFO   Postgres|core-ingest.update-signals|streaming  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2024-02-15 10:03:51,761 INFO   Postgres|core-ingest.update-signals|streaming  Connected metrics set to 'false'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2024-02-15 10:03:51,762 INFO   ||  SignalProcessor stopped   [io.debezium.pipeline.signal.SignalProcessor]
2024-02-15 10:03:51,763 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2024-02-15 10:03:51,765 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2024-02-15 10:03:51,765 WARN   ||  WorkerSourceTask{id=airings-signal-connector-0} failed to poll records from SourceTask. Will retry operation.   [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask]
org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:63)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:186)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:42)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:272)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:197)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:137)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.postgresql.util.PSQLException: FATAL: terminating connection due to administrator command
	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2713)
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2401)
	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368)
	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:498)
	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:415)
	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)
	at org.postgresql.jdbc.PgPreparedStatement.executeQuery(PgPreparedStatement.java:134)
	at io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:694)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.probeConnectionIfNeeded(PostgresStreamingChangeEventSource.java:367)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:223)
	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:183)
	... 9 more
2024-02-15 10:03:51,766 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:03:55,806 INFO   ||  10.80.192.1 - - [15/Feb/2024:10:03:55 +0000] "GET / HTTP/1.1" 200 91 "-" "kube-probe/1.24" 0   [org.apache.kafka.connect.runtime.rest.RestServer]
2024-02-15 10:03:56,368 INFO   ||  Attempting to restart task.   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:03:56,369 INFO   ||  Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker   [io.debezium.config.CommonConnectorConfig]
2024-02-15 10:03:56,371 INFO   ||  Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy   [io.debezium.config.CommonConnectorConfig]
2024-02-15 10:03:56,385 INFO   ||  WorkerSourceTask{id=airings-etc-connector-0} Committing offsets for 14 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:03:56,451 ERROR  ||  WorkerSourceTask{id=airings-etc-connector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
io.debezium.DebeziumException: Couldn't obtain encoding for database kg_core_unprocessed
	at io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:576)
	at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:84)
	at io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:253)
	at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:180)
	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:463)
	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:351)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:75)
	at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.postgresql.util.PSQLException: Connection to REDACTED.rds.amazonaws.com:5432 refused. Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.
	at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:342)
	at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54)
	at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:263)
	at org.postgresql.Driver.makeConnection(Driver.java:443)
	at org.postgresql.Driver.connect(Driver.java:297)
	at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:241)
	at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:127)
	at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:873)
	at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:868)
	at io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:573)
	... 14 more
Caused by: java.net.ConnectException: Connection refused (Connection refused)
	at java.base/java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)
	at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)
	at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.base/java.net.Socket.connect(Socket.java:609)
	at org.postgresql.core.PGStream.createSocket(PGStream.java:243)
	at org.postgresql.core.PGStream.<init>(PGStream.java:98)
	at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:132)
	at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:258)
	... 23 more
2024-02-15 10:03:56,452 INFO   ||  Stopping down connector   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:03:56,452 INFO   ||  [Producer clientId=connector-producer-airings-etc-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2024-02-15 10:03:56,458 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:03:56,458 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:03:56,458 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:03:56,458 INFO   ||  App info kafka.producer for connector-producer-airings-etc-connector-0 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
2024-02-15 10:03:56,459 INFO   ||  App info kafka.admin.client for connector-adminclient-airings-etc-connector-0 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
2024-02-15 10:03:56,461 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:03:56,461 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:03:56,461 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:03:56,729 INFO   ||  WorkerSourceTask{id=airings-signal-connector-0} Committing offsets for 7 acknowledged messages   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2024-02-15 10:03:56,731 WARN   ||  Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:04:01,766 INFO   ||  Attempting to restart task.   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:04:01,766 INFO   ||  Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker   [io.debezium.config.CommonConnectorConfig]
2024-02-15 10:04:01,767 INFO   ||  Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy   [io.debezium.config.CommonConnectorConfig]
2024-02-15 10:04:01,780 ERROR  ||  WorkerSourceTask{id=airings-signal-connector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
io.debezium.DebeziumException: Couldn't obtain encoding for database kg_core_unprocessed
	at io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:576)
	at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:84)
	at io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:253)
	at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:180)
	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:463)
	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:351)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)
	at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:75)
	at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.postgresql.util.PSQLException: Connection to REDACTED.rds.amazonaws.com:5432 refused. Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.
	at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:342)
	at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54)
	at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:263)
	at org.postgresql.Driver.makeConnection(Driver.java:443)
	at org.postgresql.Driver.connect(Driver.java:297)
	at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:241)
	at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:127)
	at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:873)
	at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:868)
	at io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:573)
	... 14 more
Caused by: java.net.ConnectException: Connection refused (Connection refused)
	at java.base/java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)
	at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)
	at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.base/java.net.Socket.connect(Socket.java:609)
	at org.postgresql.core.PGStream.createSocket(PGStream.java:243)
	at org.postgresql.core.PGStream.<init>(PGStream.java:98)
	at org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:132)
	at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:258)
	... 23 more
2024-02-15 10:04:01,781 INFO   ||  Stopping down connector   [io.debezium.connector.common.BaseSourceTask]
2024-02-15 10:04:01,781 INFO   ||  [Producer clientId=connector-producer-airings-signal-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2024-02-15 10:04:01,783 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:04:01,783 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:04:01,783 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:04:01,784 INFO   ||  App info kafka.producer for connector-producer-airings-signal-connector-0 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
2024-02-15 10:04:01,784 INFO   ||  App info kafka.admin.client for connector-adminclient-airings-signal-connector-0 unregistered   [org.apache.kafka.common.utils.AppInfoParser]
2024-02-15 10:04:01,786 INFO   ||  Metrics scheduler closed   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:04:01,786 INFO   ||  Closing reporter org.apache.kafka.common.metrics.JmxReporter   [org.apache.kafka.common.metrics.Metrics]
2024-02-15 10:04:01,786 INFO   ||  Metrics reporters closed   [org.apache.kafka.common.metrics.Metrics]