Kafdrop

{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":2}

{"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.PostgresConnectorTask.start(PostgresConnectorTask.java:158)\n\tat io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:248)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:280)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:202)\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":3}

{"state":"RUNNING","trace":null,"worker_id":"172.18.0.7:8083","generation":4}

{"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":5}