Topic Messages: connect-cluster-status

Partition: 4   Offset: 0   Key: status-connector-common-webhook-connector   Timestamp: 2025-11-24 10:55:34.259 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":2}
Partition: 2   Offset: 0   Key: status-task-common-webhook-connector-0   Timestamp: 2025-11-24 10:55:34.527 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":3}
Partition: 2   Offset: 8   Key: status-topic-events.webhook.common_webhook:connector-common-webhook-connector   Timestamp: 2025-11-24 10:55:36.057 Headers: empty
  
{"topic":{"name":"events.webhook.common_webhook","connector":"common-webhook-connector","task":0,"discoverTimestamp":1763981736057}}
Partition: 3   Offset: 0   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2025-11-25 05:33:33.979 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":4}
Partition: 3   Offset: 1   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2025-11-25 05:33:34.097 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":5}
Partition: 0   Offset: 9   Key: status-topic-events.public.UserTrackings:connector-debezium-ocean-scrappingtrackings   Timestamp: 2025-11-25 05:33:34.887 Headers: empty
  
{"topic":{"name":"events.public.UserTrackings","connector":"debezium-ocean-scrappingtrackings","task":0,"discoverTimestamp":1764048814887}}
Partition: 3   Offset: 6   Key: status-task-debezium-vessel-ais-connector-0   Timestamp: 2025-11-25 06:09:34.232 Headers: empty
  
empty
Partition: 1   Offset: 0   Key: status-connector-debezium-events-trackings   Timestamp: 2025-11-25 06:37:33.833 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":10}
Partition: 1   Offset: 1   Key: status-connector-debezium-user-trackings   Timestamp: 2025-11-25 06:37:33.850 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":11}
Partition: 2   Offset: 13   Key: status-task-debezium-events-trackings-0   Timestamp: 2025-11-25 06:37:33.947 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":12}
Partition: 3   Offset: 7   Key: status-task-debezium-user-trackings-0   Timestamp: 2025-11-25 06:37:33.953 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":12}
Partition: 2   Offset: 20   Key: status-topic-event.public.UserTrackings:connector-debezium-user-trackings   Timestamp: 2025-11-25 06:37:34.636 Headers: empty
  
{"topic":{"name":"event.public.UserTrackings","connector":"debezium-user-trackings","task":0,"discoverTimestamp":1764052654636}}
Partition: 4   Offset: 7   Key: status-topic-events.intemo_dev.awb_details:connector-debezium-events-trackings   Timestamp: 2025-11-25 06:39:24.334 Headers: empty
  
{"topic":{"name":"events.intemo_dev.awb_details","connector":"debezium-events-trackings","task":0,"discoverTimestamp":1764052764334}}
Partition: 2   Offset: 23   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2025-11-25 12:53:33.824 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":15}
Partition: 3   Offset: 11   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2025-11-25 12:53:33.874 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":16}
Partition: 0   Offset: 12   Key: status-topic-event.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2025-11-25 12:54:56.601 Headers: empty
  
{"topic":{"name":"event.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1764075296601}}
Partition: 3   Offset: 12   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-04-30 06:32:54.981 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":31}
Partition: 2   Offset: 29   Key: status-topic-event.public.bot_entries:connector-bot-entry-workflow-connector   Timestamp: 2026-04-30 06:34:45.217 Headers: empty
  
{"topic":{"name":"event.public.bot_entries","connector":"bot-entry-workflow-connector","task":0,"discoverTimestamp":1777530885217}}
Partition: 3   Offset: 13   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-04 08:52:54.970 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":32}
Partition: 3   Offset: 14   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-04 08:52:54.978 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":32}
Partition: 1   Offset: 4   Key: status-task-bot-entry-workflow-connector-0   Timestamp: 2026-05-04 08:52:55.550 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":33}
Partition: 1   Offset: 5   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:16:55.177 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":35}
Partition: 1   Offset: 6   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:16:55.180 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":35}
Partition: 1   Offset: 7   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:44:54.981 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":35}
Partition: 1   Offset: 8   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:44:54.986 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":35}
Partition: 3   Offset: 15   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-21 11:44:55.699 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":35}
Partition: 3   Offset: 16   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-21 11:44:55.729 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 1   Offset: 9   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:45:44.450 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 3   Offset: 17   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-21 11:45:44.450 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 3   Offset: 18   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-21 11:45:44.450 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 1   Offset: 10   Key: status-connector-debezium-events-trackings   Timestamp: 2026-05-21 11:45:44.451 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 2   Offset: 30   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-21 11:45:44.451 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 4   Offset: 8   Key: status-connector-common-webhook-connector   Timestamp: 2026-05-21 11:45:44.451 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 3   Offset: 19   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2026-05-21 11:45:44.891 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 1   Offset: 11   Key: status-task-bot-entry-workflow-connector-0   Timestamp: 2026-05-21 11:45:45.082 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 3   Offset: 20   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-21 11:45:45.082 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 2   Offset: 31   Key: status-task-debezium-events-trackings-0   Timestamp: 2026-05-21 11:45:45.083 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 2   Offset: 32   Key: status-task-common-webhook-connector-0   Timestamp: 2026-05-21 11:45:45.594 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 3   Offset: 21   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-21 11:45:45.796 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":36}
Partition: 1   Offset: 13   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:46:00.442 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 22   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-21 11:46:00.443 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 23   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-21 11:46:00.443 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 12   Key: status-connector-debezium-events-trackings   Timestamp: 2026-05-21 11:46:00.445 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 2   Offset: 33   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-21 11:46:00.445 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 24   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-21 11:46:00.735 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 2   Offset: 34   Key: status-task-debezium-events-trackings-0   Timestamp: 2026-05-21 11:46:00.748 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 25   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-21 11:46:00.749 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 26   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2026-05-21 11:46:00.751 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 14   Key: status-task-bot-entry-workflow-connector-0   Timestamp: 2026-05-21 11:46:00.762 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 4   Offset: 9   Key: status-connector-common-webhook-connector   Timestamp: 2026-05-21 11:46:00.819 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 2   Offset: 35   Key: status-task-common-webhook-connector-0   Timestamp: 2026-05-21 11:46:00.977 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 15   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:46:55.053 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 16   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-21 11:46:55.070 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 27   Key: status-topic-events.public.UserTrackings:connector-debezium-user-trackings   Timestamp: 2026-05-21 11:47:52.027 Headers: empty
  
{"topic":{"name":"events.public.UserTrackings","connector":"debezium-user-trackings","task":0,"discoverTimestamp":1779364072025}}
Partition: 3   Offset: 28   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-21 12:38:48.766 Headers: empty
  
{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Unrecoverable exception from producer send callback\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.maybeThrowProducerSendException(WorkerSourceTask.java:342)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.prepareToSendRecord(WorkerSourceTask.java:134)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:407)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:363)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:225)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:280)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:78)\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:539)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\n\tat java.base/java.lang.Thread.run(Thread.java:840)\nCaused by: org.apache.kafka.common.errors.RecordTooLargeException: The message is 1915743 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.\n","worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 17   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-22 05:52:19.007 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 18   Key: status-connector-debezium-events-trackings   Timestamp: 2026-05-22 05:52:19.007 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 2   Offset: 36   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 05:52:19.007 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 29   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-22 05:52:19.007 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 30   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-22 05:52:19.007 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 4   Offset: 10   Key: status-connector-common-webhook-connector   Timestamp: 2026-05-22 05:52:19.008 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 31   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 05:52:19.478 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 3   Offset: 32   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2026-05-22 05:52:19.505 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 2   Offset: 37   Key: status-task-common-webhook-connector-0   Timestamp: 2026-05-22 05:52:19.574 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 19   Key: status-task-bot-entry-workflow-connector-0   Timestamp: 2026-05-22 05:52:19.792 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 2   Offset: 38   Key: status-task-debezium-events-trackings-0   Timestamp: 2026-05-22 05:52:19.792 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":38}
Partition: 1   Offset: 21   Key: status-connector-debezium-events-trackings   Timestamp: 2026-05-22 05:52:33.305 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 1   Offset: 20   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-22 05:52:33.306 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 2   Offset: 39   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 05:52:33.306 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 33   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-22 05:52:33.306 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 34   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-22 05:52:33.306 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 35   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-22 05:52:33.788 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 2   Offset: 40   Key: status-task-debezium-events-trackings-0   Timestamp: 2026-05-22 05:52:33.790 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 1   Offset: 22   Key: status-task-bot-entry-workflow-connector-0   Timestamp: 2026-05-22 05:52:33.804 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 36   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 05:52:33.806 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 37   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2026-05-22 05:52:33.819 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 4   Offset: 11   Key: status-connector-common-webhook-connector   Timestamp: 2026-05-22 05:52:33.859 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 2   Offset: 41   Key: status-task-common-webhook-connector-0   Timestamp: 2026-05-22 05:52:34.178 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 38   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-22 05:54:30.785 Headers: empty
  
{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Unrecoverable exception from producer send callback\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.maybeThrowProducerSendException(WorkerSourceTask.java:342)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.prepareToSendRecord(WorkerSourceTask.java:134)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:407)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:363)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:225)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:280)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:78)\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:539)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\n\tat java.base/java.lang.Thread.run(Thread.java:840)\nCaused by: org.apache.kafka.common.errors.RecordTooLargeException: The message is 1915743 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.\n","worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 2   Offset: 42   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:08:55.277 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 2   Offset: 43   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:08:55.286 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 39   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 06:08:55.809 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":40}
Partition: 3   Offset: 40   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 06:08:55.860 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":41}
Partition: 0   Offset: 13   Key: status-topic-eventt.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:08:56.245 Headers: empty
  
{"topic":{"name":"eventt.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1779430136244}}
Partition: 0   Offset: 14   Key: status-topic-eventt.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:08:56.253 Headers: empty
  
{"topic":{"name":"eventt.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1779430136252}}
Partition: 2   Offset: 44   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:10:55.230 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":41}
Partition: 2   Offset: 45   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:10:55.234 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":41}
Partition: 3   Offset: 41   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 06:10:55.875 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":41}
Partition: 3   Offset: 42   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 06:10:55.909 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 4   Offset: 12   Key: status-topic-local.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:10:56.068 Headers: empty
  
{"topic":{"name":"local.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1779430256068}}
Partition: 4   Offset: 13   Key: status-topic-local.public.container_bl_details:connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:10:56.073 Headers: empty
  
{"topic":{"name":"local.public.container_bl_details","connector":"debezium-ocean-mastertracking","task":0,"discoverTimestamp":1779430256073}}
Partition: 2   Offset: 46   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:12:54.919 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 2   Offset: 47   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:12:54.931 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 1   Offset: 23   Key: status-connector-debezium-events-trackings   Timestamp: 2026-05-22 06:16:58.129 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 1   Offset: 24   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-22 06:16:58.130 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 2   Offset: 48   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:16:58.130 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 3   Offset: 43   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-22 06:16:58.130 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 3   Offset: 44   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-22 06:16:58.132 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 4   Offset: 14   Key: status-connector-common-webhook-connector   Timestamp: 2026-05-22 06:16:58.132 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":42}
Partition: 1   Offset: 25   Key: status-connector-debezium-user-trackings   Timestamp: 2026-05-22 06:22:25.986 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 45   Key: status-connector-bot-entry-workflow-connector   Timestamp: 2026-05-22 06:22:25.987 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 2   Offset: 49   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 06:22:25.992 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 46   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-22 06:22:26.000 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 1   Offset: 26   Key: status-connector-debezium-events-trackings   Timestamp: 2026-05-22 06:22:26.024 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 4   Offset: 15   Key: status-connector-common-webhook-connector   Timestamp: 2026-05-22 06:22:26.032 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 2   Offset: 50   Key: status-task-debezium-events-trackings-0   Timestamp: 2026-05-22 06:22:26.101 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 47   Key: status-task-debezium-ocean-scrappingtrackings-0   Timestamp: 2026-05-22 06:22:26.128 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 2   Offset: 51   Key: status-task-common-webhook-connector-0   Timestamp: 2026-05-22 06:22:26.138 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 1   Offset: 27   Key: status-task-bot-entry-workflow-connector-0   Timestamp: 2026-05-22 06:22:26.147 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 48   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-22 06:22:26.199 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 49   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 06:22:26.202 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 50   Key: status-task-debezium-user-trackings-0   Timestamp: 2026-05-22 06:24:21.646 Headers: empty
  
{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Unrecoverable exception from producer send callback\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.maybeThrowProducerSendException(WorkerSourceTask.java:342)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.prepareToSendRecord(WorkerSourceTask.java:134)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:407)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:363)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:225)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:280)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:78)\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:539)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\n\tat java.base/java.lang.Thread.run(Thread.java:840)\nCaused by: org.apache.kafka.common.errors.RecordTooLargeException: The message is 1915743 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.\n","worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 51   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-22 08:42:55.160 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 52   Key: status-connector-debezium-ocean-scrappingtrackings   Timestamp: 2026-05-22 08:42:55.165 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 2   Offset: 52   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 08:42:55.190 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 2   Offset: 53   Key: status-connector-debezium-ocean-mastertracking   Timestamp: 2026-05-22 08:42:55.195 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 53   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 08:42:55.542 Headers: empty
  
{"state":"UNASSIGNED","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":45}
Partition: 3   Offset: 54   Key: status-task-debezium-ocean-mastertracking-0   Timestamp: 2026-05-22 08:42:55.577 Headers: empty
  
{"state":"RUNNING","trace":null,"worker_id":"staging-intemo-kafka-connect-connect-0.staging-intemo-kafka-connect-connect.default.svc:8083","generation":46}