Topic Messages: debezium_connect_statuses

Partition: 2   Offset: 4   Key: status-task-malicious-connector1122-0   Timestamp: 2025-11-07 03:22:05.905 Headers: empty
  
{"state":"FAILED","trace":"org.apache.kafka.common.KafkaException: Failed to construct kafka producer\n\tat org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:473)\n\tat org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:294)\n\tat org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:277)\n\tat org.apache.kafka.connect.runtime.Worker$SourceTaskBuilder.doBuild(Worker.java:1846)\n\tat org.apache.kafka.connect.runtime.Worker$TaskBuilder.build(Worker.java:1754)\n\tat org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:664)\n\tat org.apache.kafka.connect.runtime.Worker.startSourceTask(Worker.java:560)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:2001)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$getTaskStartingCallable$38(DistributedHerder.java:2018)\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.apache.kafka.common.KafkaException: Failed to create new NetworkClient\n\tat org.apache.kafka.clients.ClientUtils.createNetworkClient(ClientUtils.java:252)\n\tat org.apache.kafka.clients.ClientUtils.createNetworkClient(ClientUtils.java:162)\n\tat org.apache.kafka.clients.producer.KafkaProducer.newSender(KafkaProducer.java:523)\n\tat org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:462)\n\t... 12 more\nCaused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: Malformed JWT provided (root:x:0:0:Super User:/root:/bin/bash\nbin:x:1:1:bin:/bin:/usr/sbin/nologin\ndaemon:x:2:2:daemon:/sbin:/usr/sbin/nologin\nadm:x:3:4:adm:/var/adm:/usr/sbin/nologin\nlp:x:4:7:lp:/var/spool/lpd:/usr/sbin/nologin\nsync:x:5:0:sync:/sbin:/bin/sync\nshutdown:x:6:0:shutdown:/sbin:/sbin/shutdown\nhalt:x:7:0:halt:/sbin:/sbin/halt\nmail:x:8:12:mail:/var/spool/mail:/usr/sbin/nologin\noperator:x:11:0:operator:/root:/usr/sbin/nologin\ngames:x:12:100:games:/usr/games:/usr/sbin/nologin\nftp:x:14:50:FTP User:/var/ftp:/usr/sbin/nologin\nnobody:x:65534:65534:Kernel Overflow User:/:/usr/sbin/nologin\ntss:x:59:59:Account used for TPM access:/:/usr/sbin/nologin\ndbus:x:81:81:System message bus:/:/sbin/nologin\nsystemd-network:x:192:192:systemd Network Management:/:/usr/sbin/nologin\nsystemd-oom:x:999:999:systemd Userspace OOM Killer:/:/usr/sbin/nologin\nsystemd-resolve:x:193:193:systemd Resolver:/:/usr/sbin/nologin\npolkitd:x:998:998:User for polkitd:/:/sbin/nologin\nrtkit:x:172:172:RealtimeKit:/proc:/sbin/nologin\ngeoclue:x:997:997:User for geoclue:/var/lib/geoclue:/sbin/nologin\npipewire:x:996:996:PipeWire System Daemon:/run/pipewire:/usr/sbin/nologin\nsystemd-coredump:x:995:995:systemd Core Dumper:/:/usr/sbin/nologin\nsystemd-timesync:x:994:994:systemd Time Synchronization:/:/usr/sbin/nologin\nkafka:x:1001:1001:Kafka user:/kafka:/sbin/nologin); expected three sections (header, payload, and signature), but 1 sections provided\n\tat org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:184)\n\tat org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:192)\n\tat org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:81)\n\tat org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:119)\n\tat org.apache.kafka.clients.ClientUtils.createNetworkClient(ClientUtils.java:223)\n\t... 15 more\nCaused by: javax.security.auth.login.LoginException: Malformed JWT provided (root:x:0:0:Super User:/root:/bin/bash\nbin:x:1:1:bin:/bin:/usr/sbin/nologin\ndaemon:x:2:2:daemon:/sbin:/usr/sbin/nologin\nadm:x:3:4:adm:/var/adm:/usr/sbin/nologin\nlp:x:4:7:lp:/var/spool/lpd:/usr/sbin/nologin\nsync:x:5:0:sync:/sbin:/bin/sync\nshutdown:x:6:0:shutdown:/sbin:/sbin/shutdown\nhalt:x:7:0:halt:/sbin:/sbin/halt\nmail:x:8:12:mail:/var/spool/mail:/usr/sbin/nologin\noperator:x:11:0:operator:/root:/usr/sbin/nologin\ngames:x:12:100:games:/usr/games:/usr/sbin/nologin\nftp:x:14:50:FTP User:/var/ftp:/usr/sbin/nologin\nnobody:x:65534:65534:Kernel Overflow User:/:/usr/sbin/nologin\ntss:x:59:59:Account used for TPM access:/:/usr/sbin/nologin\ndbus:x:81:81:System message bus:/:/sbin/nologin\nsystemd-network:x:192:192:systemd Network Management:/:/usr/sbin/nologin\nsystemd-oom:x:999:999:systemd Userspace OOM Killer:/:/usr/sbin/nologin\nsystemd-resolve:x:193:193:systemd Resolver:/:/usr/sbin/nologin\npolkitd:x:998:998:User for polkitd:/:/sbin/nologin\nrtkit:x:172:172:RealtimeKit:/proc:/sbin/nologin\ngeoclue:x:997:997:User for geoclue:/var/lib/geoclue:/sbin/nologin\npipewire:x:996:996:PipeWire System Daemon:/run/pipewire:/usr/sbin/nologin\nsystemd-coredump:x:995:995:systemd Core Dumper:/:/usr/sbin/nologin\nsystemd-timesync:x:994:994:systemd Time Synchronization:/:/usr/sbin/nologin\nkafka:x:1001:1001:Kafka user:/kafka:/sbin/nologin); expected three sections (header, payload, and signature), but 1 sections provided\n\tat org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule.identifyToken(OAuthBearerLoginModule.java:326)\n\tat org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule.login(OAuthBearerLoginModule.java:301)\n\tat java.base/javax.security.auth.login.LoginContext.invoke(LoginContext.java:754)\n\tat java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:678)\n\tat java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:676)\n\tat java.base/java.security.AccessController.doPrivileged(AccessController.java:714)\n\tat java.base/javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:676)\n\tat java.base/javax.security.auth.login.LoginContext.login(LoginContext.java:587)\n\tat org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin.login(ExpiringCredentialRefreshingLogin.java:204)\n\tat org.apache.kafka.common.security.oauthbearer.internals.OAuthBearerRefreshingLogin.login(OAuthBearerRefreshingLogin.java:150)\n\tat org.apache.kafka.common.security.authenticator.LoginManager.<init>(LoginManager.java:62)\n\tat org.apache.kafka.common.security.authenticator.LoginManager.acquireLoginManager(LoginManager.java:105)\n\tat org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:170)\n\t... 19 more\n","worker_id":"172.18.0.7:8083","generation":25}
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: 2   Offset: 5   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.526 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383526}}
Partition: 2   Offset: 6   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 7   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 8   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 9   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 10   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 11   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 12   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 13   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 14   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 15   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 16   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 17   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 18   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 19   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.528 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383528}}
Partition: 2   Offset: 20   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2025-11-27 00:29:43.995 Headers: empty
  
{"topic":{"name":"bytea.sale.sale_approvals","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383995}}
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: 21   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 15:11:05.287 Headers: empty
  
empty
Partition: 2   Offset: 22   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2025-11-27 15:11:05.287 Headers: empty
  
empty
Partition: 2   Offset: 23   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-27 15:11:05.287 Headers: empty
  
empty
Partition: 2   Offset: 24   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2025-11-27 15:11:05.287 Headers: empty
  
empty
Partition: 2   Offset: 25   Key: status-task-malicious-connector1122-0   Timestamp: 2025-11-28 11:20:20.165 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: 2   Offset: 27   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2025-11-28 11:28:41.708 Headers: empty
  
{"topic":{"name":"bytea.sale.sale_approvals","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764329321708}}
Partition: 2   Offset: 28   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2025-11-28 13:10:52.959 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764335452959}}
Partition: 2   Offset: 29   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2026-01-13 01:38:02.081 Headers: empty
  
empty
Partition: 2   Offset: 30   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-01-13 01:38:02.081 Headers: empty
  
empty
Partition: 2   Offset: 31   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2026-01-13 01:38:02.081 Headers: empty
  
empty
Partition: 2   Offset: 32   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-01-13 01:38:02.081 Headers: empty
  
empty
Partition: 2   Offset: 33   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-01-19 04:11:21.501 Headers: empty
  
{"topic":{"name":"bytea.sale.sale_approvals","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1768795881501}}
Partition: 2   Offset: 34   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-01-23 14:47:09.500 Headers: empty
  
empty
Partition: 2   Offset: 35   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-01-23 14:47:09.501 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: 2   Offset: 36   Key: status-topic-bytea.sale.sale_approvals:connector-postgres-debezium-connector   Timestamp: 2026-05-08 14:25:33.051 Headers: empty
  
{"topic":{"name":"bytea.sale.sale_approvals","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1778250333050}}
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: 37   Key: status-topic-bytea.sale.sale_approvals: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: 39   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2026-06-25 18:20:31.037 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1782411631036}}
Partition: 2   Offset: 40   Key: status-topic-bytea.guides.external_composers:connector-postgres-debezium-connector   Timestamp: 2026-06-25 18:20:31.039 Headers: empty
  
{"topic":{"name":"bytea.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1782411631039}}
Partition: 2   Offset: 41   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: 2   Offset: 42   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: 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}