Topic Messages: debezium_connect_statuses

Partition: 1   Offset: 34   Key: status-topic-rds.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2025-11-26 20:54:49.033 Headers: empty
 
empty
Partition: 1   Offset: 42   Key: status-topic-bytea.chat.conversation_messages:connector-postgres-debezium-connector   Timestamp: 2025-11-27 15:11:05.287 Headers: empty
 
empty
Partition: 2   Offset: 26   Key: status-task-malicious-connector1122-0   Timestamp: 2025-11-28 11:20:20.165 Headers: empty
 
empty
Partition: 1   Offset: 45   Key: status-task-squtest-0   Timestamp: 2025-11-28 11:20:40.361 Headers: empty
 
empty
Partition: 0   Offset: 3   Key: status-topic-bytea.public.debezium_heartbeat:connector-postgres-debezium-connector   Timestamp: 2026-04-08 07:21:44.073 Headers: empty
 
{"topic":{"name":"bytea.public.debezium_heartbeat","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1775632904073}}
Partition: 3   Offset: 83   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-12 09:35:25.399 Headers: empty
 
{"state":"FAILED","trace":"io.debezium.DebeziumException: Couldn't obtain encoding for database sucessoapp\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:589)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:91)\n\tat io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:375)\n\tat io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:285)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:469)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:357)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: org.postgresql.util.PSQLException: Connection to dev-sucessoapp.cmjegois0mi2.us-east-1.rds.amazonaws.com:5432 refused. Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:342)\n\tat org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54)\n\tat org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:263)\n\tat org.postgresql.Driver.makeConnection(Driver.java:443)\n\tat org.postgresql.Driver.connect(Driver.java:297)\n\tat io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:246)\n\tat io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:132)\n\tat io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:878)\n\tat io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:873)\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:586)\n\t... 14 more\nCaused by: java.net.ConnectException: Connection refused\n\tat java.base/sun.nio.ch.Net.pollConnect(Native Method)\n\tat java.base/sun.nio.ch.Net.pollConnectNow(Net.java:682)\n\tat java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:549)\n\tat java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:592)\n\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)\n\tat java.base/java.net.Socket.connect(Socket.java:751)\n\tat org.postgresql.core.PGStream.createSocket(PGStream.java:243)\n\tat org.postgresql.core.PGStream.<init>(PGStream.java:98)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:132)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:258)\n\t... 23 more\n","worker_id":"172.18.0.9:8083","generation":81}
Partition: 0   Offset: 4   Key: status-topic-bytea.public.debezium_heartbeat:connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:23:07.316 Headers: empty
 
empty
Partition: 0   Offset: 5   Key: status-topic-bytea.public.debezium_heartbeat:connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:23:07.316 Headers: empty
 
empty
Partition: 2   Offset: 38   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:23:07.316 Headers: empty
 
empty
Partition: 4   Offset: 76   Key: status-topic-bytea.clicksign.users_documents:connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:23:07.316 Headers: empty
 
empty
Partition: 3   Offset: 84   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:23:07.337 Headers: empty
 
empty
Partition: 3   Offset: 85   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:23:07.337 Headers: empty
 
empty
Partition: 3   Offset: 86   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:23:07.339 Headers: empty
 
empty
Partition: 3   Offset: 87   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:23:07.339 Headers: empty
 
empty
Partition: 3   Offset: 88   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:29:10.716 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":85}
Partition: 4   Offset: 77   Key: status-topic-__debezium-heartbeat.bytea:connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:29:16.229 Headers: empty
 
{"topic":{"name":"__debezium-heartbeat.bytea","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1782077356229}}
Partition: 0   Offset: 6   Key: status-topic-bytea.public.debezium_heartbeat:connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:29:16.230 Headers: empty
 
{"topic":{"name":"bytea.public.debezium_heartbeat","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1782077356230}}
Partition: 1   Offset: 75   Key: status-connector-postgres-debezium-connector   Timestamp: 2026-06-21 21:33:14.456 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":85}
Partition: 3   Offset: 89   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:33:14.847 Headers: empty
 
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.9:8083","generation":85}
Partition: 3   Offset: 90   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-06-21 21:33:15.358 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":86}
Partition: 2   Offset: 43   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2026-06-25 18:20:31.040 Headers: empty
 
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1782411631040}}
Partition: 4   Offset: 78   Key: status-topic-bytea.clicksign.users_documents:connector-postgres-debezium-connector   Timestamp: 2026-07-14 20:15:14.828 Headers: empty
 
{"topic":{"name":"bytea.clicksign.users_documents","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1784060114827}}
Partition: 3   Offset: 91   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-07-17 15:26:02.278 Headers: empty
 
{"state":"FAILED","trace":"io.debezium.DebeziumException: Couldn't obtain encoding for database sucessoapp\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:589)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:91)\n\tat io.debezium.connector.common.BaseSourceTask.startIfNeededAndPossible(BaseSourceTask.java:375)\n\tat io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:285)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.poll(AbstractWorkerSourceTask.java:469)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:357)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: org.postgresql.util.PSQLException: The connection attempt failed.\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:354)\n\tat org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:54)\n\tat org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:263)\n\tat org.postgresql.Driver.makeConnection(Driver.java:443)\n\tat org.postgresql.Driver.connect(Driver.java:297)\n\tat io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:246)\n\tat io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:132)\n\tat io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:878)\n\tat io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:873)\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getDatabaseCharset(PostgresConnection.java:586)\n\t... 14 more\nCaused by: java.net.UnknownHostException: dev-sucessoapp.cmjegois0mi2.us-east-1.rds.amazonaws.com\n\tat java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:567)\n\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)\n\tat java.base/java.net.Socket.connect(Socket.java:751)\n\tat org.postgresql.core.PGStream.createSocket(PGStream.java:243)\n\tat org.postgresql.core.PGStream.<init>(PGStream.java:98)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:132)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:258)\n\t... 23 more\n","worker_id":"172.18.0.9:8083","generation":86}
Partition: 3   Offset: 92   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-07-17 21:26:55.267 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":86}
Partition: 3   Offset: 93   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-07-17 21:48:58.385 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":86}
Partition: 1   Offset: 76   Key: status-connector-postgres-debezium-connector   Timestamp: 2026-07-17 21:49:58.694 Headers: empty
 
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.9:8083","generation":86}
Partition: 1   Offset: 77   Key: status-connector-postgres-debezium-connector   Timestamp: 2026-07-17 21:50:29.393 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":88}
Partition: 3   Offset: 94   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-07-17 21:50:30.720 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":88}
Partition: 3   Offset: 95   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-07-17 21:50:36.775 Headers: empty
 
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.9:8083","generation":88}
Partition: 3   Offset: 96   Key: status-task-postgres-debezium-connector-0   Timestamp: 2026-07-17 21:50:37.182 Headers: empty
 
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.9:8083","generation":88}
Partition: 2   Offset: 44   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-07-21 18:36:05.636 Headers: empty
 
{"topic":{"name":"bytea.sale.sale_approvals","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1784658965630}}
Partition: 1   Offset: 78   Key: status-topic-bytea.chat.conversation_messages:connector-postgres-debezium-connector   Timestamp: 2026-09-09 00:14:20.452 Headers: empty
 
{"topic":{"name":"bytea.chat.conversation_messages","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1788912860451}}