2024-05-15 15:53:01.198 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} 2024-05-15 15:53:02.017 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} 2024-05-15 15:53:02.200 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} [2024-05-15 15:53:03,049] ERROR Producer failure (io.debezium.pipeline.ErrorHandler) org.postgresql.util.PSQLException: An I/O error occurred while sending to the backend. at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:395) 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:696) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.probeConnectionIfNeeded(PostgresStreamingChangeEventSource.java:369) 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:271) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:194) 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: java.io.EOFException at org.postgresql.core.PGStream.receiveChar(PGStream.java:467) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2155) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368) ... 17 more [2024-05-15 15:53:03,052] WARN Retry 1 of unlimited retries will be attempted (io.debezium.pipeline.ErrorHandler) [2024-05-15 15:53:03,066] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-05-15 15:53:03,066] INFO Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator) [2024-05-15 15:53:03,071] WARN Going to restart connector after 10 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask) [2024-05-15 15:53:03,074] INFO SignalProcessor stopped (io.debezium.pipeline.signal.SignalProcessor) [2024-05-15 15:53:03,076] INFO Debezium ServiceRegistry stopped. (io.debezium.service.DefaultServiceRegistry) [2024-05-15 15:53:03,141] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2024-05-15 15:53:03,144] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2024-05-15 15:53:03,148] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2024-05-15 15:53:03,150] WARN WorkerSourceTask{id=test_postgres-source-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:271) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:194) 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: An I/O error occurred while sending to the backend. at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:395) 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:696) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.probeConnectionIfNeeded(PostgresStreamingChangeEventSource.java:369) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:223) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:183) ... 9 more Caused by: java.io.EOFException at org.postgresql.core.PGStream.receiveChar(PGStream.java:467) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2155) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:368) ... 17 more [2024-05-15 15:53:03,152] INFO Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask) [2024-05-15 15:53:03,169] INFO 172.22.0.8 - - [15/May/2024:15:53:03 +0000] "GET /connectors HTTP/1.1" 200 24 "-" "curl/7.61.1" 3 (org.apache.kafka.connect.runtime.rest.RestServer) 2024-05-15 15:53:03.689 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} 2024-05-15 15:53:03.750 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} 2024-05-15 15:53:05.837 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} 2024-05-15 15:53:06.183 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} [2024-05-15 15:53:08,303] INFO 172.22.0.8 - - [15/May/2024:15:53:08 +0000] "GET /connectors HTTP/1.1" 200 24 "-" "curl/7.61.1" 3 (org.apache.kafka.connect.runtime.rest.RestServer) 2024-05-15 15:53:10.155 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} 2024-05-15 15:53:10.556 WARN o.g.a.s.i.g.i.ManagedChannelImpl - [org.glowroot.agent.shaded.io.grpc.internal.ManagedChannelImpl-1] Failed to resolve name. status=Status{code=UNAVAILABLE, description=NameResolver returned an empty list, cause=null} [2024-05-15 15:53:11,424] 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-05-15 15:53:11.877 WARN o.g.a.c.DownstreamServiceObserver - lost connection to the central collector (will keep trying to re-establish...): java.net.ConnectException: Connection refused [2024-05-15 15:53:13,152] INFO Attempting to restart task. (io.debezium.connector.common.BaseSourceTask) [2024-05-15 15:53:13,152] INFO Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker (io.debezium.config.CommonConnectorConfig) [2024-05-15 15:53:13,154] INFO Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy (io.debezium.config.CommonConnectorConfig) [2024-05-15 15:53:13,159] ERROR WorkerSourceTask{id=test_postgres-source-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 postgres_test at io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:577) at io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:86) at io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:268) at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:178) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:469) at org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:357) 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:77) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:236) 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: The connection attempt failed. at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:354) at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54) at org.postgresql.jdbc.PgConnection.(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:243) at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:129) at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:875) at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:870) at io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:574) ... 14 more Caused by: java.net.UnknownHostException: db.myhost.com at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:229) at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.base/java.net.Socket.connect(Socket.java:615) at org.postgresql.core.PGStream.createSocket(PGStream.java:243) at org.postgresql.core.PGStream.(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-05-15 15:53:13,161] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask) [2024-05-15 15:53:13,161] INFO [Producer clientId=connector-producer-test_postgres-source-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer)