Partition: 3
Offset: 24
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-10-31 12:42:43.627
Headers: empty
{"topic":{"name":"__debezium-heartbeat.rds","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1761914563627}}
Partition: 4
Offset: 23
Key: status-topic-rds.guides.external_composers:connector-postgres-debezium-connector
Timestamp: 2025-11-04 00:58:44.929
Headers: empty
{"topic":{"name":"rds.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1762217924929}}
Partition: 3
Offset: 25
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-06 02:54:37.522
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: FATAL: password authentication failed for user \"postgres\"\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.doAuthentication(ConnectionFactoryImpl.java:693)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.tryConnect(ConnectionFactoryImpl.java:203)\n\tat org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:258)\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\n","worker_id":"172.18.0.7:8083","generation":23}
Partition: 3
Offset: 26
Key: status-connector-malicious-connector1122
Timestamp: 2025-11-07 03:22:05.893
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":24}
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: 3
Offset: 27
Key: status-connector-malicious-connector9
Timestamp: 2025-11-16 05:45:34.331
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":26}
Partition: 4
Offset: 24
Key: status-task-malicious-connector9-0
Timestamp: 2025-11-16 05:45:34.347
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":27}
Partition: 3
Offset: 28
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-19 19:01:37.022
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":28}
Partition: 3
Offset: 29
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-20 22:15:28.996
Headers: empty
{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Unable to obtain valid replication slot. Make sure there are no long-running transactions running in parallel as they may hinder the allocation of the replication slot when starting this connector\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.readReplicationSlotInfo(PostgresConnection.java:346)\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getReplicationSlotState(PostgresConnection.java:269)\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.validateLogPosition(PostgresConnection.java:837)\n\tat io.debezium.connector.common.BaseSourceTask.isLogPositionAvailable(BaseSourceTask.java:160)\n\tat io.debezium.connector.common.BaseSourceTask.validateAndLoadSchemaHistory(BaseSourceTask.java:125)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:148)\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)\n","worker_id":"172.18.0.7:8083","generation":28}
Partition: 0
Offset: 0
Key: status-connector-squtest
Timestamp: 2025-11-21 07:11:57.600
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":29}
Partition: 1
Offset: 16
Key: status-task-squtest-0
Timestamp: 2025-11-21 07:11:57.614
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":30}
Partition: 3
Offset: 30
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-23 20:48:41.803
Headers: empty
Partition: 3
Offset: 31
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-23 20:48:41.803
Headers: empty
Partition: 4
Offset: 25
Key: status-topic-rds.guides.external_composers:connector-postgres-debezium-connector
Timestamp: 2025-11-23 20:48:41.803
Headers: empty
Partition: 4
Offset: 26
Key: status-topic-rds.guides.external_composers:connector-postgres-debezium-connector
Timestamp: 2025-11-23 20:48:41.803
Headers: empty
Partition: 3
Offset: 32
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-23 20:48:41.816
Headers: empty
Partition: 3
Offset: 33
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-23 20:48:41.817
Headers: empty
Partition: 3
Offset: 34
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-23 20:48:42.392
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":35}
Partition: 3
Offset: 35
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-23 20:48:52.915
Headers: empty
{"topic":{"name":"__debezium-heartbeat.rds","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1763930932915}}
Partition: 3
Offset: 36
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-24 14:34:41.198
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":35}
Partition: 3
Offset: 37
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-24 14:35:37.354
Headers: empty
Partition: 3
Offset: 38
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-24 14:35:37.354
Headers: empty
Partition: 3
Offset: 39
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-24 14:35:37.358
Headers: empty
Partition: 3
Offset: 40
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-24 14:35:37.359
Headers: empty
Partition: 3
Offset: 41
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-24 14:35:43.196
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":40}
Partition: 3
Offset: 42
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-24 14:35:53.746
Headers: empty
{"topic":{"name":"__debezium-heartbeat.rds","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1763994953746}}
Partition: 1
Offset: 27
Key: status-topic-rds.sale.sale_approvals:connector-postgres-debezium-connector
Timestamp: 2025-11-25 01:32:45.914
Headers: empty
{"topic":{"name":"rds.sale.sale_approvals","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764034365913}}
Partition: 4
Offset: 27
Key: status-topic-rds.guides.external_composers:connector-postgres-debezium-connector
Timestamp: 2025-11-25 17:08:11.023
Headers: empty
{"topic":{"name":"rds.guides.external_composers","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764090491022}}
Partition: 3
Offset: 43
Key: status-topic-rds.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-25 22:24:17.407
Headers: empty
{"topic":{"name":"rds.clicksign.users_documents","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764109457406}}
Partition: 1
Offset: 29
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-26 01:32:04.211
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":40}
Partition: 3
Offset: 44
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-26 01:32:04.889
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":40}
Partition: 3
Offset: 45
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-26 01:32:05.204
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":41}
Partition: 1
Offset: 30
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:25.782
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":41}
Partition: 1
Offset: 31
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:25.784
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":41}
Partition: 3
Offset: 46
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-26 20:54:26.487
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":41}
Partition: 1
Offset: 32
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:39.027
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":42}
Partition: 1
Offset: 33
Key: status-topic-rds.sale.sale_approvals:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.032
Headers: empty
Partition: 3
Offset: 47
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.032
Headers: empty
Partition: 3
Offset: 48
Key: status-topic-rds.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.032
Headers: empty
Partition: 4
Offset: 28
Key: status-topic-rds.guides.external_composers:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.032
Headers: empty
Partition: 4
Offset: 29
Key: status-topic-rds.guides.external_composers:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.032
Headers: empty
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
Partition: 3
Offset: 49
Key: status-topic-__debezium-heartbeat.rds:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.033
Headers: empty
Partition: 3
Offset: 50
Key: status-topic-rds.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.033
Headers: empty
Partition: 3
Offset: 51
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-26 20:54:49.034
Headers: empty
Partition: 1
Offset: 35
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-26 20:54:49.035
Headers: empty
Partition: 3
Offset: 52
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-26 20:54:49.035
Headers: empty
Partition: 1
Offset: 36
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-27 00:29:42.536
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":45}
Partition: 3
Offset: 53
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-27 00:29:42.913
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":46}
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: 4
Offset: 30
Key: status-topic-bytea.billing.psp_charge_history:connector-postgres-debezium-connector
Timestamp: 2025-11-27 00:29:43.637
Headers: empty
{"topic":{"name":"bytea.billing.psp_charge_history","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383637}}
Partition: 1
Offset: 37
Key: status-topic-bytea.chat.conversation_messages:connector-postgres-debezium-connector
Timestamp: 2025-11-27 00:29:43.754
Headers: empty
{"topic":{"name":"bytea.chat.conversation_messages","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383754}}
Partition: 4
Offset: 31
Key: status-topic-bytea.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-27 00:29:43.874
Headers: empty
{"topic":{"name":"bytea.clicksign.users_documents","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203383874}}
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: 4
Offset: 32
Key: status-topic-__debezium-heartbeat.bytea:connector-postgres-debezium-connector
Timestamp: 2025-11-27 00:29:44.115
Headers: empty
{"topic":{"name":"__debezium-heartbeat.bytea","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764203384115}}
Partition: 1
Offset: 38
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:10:21.171
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":46}
Partition: 1
Offset: 39
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:10:21.173
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":46}
Partition: 3
Offset: 54
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-27 15:10:22.138
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":46}
Partition: 1
Offset: 40
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:10:55.283
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":47}
Partition: 1
Offset: 41
Key: status-topic-bytea.chat.conversation_messages:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: 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
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
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
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
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
Partition: 4
Offset: 33
Key: status-topic-__debezium-heartbeat.bytea:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: empty
Partition: 4
Offset: 34
Key: status-topic-bytea.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: empty
Partition: 4
Offset: 35
Key: status-topic-bytea.billing.psp_charge_history:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: empty
Partition: 4
Offset: 36
Key: status-topic-__debezium-heartbeat.bytea:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: empty
Partition: 4
Offset: 37
Key: status-topic-bytea.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: empty
Partition: 4
Offset: 38
Key: status-topic-bytea.billing.psp_charge_history:connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.287
Headers: empty
Partition: 1
Offset: 43
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-27 15:11:05.290
Headers: empty
Partition: 3
Offset: 55
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-27 15:11:05.290
Headers: empty
Partition: 3
Offset: 56
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-27 15:11:05.290
Headers: empty
Partition: 3
Offset: 57
Key: status-connector-malicious-connector9
Timestamp: 2025-11-28 11:19:51.949
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":49}
Partition: 3
Offset: 58
Key: status-connector-malicious-connector9
Timestamp: 2025-11-28 11:19:51.953
Headers: empty
Partition: 4
Offset: 39
Key: status-task-malicious-connector9-0
Timestamp: 2025-11-28 11:19:51.953
Headers: empty
Partition: 4
Offset: 40
Key: status-task-malicious-connector9-0
Timestamp: 2025-11-28 11:19:51.953
Headers: empty
Partition: 3
Offset: 59
Key: status-connector-malicious-connector1122
Timestamp: 2025-11-28 11:20:20.162
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":51}
Partition: 2
Offset: 25
Key: status-task-malicious-connector1122-0
Timestamp: 2025-11-28 11:20:20.165
Headers: empty
Partition: 2
Offset: 26
Key: status-task-malicious-connector1122-0
Timestamp: 2025-11-28 11:20:20.165
Headers: empty
Partition: 3
Offset: 60
Key: status-connector-malicious-connector1122
Timestamp: 2025-11-28 11:20:20.165
Headers: empty
Partition: 0
Offset: 1
Key: status-connector-squtest
Timestamp: 2025-11-28 11:20:40.355
Headers: empty
{"state":"UNASSIGNED","trace":null,"worker_id":"172.18.0.7:8083","generation":53}
Partition: 0
Offset: 2
Key: status-connector-squtest
Timestamp: 2025-11-28 11:20:40.361
Headers: empty
Partition: 1
Offset: 44
Key: status-task-squtest-0
Timestamp: 2025-11-28 11:20:40.361
Headers: empty
Partition: 1
Offset: 45
Key: status-task-squtest-0
Timestamp: 2025-11-28 11:20:40.361
Headers: empty
Partition: 1
Offset: 46
Key: status-connector-postgres-debezium-connector
Timestamp: 2025-11-28 11:28:03.698
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":56}
Partition: 3
Offset: 61
Key: status-task-postgres-debezium-connector-0
Timestamp: 2025-11-28 11:28:04.132
Headers: empty
{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":57}
Partition: 4
Offset: 41
Key: status-topic-__debezium-heartbeat.bytea:connector-postgres-debezium-connector
Timestamp: 2025-11-28 11:28:14.654
Headers: empty
{"topic":{"name":"__debezium-heartbeat.bytea","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764329294654}}
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: 4
Offset: 42
Key: status-topic-bytea.clicksign.users_documents:connector-postgres-debezium-connector
Timestamp: 2025-11-28 11:28:59.744
Headers: empty
{"topic":{"name":"bytea.clicksign.users_documents","connector":"postgres-debezium-connector","task":0,"discoverTimestamp":1764329339744}}
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}}
