Re: [I] Duplicate file path found in Iceberg metadata snapshot [iceberg]

["lkindere (via GitHub)" <gi...@apache.org>]

lkindere commented on issue #13763:
URL: https://github.com/apache/iceberg/issues/13763#issuecomment-3258355131

   Any updates about this issue? Seems this is still occurring and is caused by the IcebergSinkConnector
   Currently Using 1.8.2 Kafka connect with 1.9.1 Iceberg core (as 1.9.1 Kafka connect seems unstable, and Iceberg core 1.9.1 is required for OAuth)
   
   Example if we query table.entries for the specific file path we get an error for (<prefix>00001-1756997337361-a7efb760-7ff6-43f2-a4a7-0ba2720ce11c-00002.parquet):
   ```json
   [
     {
       "status": 0,
       "snapshot_id": 4343445114214793138,
       "sequence_number": 39188,
       "file_sequence_number": 39188,
       "data_file": {
         "content": 0,
         "file_path": "<prefix>00001-1756997337361-a7efb760-7ff6-43f2-a4a7-0ba2720ce11c-00002.parquet",
         "file_format": "PARQUET",
         "spec_id": 0,
         "partition": {
           "country_code": "<cc>",
           "entity_number": "<en>"
         },
         "record_count": 5,
         "file_size_in_bytes": 11302,
         "column_sizes": {},
         "value_counts": {},
         "null_value_counts": {},
         "nan_value_counts": {},
         "lower_bounds": {},
         "upper_bounds": {},
         "split_offsets": [
           4
         ],
         "sort_order_id": 0
       },
       "readable_metrics": {
         "C440_BOX": {},
         "C440_DD": {},
         "C440_EP": {},
         "C440_FORMDATE": {},
         "C440_FORMNO": {},
         "C440_ID": {},
         "C440_LINE": {},
         "C440_MODDATE": {},
         "C440_MODUSER": {},
         "C440_STATUS": {},
         "C440_STORENAME": {},
         "C440_STORENO": {},
         "__kafka_metadata.__kafka_insert_time": {},
         "__kafka_metadata.__kafka_offset": {},
         "__kafka_metadata.__kafka_partition": {},
         "__kafka_metadata.__kafka_topic": {},
         "__md5": {},
         "country_code": {},
         "created_at": {},
         "current_ts": {},
         "db_name": {},
         "entity_number": {},
         "ingested_at": {},
         "op_ts": {},
         "op_type": {},
         "pos": {},
         "primary_keys.element": {},
         "scn": {},
         "table": {},
         "table_name": {},
         "updated_at": {}
       }
     },
     {
       "status": 0,
       "snapshot_id": 2368336716243636983,
       "sequence_number": 39187,
       "file_sequence_number": 39187,
       "data_file": {
         "content": 0,
         "file_path": "<prefix>00001-1756997337361-a7efb760-7ff6-43f2-a4a7-0ba2720ce11c-00002.parquet",
         "file_format": "PARQUET",
         "spec_id": 0,
         "partition": {
           "country_code": "<cc>",
           "entity_number": "<en>"
         },
         "record_count": 5,
         "file_size_in_bytes": 11302,
         "column_sizes": {},
         "value_counts": {},
         "null_value_counts": {},
         "nan_value_counts": {},
         "lower_bounds": {},
         "upper_bounds": {},
         "split_offsets": [
           4
         ],
         "sort_order_id": 0
       },
       "readable_metrics": {
         "C440_BOX": {},
         "C440_DD": {},
         "C440_EP": {},
         "C440_FORMDATE": {},
         "C440_FORMNO": {},
         "C440_ID": {},
         "C440_LINE": {},
         "C440_MODDATE": {},
         "C440_MODUSER": {},
         "C440_STATUS": {},
         "C440_STORENAME": {},
         "C440_STORENO": {},
         "__kafka_metadata.__kafka_insert_time": {},
         "__kafka_metadata.__kafka_offset": {},
         "__kafka_metadata.__kafka_partition": {},
         "__kafka_metadata.__kafka_topic": {},
         "__md5": {},
         "country_code": {},
         "created_at": {},
         "current_ts": {},
         "db_name": {},
         "entity_number": {},
         "ingested_at": {},
         "op_ts": {},
         "op_type": {},
         "pos": {},
         "primary_keys.element": {},
         "scn": {},
         "table": {},
         "table_name": {},
         "updated_at": {}
       }
     }
   ]
   ```
   
   We can see these 2 snapshots both reference it:
   ```json
   [
     {
       "committed_at": "2025-09-04T14:57:35.853Z",
       "snapshot_id": 2368336716243636983,
       "parent_id": 1965811163510447977,
       "operation": "append",
       "manifest_list": " <prefix>snap-2368336716243636983-1-344ffdba-5b08-4ff0-a1ba-490de9e49e73.avro",
       "summary": {
         "kafka.connect.commit-id": "f7a3a2b1-ecf3-4e10-ace3-178d0d1ddda8",
         "kafka.connect.offsets.wawi.iceberg-control-small_12.connect-small-12-sink-iceberg": "{\"0\":2519423}",
         "added-data-files": "2",
         "added-records": "8",
         "added-files-size": "22558",
         "changed-partition-count": "2",
         "total-records": "1879575",
         "total-files-size": "75751857",
         "total-data-files": "283",
         "total-delete-files": "0",
         "total-position-deletes": "0",
         "total-equality-deletes": "0",
         "iceberg-version": "Apache Iceberg 1.9.2 (commit 071d5606bc6199a0be9b3f274ec7fbf111d88821)"
       }
     },
     {
       "committed_at": "2025-09-04T15:00:25.774Z",
       "snapshot_id": 4343445114214793138,
       "parent_id": 2368336716243636983,
       "operation": "append",
       "manifest_list": " <prefix>snap-4343445114214793138-1-edf12025-d320-48af-8186-73032c7f6138.avro",
       "summary": {
         "kafka.connect.commit-id": "745a6aaa-a827-46cb-9066-1f96d280437c",
         "kafka.connect.offsets.wawi.iceberg-control-small_12.connect-small-12-sink-iceberg": "{\"0\":2519418}",
         "added-data-files": "2",
         "added-records": "8",
         "added-files-size": "22558",
         "changed-partition-count": "2",
         "total-records": "1879583",
         "total-files-size": "75774415",
         "total-data-files": "285",
         "total-delete-files": "0",
         "total-position-deletes": "0",
         "total-equality-deletes": "0",
         "iceberg-version": "Apache Iceberg 1.9.2 (commit 071d5606bc6199a0be9b3f274ec7fbf111d88821)"
       }
     }
   ]
   ```
   
   
   
   It seems possibly to be caused by the connector tasks restarting, for example here are partial Kafka logs for when this occurred:
   
   ```diff
   [2025-09-04 14:55:00,864] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1432530602, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:00,864] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1849102486, epoch=INITIAL) to node 0: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:00,864] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1937322821, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:00,864] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:13,230] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to socket connection setup timeout. The timeout value is 30000 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 14:55:18,353] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Finished assignment for group at generation 322: {54adfc40-66fd-4773-9dd9-7899b4fa28d1-6e308fd6-be02-4a17-bad1-68591a67292f=Assignment(partitions=[ <prefix>.iceberg-control-small_12-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:664)
   [2025-09-04 14:55:18,353] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Successfully joined group with generation Generation{generationId=322, memberId='54adfc40-66fd-4773-9dd9-7899b4fa28d1-6e308fd6-be02-4a17-bad1-68591a67292f', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 14:55:18,357] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Adding newly assigned partitions:  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:58)
   [2025-09-04 14:55:18,357] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Notifying assignor about the new Assignment(partitions=[ <prefix>.iceberg-control-small_12-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:324)
   [2025-09-04 14:55:18,357] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Successfully synced group in generation Generation{generationId=322, memberId='54adfc40-66fd-4773-9dd9-7899b4fa28d1-6e308fd6-be02-4a17-bad1-68591a67292f', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:843)
   [2025-09-04 14:55:25,743] INFO [Consumer clientId=e1f2b595-2264-49d7-b82f-3840d8659dd8, groupId=connect-table-small-12-sink-iceberg-coord] Request joining group due to: group is already rebalancing (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 14:55:32,026] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-1] Node 2 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1230 due to node 1 being disconnected (elapsed time since creation: 60001ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1228 due to node 2 being disconnected (elapsed time since creation: 60001ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1227 due to node 3 being disconnected (elapsed time since creation: 60001ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1232 due to node 4 being disconnected (elapsed time since creation: 60001ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1231 due to node 5 being disconnected (elapsed time since creation: 60001ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:55:34,639] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=661248138, epoch=10) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:34,640] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=38) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:34,640] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=34) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:34,640] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:34,640] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:55:34,723] INFO [table-small-12-sink-iceberg|task-1] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 14:56:03,091] INFO [Consumer clientId=e1f2b595-2264-49d7-b82f-3840d8659dd8, groupId=connect-table-small-12-sink-iceberg-coord] Attempt to heartbeat with Generation{generationId=321, memberId='e1f2b595-2264-49d7-b82f-3840d8659dd8-ee13b369-a385-45e7-84b1-2fc57c62efb5', protocol='range'} and group instance id Optional.empty failed due to UNKNOWN_MEMBER_ID, resetting generation (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1267)
   [2025-09-04 14:56:03,091] INFO [Consumer clientId=e1f2b595-2264-49d7-b82f-3840d8659dd8, groupId=connect-table-small-12-sink-iceberg-coord] Group coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483647 rack: null isFenced: false) is unavailable or invalid due to cause: session timed out without receiving a heartbeat response. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)
   [2025-09-04 14:56:03,091] INFO [Consumer clientId=e1f2b595-2264-49d7-b82f-3840d8659dd8, groupId=connect-table-small-12-sink-iceberg-coord] Request joining group due to: encountered UNKNOWN_MEMBER_ID from HEARTBEAT response (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 14:56:03,091] INFO [Consumer clientId=e1f2b595-2264-49d7-b82f-3840d8659dd8, groupId=connect-table-small-12-sink-iceberg-coord] Requesting disconnect from last known coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483647 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1013)
   [2025-09-04 14:56:03,091] INFO [Consumer clientId=e1f2b595-2264-49d7-b82f-3840d8659dd8, groupId=connect-table-small-12-sink-iceberg-coord] Resetting generation and member id due to: encountered UNKNOWN_MEMBER_ID from HEARTBEAT response (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1056)
   [2025-09-04 14:56:15,611] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to socket connection setup timeout. The timeout value is 29140 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 14:56:34,763] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1254 due to node 3 being disconnected (elapsed time since creation: 60015ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:56:34,763] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:56:34,763] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:56:34,771] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1258 due to node 4 being disconnected (elapsed time since creation: 60023ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:56:34,771] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1257 due to node 5 being disconnected (elapsed time since creation: 60023ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:56:34,771] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 1286 due to node 4 being disconnected (elapsed time since creation: 7ms, elapsed time since send: 7ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:56:34,771] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:56:34,771] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:56:34,771] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:56:34,772] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1256 due to node 1 being disconnected (elapsed time since creation: 60024ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:56:34,772] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:56:34,772] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=661248138, epoch=INITIAL) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:56:34,772] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:56:34,779] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1255 due to node 2 being disconnected (elapsed time since creation: 60031ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:56:34,779] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:56:34,780] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:56:40,624] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Node 5 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 14:56:40,626] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to client rebootstrap. (org.apache.kafka.clients.NetworkClient:1242)
   [2025-09-04 14:56:40,628] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Rebootstrapping with [<cluster>.azure.confluent.cloud/10.1.0.29:9092] (org.apache.kafka.clients.Metadata:315)
   [2025-09-04 14:57:05,850] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=7a6ff60d-921d-4c34-aaf5-db36b0d84ae6, groupId=cg-control-4c0a0f91-e567-44ba-a37a-db5e33bd4f15] Client requested disconnect from node 2147483646 (org.apache.kafka.clients.NetworkClient:460)
   [2025-09-04 14:57:05,857] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=7a6ff60d-921d-4c34-aaf5-db36b0d84ae6, groupId=cg-control-4c0a0f91-e567-44ba-a37a-db5e33bd4f15] Discovered group coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483646 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 14:57:05,858] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=7a6ff60d-921d-4c34-aaf5-db36b0d84ae6, groupId=cg-control-4c0a0f91-e567-44ba-a37a-db5e33bd4f15] Group coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483646 rack: null isFenced: false) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)
   [2025-09-04 14:57:05,861] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=7a6ff60d-921d-4c34-aaf5-db36b0d84ae6, groupId=cg-control-4c0a0f91-e567-44ba-a37a-db5e33bd4f15] Requesting disconnect from last known coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483646 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1013)
   [2025-09-04 14:57:18,386] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Disconnecting from node 2 due to socket connection setup timeout. The timeout value is 9445 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 14:57:34,949] INFO [table-small-12-sink-iceberg|task-1] Sending event of type: DATA_COMPLETE (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 14:57:34,949] INFO [table-small-12-sink-iceberg|task-1] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1287 due to node 3 being disconnected (elapsed time since creation: 60098ms, elapsed time since send: 60086ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1288 due to node 2 being disconnected (elapsed time since creation: 60098ms, elapsed time since send: 60060ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1290 due to node 5 being disconnected (elapsed time since creation: 60098ms, elapsed time since send: 60077ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1291 due to node 4 being disconnected (elapsed time since creation: 60098ms, elapsed time since send: 60077ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:57:34,976] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:57:35,514] INFO [table-small-12-sink-iceberg|task-1] Handled event of type: START_COMMIT (org.apache.iceberg.connect.channel.Channel:133)
   [2025-09-04 14:57:35,603] INFO [table-small-12-sink-iceberg|task-1] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 14:57:35,685] INFO [table-small-12-sink-iceberg|task-1] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   
   + [2025-09-04 14:57:36,044] INFO Committed snapshot 2368336716243636983 (MergeAppend)(org.apache.iceberg.SnapshotProducer:481)
   + [2025-09-04 14:57:36,161] INFO Received metrics report: CommitReport{tableName=polaris.raw.t440_bal_head, snapshotId=2368336716243636983, sequenceNumber=39187, operation=append, commitMetrics=CommitMetricsResult{totalDuration=TimerResult{timeUnit=NANOSECONDS, totalDuration=PT0.4885257S, count=1}, attempts=CounterResult{unit=COUNT, value=1}, addedDataFiles=CounterResult{unit=COUNT, value=2}, removedDataFiles=null, totalDataFiles=CounterResult{unit=COUNT, value=283}, addedDeleteFiles=null, addedEqualityDeleteFiles=null, addedPositionalDeleteFiles=null, addedDVs=null, removedDeleteFiles=null, removedEqualityDeleteFiles=null, removedPositionalDeleteFiles=null, removedDVs=null, totalDeleteFiles=CounterResult{unit=COUNT, value=0}, addedRecords=CounterResult{unit=COUNT, value=8}, removedRecords=null, totalRecords=CounterResult{unit=COUNT, value=1879575}, addedFilesSizeInBytes=CounterResult{unit=BYTES, value=22558}, removedFilesSizeInBytes=null, totalFilesSizeInBytes=CounterResult{unit=
 BYTES, value=75751857}, addedPositionalDeletes=null, removedPositionalDeletes=null, totalPositionalDeletes=CounterResult{unit=COUNT, value=0}, addedEqualityDeletes=null, removedEqualityDeletes=null, totalEqualityDeletes=CounterResult{unit=COUNT, value=0}, manifestsCreated=null, manifestsReplaced=null, manifestsKept=null, manifestEntriesProcessed=null}, metadata={iceberg-version=Apache Iceberg 1.9.2 (commit 071d5606bc6199a0be9b3f274ec7fbf111d88821)}} (org.apache.iceberg.metrics.LoggingMetricsReporter:38)
   + [2025-09-04 14:57:36,174] INFO Commit complete to table raw.t440_bal_head, snapshot 2368336716243636983, commit ID f7a3a2b1-ecf3-4e10-ace3-178d0d1ddda8, valid-through null (org.apache.iceberg.connect.channel.Coordinator:266)
   
   [2025-09-04 14:57:55,935] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Disconnecting from node 4 due to socket connection setup timeout. The timeout value is 8448 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 14:58:01,885] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 14:58:35,751] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1320 due to node 3 being disconnected (elapsed time since creation: 60233ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:58:35,751] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:58:35,751] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1321 due to node 2 being disconnected (elapsed time since creation: 60240ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1324 due to node 4 being disconnected (elapsed time since creation: 60240ms, elapsed time since send: 60003ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1323 due to node 5 being disconnected (elapsed time since creation: 60240ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 1351 due to node 2 being disconnected (elapsed time since creation: 135ms, elapsed time since send: 135ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:58:35,758] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:58:58,405] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node -1 due to socket connection setup timeout. The timeout value is 10448 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 14:58:59,873] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-1] Node 5 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 14:59:11,005] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Disconnecting from node 0 due to socket connection setup timeout. The timeout value is 8508 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 14:59:23,409] WARN [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   [2025-09-04 14:59:35,863] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:59:35,864] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1352 due to node 3 being disconnected (elapsed time since creation: 60014ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:59:35,864] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1353 due to node 2 being disconnected (elapsed time since creation: 60024ms, elapsed time since send: 60004ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1355 due to node 4 being disconnected (elapsed time since creation: 60024ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 1383 due to node 4 being disconnected (elapsed time since creation: 9ms, elapsed time since send: 9ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:59:35,874] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 14:59:35,877] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1354 due to node 5 being disconnected (elapsed time since creation: 60028ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 14:59:35,877] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 14:59:35,877] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:00:00,766] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Disconnecting from node 1 due to socket connection setup timeout. The timeout value is 8989 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:00:36,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1380 due to node 0 being disconnected (elapsed time since creation: 61523ms, elapsed time since send: 61523ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1382 due to node 1 being disconnected (elapsed time since creation: 60675ms, elapsed time since send: 60675ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 1384 due to node 0 being disconnected (elapsed time since creation: 60234ms, elapsed time since send: 60234ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 0 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:00:36,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:00:36,199] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1386 due to node 2 being disconnected (elapsed time since creation: 60231ms, elapsed time since send: 60209ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1385 due to node 3 being disconnected (elapsed time since creation: 60231ms, elapsed time since send: 60217ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1388 due to node 4 being disconnected (elapsed time since creation: 60231ms, elapsed time since send: 60212ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1387 due to node 5 being disconnected (elapsed time since creation: 60231ms, elapsed time since send: 60214ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:00:36,200] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=720862586, epoch=45) to node 0: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:00:36,204] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=2264982, epoch=3) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:00:36,205] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:00:36,205] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:00:36,205] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:00:36,205] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   
   + TASK RESTARTS HERE
   
   [2025-09-04 15:00:41,749] INFO [table-small-12-sink-iceberg|task-0] Creating task table-small-12-sink-iceberg-0 intial state STARTED (org.apache.kafka.connect.runtime.Worker:816)
   [2025-09-04 15:00:41,756] INFO [table-small-12-sink-iceberg|task-0] ConnectorConfig values:
   [2025-09-04 15:00:41,757] INFO [table-small-12-sink-iceberg|task-0] EnrichedConnectorConfig values:
   [2025-09-04 15:00:41,757] INFO [table-small-12-sink-iceberg|task-0] Instantiated task table-small-12-sink-iceberg-0 with version 1.9.2 of type org.apache.iceberg.connect.IcebergSinkTask (org.apache.kafka.connect.runtime.Worker:837)
   [2025-09-04 15:00:41,757] INFO [table-small-12-sink-iceberg|task-0] TaskConfig values:
   [2025-09-04 15:00:41,758] INFO [table-small-12-sink-iceberg|task-0] AvroConverterConfig values:
   [2025-09-04 15:00:41,759] INFO [table-small-12-sink-iceberg|task-0] KafkaAvroSerializerConfig values:
   [2025-09-04 15:00:41,762] INFO [table-small-12-sink-iceberg|task-0] KafkaAvroDeserializerConfig values:
   [2025-09-04 15:00:41,766] INFO [table-small-12-sink-iceberg|task-0] AvroConverterConfig values:
   [2025-09-04 15:00:41,766] INFO [table-small-12-sink-iceberg|task-0] AvroDataConfig values:
   [2025-09-04 15:00:41,767] INFO [table-small-12-sink-iceberg|task-0] KafkaAvroSerializerConfig values:
   [2025-09-04 15:00:41,772] INFO [table-small-12-sink-iceberg|task-0] KafkaAvroDeserializerConfig values:
   [2025-09-04 15:00:41,826] INFO [table-small-12-sink-iceberg|task-0] AvroDataConfig values:
   [2025-09-04 15:00:41,827] INFO [table-small-12-sink-iceberg|task-0] Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task table-small-12-sink-iceberg-0 using the worker config (org.apache.kafka.connect.runtime.Worker:867)
   [2025-09-04 15:00:41,827] INFO [table-small-12-sink-iceberg|task-0] Set up the key converter class io.confluent.connect.avro.AvroConverter for task table-small-12-sink-iceberg-0 using the connector config (org.apache.kafka.connect.runtime.Worker:855)
   [2025-09-04 15:00:41,827] INFO [table-small-12-sink-iceberg|task-0] Set up the value converter class io.confluent.connect.avro.AvroConverter for task table-small-12-sink-iceberg-0 using the connector config (org.apache.kafka.connect.runtime.Worker:861)
   [2025-09-04 15:00:41,828] INFO [table-small-12-sink-iceberg|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{com.confluent.kafka.connect.transforms.TimestampConverter$Value, com.confluent.kafka.connect.transforms.TimestampConverter$Value, com.confluent.kafka.connect.transforms.AddMetadata, com.confluent.kafka.connect.transforms.CopyField, com.confluent.kafka.connect.transforms.CopyField, com.confluent.kafka.connect.transforms.MD5Calculator, com.confluent.kafka.connect.transforms.IngestedAtField} (org.apache.kafka.connect.runtime.Worker:2142)
   [2025-09-04 15:00:41,829] INFO [table-small-12-sink-iceberg|task-0] EnrichedConnectorConfig values:
   [2025-09-04 15:00:41,829] INFO [table-small-12-sink-iceberg|task-0] SinkConnectorConfig values:
   [2025-09-04 15:00:41,830] INFO [table-small-12-sink-iceberg|task-0] ConsumerConfig values:
   [2025-09-04 15:00:41,830] INFO [table-small-12-sink-iceberg|task-0] Initializing: org.apache.kafka.connect.runtime.TransformationChain{com.confluent.kafka.connect.transforms.TimestampConverter$Value, com.confluent.kafka.connect.transforms.TimestampConverter$Value, com.confluent.kafka.connect.transforms.AddMetadata, com.confluent.kafka.connect.transforms.CopyField, com.confluent.kafka.connect.transforms.CopyField, com.confluent.kafka.connect.transforms.MD5Calculator, com.confluent.kafka.connect.transforms.IngestedAtField} (org.apache.kafka.connect.runtime.Worker:2204)
   [2025-09-04 15:00:41,830] INFO [table-small-12-sink-iceberg|task-0] TracerConfig values:
   [2025-09-04 15:00:41,831] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:00:41,833] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:00:41,833] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998041833 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:00:41,833] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:00:41,833] INFO [table-small-12-sink-iceberg|task-0] These configurations '[metrics.context.resource.connector, metrics.context.resource.version, metrics.context.resource.type, metrics.context.resource.commit.id, metrics.context.resource.task, metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:00:41,838] INFO [table-small-12-sink-iceberg|task-0] AdminClientConfig values:
   [2025-09-04 15:00:41,838] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:00:41,840] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:00:41,840] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998041840 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:00:41,840] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:00:41,840] INFO [table-small-12-sink-iceberg|task-0] These configurations '[metrics.context.resource.connector, metrics.context.resource.version, listeners.https.ssl.truststore.password, group.id, metrics.context.resource.type, metrics.context.resource.commit.id, rest.advertised.port, plugin.path, metrics.context.resource.task, rest.extension.classes, confluent.license, listeners.https.ssl.key.password, metrics.context.connect.kafka.cluster.id, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, offset.storage.topic, rest.advertised.listener, value.converter, session.timeout.ms, key.converter, listeners.https.ssl.enabled.protocols, expose.internal.connect.endpoints, config.storage.topic, listeners, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, heartbeat.interval.ms, listeners.https.ssl.keystore.password, config.storage.rep
 lication.factor, topic.creation.enable, offset.flush.interval.ms, key.converter.schemas.enable, listeners.https.ssl.truststore.location, value.converter.schemas.enable, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:00:41,963] INFO [table-small-12-sink-iceberg|task-0] ProducerConfig values:
   [2025-09-04 15:00:41,965] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:00:41,967] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Subscribed to topic(s): topic_t175_kred_carriers, topic_t177_dblogin, topic_t182_ctw_ <prefix>, topic_t183_splace_gate, topic_t184_sic_opendocs, topic_t186_new_ean, topic_t189_carriers, topic_t230_inv_repheader, topic_t231_inv_repdetail, topic_t239_storage, topic_t240_hazard, topic_t241_ph_value, topic_t255_ars16audit, topic_t300_bookingperiod, topic_t306_spcondsubtype, topic_t307_specialcondit, topic_t370_bo_input_lct, topic_t390_sapintfacetyp, topic_t404_mde_suppliers, topic_t417_order_stock_factors, topic_t419_open_store_restrictions, topic_t427_holiday_rules, topic_t440_bal_head, topic_t441_bal_det, topic_t443_efis_list, topic_t480_tour_picklists, topic_t481_hauliers, topic_t483_rest_palettes, topic_t484_tour_comments, topic_t485_timefactors (org.apache.kafka.clients.consumer.internals.ClassicKafka
 Consumer:502)
   [2025-09-04 15:00:41,967] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:00:41,967] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998041967 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:00:41,967] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:00:41,967] INFO [table-small-12-sink-iceberg|task-0] These configurations '[metrics.context.resource.connector, metrics.context.resource.version, metrics.context.connect.group.id, metrics.context.resource.type, metrics.context.resource.commit.id, metrics.context.resource.task, metrics.context.connect.kafka.cluster.id]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:00:41,968] INFO [table-small-12-sink-iceberg|task-0] IcebergSinkConfig values:
   [2025-09-04 15:00:41,968] INFO [table-small-12-sink-iceberg|task-0] JsonConverterConfig values:
   [2025-09-04 15:00:41,968] INFO [table-small-12-sink-iceberg|task-0] WorkerSinkTask{id=table-small-12-sink-iceberg-0} Executing sink task (org.apache.kafka.connect.runtime.WorkerSinkTask:234)
   [2025-09-04 15:00:41,968] INFO [table-small-12-sink-iceberg|task-0] WorkerSinkTask{id=table-small-12-sink-iceberg-0} Sink task finished initialization and start, task thread is 2567 (org.apache.kafka.connect.runtime.WorkerSinkTask:350)
   [2025-09-04 15:00:42,036] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cluster ID: <cluster> (org.apache.kafka.clients.Metadata:366)
   [2025-09-04 15:00:42,036] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Discovered group coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 15:00:42,037] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:00:42,050] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Cluster ID: <cluster> (org.apache.kafka.clients.Metadata:366)
   [2025-09-04 15:00:42,063] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:00:42,063] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: need to re-join with the given member-id: connector-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:00:47,662] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: group is already rebalancing (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:00:59,267] INFO [table-small-12-sink-iceberg|task-1] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:00:59,267] INFO [table-small-12-sink-iceberg|task-1] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:00:59,303] INFO [table-small-12-sink-iceberg|task-1] Sending event of type: DATA_COMPLETE (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:00:59,354] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: group is already rebalancing (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:00:59,371] INFO [table-small-12-sink-iceberg|task-1] Handled event of type: START_COMMIT (org.apache.iceberg.connect.channel.Channel:133)
   [2025-09-04 15:00:59,372] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Revoke previously assigned partitions topic_t175_kred_carriers-0, topic_t175_kred_carriers-1, topic_t175_kred_carriers-2, topic_t175_kred_carriers-3, topic_t177_dblogin-0, topic_t177_dblogin-1, topic_t177_dblogin-2, topic_t177_dblogin-3, topic_t182_ctw_ <prefix>-0, topic_t182_ctw_ <prefix>-1, topic_t182_ctw_ <prefix>-2, topic_t182_ctw_ <prefix>-3, topic_t183_splace_gate-0, topic_t183_splace_gate-1, topic_t183_splace_gate-2, topic_t183_splace_gate-3, topic_t184_sic_opendocs-0, topic_t184_sic_opendocs-1, topic_t184_sic_opendocs-2, topic_t184_sic_opendocs-3, topic_t186_new_ean-0, topic_t186_new_ean-1, topic_t186_new_ean-2, topic_t186_new_ean-3, topic_t189_carriers-0, topic_t189_carriers-1, topic_t189_carriers-2, topic_t189_carriers-3, topic_t230_inv_repheader-0, topic_t230_inv_repheader-1, topic_t230_inv_
 repheader-2, topic_t230_inv_repheader-3, topic_t231_inv_repdetail-0, topic_t231_inv_repdetail-1, topic_t231_inv_repdetail-2, topic_t231_inv_repdetail-3, topic_t239_storage-0, topic_t239_storage-1, topic_t239_storage-2, topic_t239_storage-3, topic_t240_hazard-0, topic_t240_hazard-1, topic_t240_hazard-2, topic_t240_hazard-3, topic_t241_ph_value-0, topic_t241_ph_value-1, topic_t241_ph_value-2, topic_t241_ph_value-3, topic_t255_ars16audit-0, topic_t255_ars16audit-1, topic_t255_ars16audit-2, topic_t255_ars16audit-3, topic_t300_bookingperiod-0, topic_t300_bookingperiod-1, topic_t300_bookingperiod-2, topic_t300_bookingperiod-3, topic_t306_spcondsubtype-0, topic_t306_spcondsubtype-1, topic_t306_spcondsubtype-2, topic_t306_spcondsubtype-3, topic_t307_specialcondit-0, topic_t307_specialcondit-1, topic_t307_specialcondit-2, topic_t307_specialcondit-3, topic_t370_bo_input_lct-0, topic_t370_bo_input_lct-1, topic_t370_bo_input_lct-2, topic_t370_bo_input_lct-3, topic_t390_sapintfacetyp-0, topic_t3
 90_sapintfacetyp-1, topic_t390_sapintfacetyp-2, topic_t390_sapintfacetyp-3, topic_t404_mde_suppliers-0, topic_t404_mde_suppliers-1, topic_t404_mde_suppliers-2, topic_t404_mde_suppliers-3, topic_t417_order_stock_factors-0, topic_t417_order_stock_factors-1, topic_t417_order_stock_factors-2, topic_t417_order_stock_factors-3, topic_t419_open_store_restrictions-0, topic_t419_open_store_restrictions-1, topic_t419_open_store_restrictions-2, topic_t419_open_store_restrictions-3, topic_t427_holiday_rules-0, topic_t427_holiday_rules-1, topic_t427_holiday_rules-2, topic_t427_holiday_rules-3, topic_t440_bal_head-0, topic_t440_bal_head-1, topic_t440_bal_head-2, topic_t440_bal_head-3, topic_t441_bal_det-0, topic_t441_bal_det-1, topic_t441_bal_det-2, topic_t441_bal_det-3, topic_t443_efis_list-0, topic_t443_efis_list-1, topic_t443_efis_list-2, topic_t443_efis_list-3, topic_t480_tour_picklists-0, topic_t480_tour_picklists-1, topic_t480_tour_picklists-2, topic_t480_tour_picklists-3, topic_t480_tour_p
 icklists-4, topic_t480_tour_picklists-5, topic_t480_tour_picklists-6, topic_t480_tour_picklists-7, topic_t481_hauliers-0, topic_t481_hauliers-1, topic_t481_hauliers-2, topic_t481_hauliers-3, topic_t483_rest_palettes-0, topic_t483_rest_palettes-1, topic_t483_rest_palettes-2, topic_t483_rest_palettes-3, topic_t484_tour_comments-0, topic_t484_tour_comments-1, topic_t484_tour_comments-2, topic_t484_tour_comments-3, topic_t485_timefactors-0, topic_t485_timefactors-1, topic_t485_timefactors-2, topic_t485_timefactors-3 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:80)
   [2025-09-04 15:00:59,372] INFO [table-small-12-sink-iceberg|task-1] [Producer clientId=1e74e71a-4a8e-4714-b0c8-9d9510aa5554, transactionalId=worker-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1368)
   [2025-09-04 15:00:59,372] INFO [table-small-12-sink-iceberg|task-1] Channel stopping (org.apache.iceberg.connect.channel.Channel:162)
   [2025-09-04 15:00:59,378] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=7927bb5f-004e-4561-822d-da6f73d9c5ca, groupId=cg-control-1b067dc2-ea92-42f9-bd0f-17ce9c356945] Member 7927bb5f-004e-4561-822d-da6f73d9c5ca-51faca81-3329-443a-ab2a-c683626384de sending LeaveGroup request to coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483645 rack: null isFenced: false) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1174)
   [2025-09-04 15:00:59,378] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=7927bb5f-004e-4561-822d-da6f73d9c5ca, groupId=cg-control-1b067dc2-ea92-42f9-bd0f-17ce9c356945] Revoke previously assigned partitions  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:80)
   [2025-09-04 15:00:59,378] INFO [table-small-12-sink-iceberg|task-1] App info kafka.producer for 1e74e71a-4a8e-4714-b0c8-9d9510aa5554 unregistered (org.apache.kafka.common.utils.AppInfoParser:95)
   [2025-09-04 15:00:59,379] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=7927bb5f-004e-4561-822d-da6f73d9c5ca, groupId=cg-control-1b067dc2-ea92-42f9-bd0f-17ce9c356945] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:00:59,379] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=7927bb5f-004e-4561-822d-da6f73d9c5ca, groupId=cg-control-1b067dc2-ea92-42f9-bd0f-17ce9c356945] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1056)
   [2025-09-04 15:00:59,388] INFO [table-small-12-sink-iceberg|task-1] App info kafka.consumer for 7927bb5f-004e-4561-822d-da6f73d9c5ca unregistered (org.apache.kafka.common.utils.AppInfoParser:95)
   [2025-09-04 15:00:59,475] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:00:59,479] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Successfully joined group with generation Generation{generationId=483, memberId='connector-consumer-table-small-12-sink-iceberg-1-44f4b0fb-21d8-466d-9702-1317a49ecfca', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:01:08,821] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Successfully joined group with generation Generation{generationId=483, memberId='connector-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:01:10,925] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Revoke previously assigned partitions  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:80)
   [2025-09-04 15:01:10,926] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Member 54adfc40-66fd-4773-9dd9-7899b4fa28d1-6e308fd6-be02-4a17-bad1-68591a67292f sending LeaveGroup request to coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483647 rack: null isFenced: false) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1174)
   [2025-09-04 15:01:10,932] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Request joining group due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:10,932] INFO [Consumer clientId=54adfc40-66fd-4773-9dd9-7899b4fa28d1, groupId=connect-table-small-12-sink-iceberg-coord] Resetting generation and member id due to: consumer pro-actively leaving the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1056)
   [2025-09-04 15:01:15,740] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 0 due to socket connection setup timeout. The timeout value is 30000 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:15,740] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to socket connection setup timeout. The timeout value is 24030 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:15,740] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to socket connection setup timeout. The timeout value is 24395 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:28,238] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to socket connection setup timeout. The timeout value is 25569 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:28,241] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node -1 due to socket connection setup timeout. The timeout value is 19824 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:28,241] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to socket connection setup timeout. The timeout value is 30000 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:28,241] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to socket connection setup timeout. The timeout value is 30000 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:01:28,241] WARN [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   [2025-09-04 15:01:28,244] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1432530602, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:28,244] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1799704029, epoch=INITIAL) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:28,244] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1849102486, epoch=INITIAL) to node 0: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:28,245] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1937322821, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:28,245] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:28,246] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:28,249] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=7a6ff60d-921d-4c34-aaf5-db36b0d84ae6, groupId=cg-control-4c0a0f91-e567-44ba-a37a-db5e33bd4f15] Cancelled in-flight METADATA request with correlation id 503 due to node 3 being disconnected (elapsed time since creation: 1ms, elapsed time since send: 1ms, throttle time: 0ms, request timeout: 20000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:28,249] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=7a6ff60d-921d-4c34-aaf5-db36b0d84ae6, groupId=cg-control-4c0a0f91-e567-44ba-a37a-db5e33bd4f15] Node 3 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 15:01:40,757] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node -1 due to client rebootstrap. (org.apache.kafka.clients.NetworkClient:1242)
   [2025-09-04 15:01:40,757] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Rebootstrapping with [<cluster>.azure.confluent.cloud/10.1.0.29:9092] (org.apache.kafka.clients.Metadata:315)
   [2025-09-04 15:01:40,757] WARN [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   [2025-09-04 15:01:44,645] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1404 due to node 1 being disconnected (elapsed time since creation: 68335ms, elapsed time since send: 68277ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:44,645] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:01:44,659] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1402 due to node 2 being disconnected (elapsed time since creation: 68335ms, elapsed time since send: 68276ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:44,659] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1401 due to node 3 being disconnected (elapsed time since creation: 68335ms, elapsed time since send: 68281ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:44,659] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 1409 due to node 3 being disconnected (elapsed time since creation: 68280ms, elapsed time since send: 68280ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:44,659] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:01:44,659] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1406 due to node 4 being disconnected (elapsed time since creation: 68335ms, elapsed time since send: 68276ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1405 due to node 5 being disconnected (elapsed time since creation: 68335ms, elapsed time since send: 68256ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=2264982, epoch=INITIAL) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:44,660] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:01:56,051] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] SyncGroup failed: The group began another rebalance. Need to re-join the group. Sent generation was Generation{generationId=483, memberId='connector-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:867)
   [2025-09-04 15:01:56,052] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Group coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) is unavailable or invalid due to cause: session timed out without receiving a heartbeat response. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)
   [2025-09-04 15:01:56,052] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Requesting disconnect from last known coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1013)
   [2025-09-04 15:01:56,058] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Finished assignment for group at generation 483: {connector-consumer-table-small-12-sink-iceberg-1-44f4b0fb-21d8-466d-9702-1317a49ecfca=Assignment(partitions=[topic_t175_kred_carriers-1, topic_t175_kred_carriers-3, topic_t177_dblogin-1, topic_t177_dblogin-3, topic_t182_ctw_ <prefix>-1, topic_t182_ctw_ <prefix>-3, topic_t183_splace_gate-1, topic_t183_splace_gate-3, topic_t184_sic_opendocs-1, topic_t184_sic_opendocs-3, topic_t186_new_ean-1, topic_t186_new_ean-3, topic_t189_carriers-1, topic_t189_carriers-3, topic_t230_inv_repheader-1, topic_t230_inv_repheader-3, topic_t231_inv_repdetail-1, topic_t231_inv_repdetail-3, topic_t239_storage-1, topic_t239_storage-3, topic_t240_hazard-1, topic_t240_hazard-3, topic_t241_ph_value-1, topic_t241_ph_value-3, topic_t255_ars16audit-1, topic_t255_ars16audit-3, topic_t3
 00_bookingperiod-1, topic_t300_bookingperiod-3, topic_t306_spcondsubtype-1, topic_t306_spcondsubtype-3, topic_t307_specialcondit-1, topic_t307_specialcondit-3, topic_t370_bo_input_lct-1, topic_t370_bo_input_lct-3, topic_t390_sapintfacetyp-1, topic_t390_sapintfacetyp-3, topic_t404_mde_suppliers-1, topic_t404_mde_suppliers-3, topic_t417_order_stock_factors-1, topic_t417_order_stock_factors-3, topic_t419_open_store_restrictions-1, topic_t419_open_store_restrictions-3, topic_t427_holiday_rules-1, topic_t427_holiday_rules-3, topic_t440_bal_head-1, topic_t440_bal_head-3, topic_t441_bal_det-1, topic_t441_bal_det-3, topic_t443_efis_list-1, topic_t443_efis_list-3, topic_t480_tour_picklists-1, topic_t480_tour_picklists-3, topic_t480_tour_picklists-5, topic_t480_tour_picklists-7, topic_t481_hauliers-1, topic_t481_hauliers-3, topic_t483_rest_palettes-1, topic_t483_rest_palettes-3, topic_t484_tour_comments-1, topic_t484_tour_comments-3, topic_t485_timefactors-1, topic_t485_timefactors-3]), conne
 ctor-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9=Assignment(partitions=[topic_t175_kred_carriers-0, topic_t175_kred_carriers-2, topic_t177_dblogin-0, topic_t177_dblogin-2, topic_t182_ctw_ <prefix>-0, topic_t182_ctw_ <prefix>-2, topic_t183_splace_gate-0, topic_t183_splace_gate-2, topic_t184_sic_opendocs-0, topic_t184_sic_opendocs-2, topic_t186_new_ean-0, topic_t186_new_ean-2, topic_t189_carriers-0, topic_t189_carriers-2, topic_t230_inv_repheader-0, topic_t230_inv_repheader-2, topic_t231_inv_repdetail-0, topic_t231_inv_repdetail-2, topic_t239_storage-0, topic_t239_storage-2, topic_t240_hazard-0, topic_t240_hazard-2, topic_t241_ph_value-0, topic_t241_ph_value-2, topic_t255_ars16audit-0, topic_t255_ars16audit-2, topic_t300_bookingperiod-0, topic_t300_bookingperiod-2, topic_t306_spcondsubtype-0, topic_t306_spcondsubtype-2, topic_t307_specialcondit-0, topic_t307_specialcondit-2, topic_t370_bo_input_lct-0, topic_t370_bo_input_lct-2, topic_t390_sapintfacetyp-
 0, topic_t390_sapintfacetyp-2, topic_t404_mde_suppliers-0, topic_t404_mde_suppliers-2, topic_t417_order_stock_factors-0, topic_t417_order_stock_factors-2, topic_t419_open_store_restrictions-0, topic_t419_open_store_restrictions-2, topic_t427_holiday_rules-0, topic_t427_holiday_rules-2, topic_t440_bal_head-0, topic_t440_bal_head-2, topic_t441_bal_det-0, topic_t441_bal_det-2, topic_t443_efis_list-0, topic_t443_efis_list-2, topic_t480_tour_picklists-0, topic_t480_tour_picklists-2, topic_t480_tour_picklists-4, topic_t480_tour_picklists-6, topic_t481_hauliers-0, topic_t481_hauliers-2, topic_t483_rest_palettes-0, topic_t483_rest_palettes-2, topic_t484_tour_comments-0, topic_t484_tour_comments-2, topic_t485_timefactors-0, topic_t485_timefactors-2])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:664)
   [2025-09-04 15:01:56,060] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: encountered UNKNOWN_MEMBER_ID from SYNC_GROUP response (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:56,060] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: rebalance failed due to 'The coordinator is not aware of this member.' (UnknownMemberIdException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:56,060] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Resetting generation and member id due to: encountered UNKNOWN_MEMBER_ID from SYNC_GROUP response (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1056)
   [2025-09-04 15:01:56,060] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] SyncGroup failed: The coordinator is not aware of this member. Need to re-join the group. Sent generation was Generation{generationId=483, memberId='connector-consumer-table-small-12-sink-iceberg-1-44f4b0fb-21d8-466d-9702-1317a49ecfca', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:878)
   [2025-09-04 15:01:56,061] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Client requested disconnect from node 2147483643 (org.apache.kafka.clients.NetworkClient:460)
   [2025-09-04 15:01:56,061] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:56,062] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight HEARTBEAT request with correlation id 10 due to node 2147483643 being disconnected (elapsed time since creation: 13695ms, elapsed time since send: 13695ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:56,062] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight HEARTBEAT request with correlation id 7 due to node 2147483643 being disconnected (elapsed time since creation: 34367ms, elapsed time since send: 34367ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:56,062] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight HEARTBEAT request with correlation id 8 due to node 2147483643 being disconnected (elapsed time since creation: 19695ms, elapsed time since send: 19695ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:56,062] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight HEARTBEAT request with correlation id 9 due to node 2147483643 being disconnected (elapsed time since creation: 16695ms, elapsed time since send: 16695ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:01:56,063] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:56,063] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: need to re-join with the given member-id: connector-consumer-table-small-12-sink-iceberg-1-26317796-8cba-4a40-91b0-62bc776e9319 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:56,083] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Discovered group coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 15:01:56,083] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Group coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) is unavailable or invalid due to cause: coordinator unavailable. isDisconnected: false. Rediscovery will be attempted. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1000)
   [2025-09-04 15:01:56,083] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Requesting disconnect from last known coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1013)
   [2025-09-04 15:01:56,177] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Discovered group coordinator <coord>.westeurope.azure.confluent.cloud:9092 (id: 2147483643 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 15:01:56,178] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:56,178] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Request joining group due to: rebalance failed due to 'The group is rebalancing, so a rejoin is needed.' (RebalanceInProgressException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:56,188] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Successfully joined group with generation Generation{generationId=484, memberId='connector-consumer-table-small-12-sink-iceberg-1-26317796-8cba-4a40-91b0-62bc776e9319', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:01:56,193] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Adding newly assigned partitions: topic_t175_kred_carriers-1, topic_t175_kred_carriers-3, topic_t177_dblogin-1, topic_t177_dblogin-3, topic_t182_ctw_ <prefix>-1, topic_t182_ctw_ <prefix>-3, topic_t183_splace_gate-1, topic_t183_splace_gate-3, topic_t184_sic_opendocs-1, topic_t184_sic_opendocs-3, topic_t186_new_ean-1, topic_t186_new_ean-3, topic_t189_carriers-1, topic_t189_carriers-3, topic_t230_inv_repheader-1, topic_t230_inv_repheader-3, topic_t231_inv_repdetail-1, topic_t231_inv_repdetail-3, topic_t239_storage-1, topic_t239_storage-3, topic_t240_hazard-1, topic_t240_hazard-3, topic_t241_ph_value-1, topic_t241_ph_value-3, topic_t255_ars16audit-1, topic_t255_ars16audit-3, topic_t300_bookingperiod-1, topic_t300_bookingperiod-3, topic_t306_spcondsubtype-1, topic_t306_spcondsubtype-3, topic_t307_specialcon
 dit-1, topic_t307_specialcondit-3, topic_t370_bo_input_lct-1, topic_t370_bo_input_lct-3, topic_t390_sapintfacetyp-1, topic_t390_sapintfacetyp-3, topic_t404_mde_suppliers-1, topic_t404_mde_suppliers-3, topic_t417_order_stock_factors-1, topic_t417_order_stock_factors-3, topic_t419_open_store_restrictions-1, topic_t419_open_store_restrictions-3, topic_t427_holiday_rules-1, topic_t427_holiday_rules-3, topic_t440_bal_head-1, topic_t440_bal_head-3, topic_t441_bal_det-1, topic_t441_bal_det-3, topic_t443_efis_list-1, topic_t443_efis_list-3, topic_t480_tour_picklists-1, topic_t480_tour_picklists-3, topic_t480_tour_picklists-5, topic_t480_tour_picklists-7, topic_t481_hauliers-1, topic_t481_hauliers-3, topic_t483_rest_palettes-1, topic_t483_rest_palettes-3, topic_t484_tour_comments-1, topic_t484_tour_comments-3, topic_t485_timefactors-1, topic_t485_timefactors-3 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:58)
   [2025-09-04 15:01:56,193] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Notifying assignor about the new Assignment(partitions=[topic_t175_kred_carriers-1, topic_t175_kred_carriers-3, topic_t177_dblogin-1, topic_t177_dblogin-3, topic_t182_ctw_ <prefix>-1, topic_t182_ctw_ <prefix>-3, topic_t183_splace_gate-1, topic_t183_splace_gate-3, topic_t184_sic_opendocs-1, topic_t184_sic_opendocs-3, topic_t186_new_ean-1, topic_t186_new_ean-3, topic_t189_carriers-1, topic_t189_carriers-3, topic_t230_inv_repheader-1, topic_t230_inv_repheader-3, topic_t231_inv_repdetail-1, topic_t231_inv_repdetail-3, topic_t239_storage-1, topic_t239_storage-3, topic_t240_hazard-1, topic_t240_hazard-3, topic_t241_ph_value-1, topic_t241_ph_value-3, topic_t255_ars16audit-1, topic_t255_ars16audit-3, topic_t300_bookingperiod-1, topic_t300_bookingperiod-3, topic_t306_spcondsubtype-1, topic_t306_spcondsubtype-3,
  topic_t307_specialcondit-1, topic_t307_specialcondit-3, topic_t370_bo_input_lct-1, topic_t370_bo_input_lct-3, topic_t390_sapintfacetyp-1, topic_t390_sapintfacetyp-3, topic_t404_mde_suppliers-1, topic_t404_mde_suppliers-3, topic_t417_order_stock_factors-1, topic_t417_order_stock_factors-3, topic_t419_open_store_restrictions-1, topic_t419_open_store_restrictions-3, topic_t427_holiday_rules-1, topic_t427_holiday_rules-3, topic_t440_bal_head-1, topic_t440_bal_head-3, topic_t441_bal_det-1, topic_t441_bal_det-3, topic_t443_efis_list-1, topic_t443_efis_list-3, topic_t480_tour_picklists-1, topic_t480_tour_picklists-3, topic_t480_tour_picklists-5, topic_t480_tour_picklists-7, topic_t481_hauliers-1, topic_t481_hauliers-3, topic_t483_rest_palettes-1, topic_t483_rest_palettes-3, topic_t484_tour_comments-1, topic_t484_tour_comments-3, topic_t485_timefactors-1, topic_t485_timefactors-3]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:324)
   [2025-09-04 15:01:56,193] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Successfully synced group in generation Generation{generationId=484, memberId='connector-consumer-table-small-12-sink-iceberg-1-26317796-8cba-4a40-91b0-62bc776e9319', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:843)
   [2025-09-04 15:01:56,195] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Finished assignment for group at generation 484: {connector-consumer-table-small-12-sink-iceberg-1-26317796-8cba-4a40-91b0-62bc776e9319=Assignment(partitions=[topic_t175_kred_carriers-1, topic_t175_kred_carriers-3, topic_t177_dblogin-1, topic_t177_dblogin-3, topic_t182_ctw_ <prefix>-1, topic_t182_ctw_ <prefix>-3, topic_t183_splace_gate-1, topic_t183_splace_gate-3, topic_t184_sic_opendocs-1, topic_t184_sic_opendocs-3, topic_t186_new_ean-1, topic_t186_new_ean-3, topic_t189_carriers-1, topic_t189_carriers-3, topic_t230_inv_repheader-1, topic_t230_inv_repheader-3, topic_t231_inv_repdetail-1, topic_t231_inv_repdetail-3, topic_t239_storage-1, topic_t239_storage-3, topic_t240_hazard-1, topic_t240_hazard-3, topic_t241_ph_value-1, topic_t241_ph_value-3, topic_t255_ars16audit-1, topic_t255_ars16audit-3, topic_t3
 00_bookingperiod-1, topic_t300_bookingperiod-3, topic_t306_spcondsubtype-1, topic_t306_spcondsubtype-3, topic_t307_specialcondit-1, topic_t307_specialcondit-3, topic_t370_bo_input_lct-1, topic_t370_bo_input_lct-3, topic_t390_sapintfacetyp-1, topic_t390_sapintfacetyp-3, topic_t404_mde_suppliers-1, topic_t404_mde_suppliers-3, topic_t417_order_stock_factors-1, topic_t417_order_stock_factors-3, topic_t419_open_store_restrictions-1, topic_t419_open_store_restrictions-3, topic_t427_holiday_rules-1, topic_t427_holiday_rules-3, topic_t440_bal_head-1, topic_t440_bal_head-3, topic_t441_bal_det-1, topic_t441_bal_det-3, topic_t443_efis_list-1, topic_t443_efis_list-3, topic_t480_tour_picklists-1, topic_t480_tour_picklists-3, topic_t480_tour_picklists-5, topic_t480_tour_picklists-7, topic_t481_hauliers-1, topic_t481_hauliers-3, topic_t483_rest_palettes-1, topic_t483_rest_palettes-3, topic_t484_tour_comments-1, topic_t484_tour_comments-3, topic_t485_timefactors-1, topic_t485_timefactors-3]), conne
 ctor-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9=Assignment(partitions=[topic_t175_kred_carriers-0, topic_t175_kred_carriers-2, topic_t177_dblogin-0, topic_t177_dblogin-2, topic_t182_ctw_ <prefix>-0, topic_t182_ctw_ <prefix>-2, topic_t183_splace_gate-0, topic_t183_splace_gate-2, topic_t184_sic_opendocs-0, topic_t184_sic_opendocs-2, topic_t186_new_ean-0, topic_t186_new_ean-2, topic_t189_carriers-0, topic_t189_carriers-2, topic_t230_inv_repheader-0, topic_t230_inv_repheader-2, topic_t231_inv_repdetail-0, topic_t231_inv_repdetail-2, topic_t239_storage-0, topic_t239_storage-2, topic_t240_hazard-0, topic_t240_hazard-2, topic_t241_ph_value-0, topic_t241_ph_value-2, topic_t255_ars16audit-0, topic_t255_ars16audit-2, topic_t300_bookingperiod-0, topic_t300_bookingperiod-2, topic_t306_spcondsubtype-0, topic_t306_spcondsubtype-2, topic_t307_specialcondit-0, topic_t307_specialcondit-2, topic_t370_bo_input_lct-0, topic_t370_bo_input_lct-2, topic_t390_sapintfacetyp-
 0, topic_t390_sapintfacetyp-2, topic_t404_mde_suppliers-0, topic_t404_mde_suppliers-2, topic_t417_order_stock_factors-0, topic_t417_order_stock_factors-2, topic_t419_open_store_restrictions-0, topic_t419_open_store_restrictions-2, topic_t427_holiday_rules-0, topic_t427_holiday_rules-2, topic_t440_bal_head-0, topic_t440_bal_head-2, topic_t441_bal_det-0, topic_t441_bal_det-2, topic_t443_efis_list-0, topic_t443_efis_list-2, topic_t480_tour_picklists-0, topic_t480_tour_picklists-2, topic_t480_tour_picklists-4, topic_t480_tour_picklists-6, topic_t481_hauliers-0, topic_t481_hauliers-2, topic_t483_rest_palettes-0, topic_t483_rest_palettes-2, topic_t484_tour_comments-0, topic_t484_tour_comments-2, topic_t485_timefactors-0, topic_t485_timefactors-2])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:664)
   [2025-09-04 15:01:56,195] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Successfully joined group with generation Generation{generationId=484, memberId='connector-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t241_ph_value-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t390_sapintfacetyp-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t255_ars16audit-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t307_specialcondit-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t404_mde_suppliers-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t239_storage-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t485_timefactors-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t186_new_ean-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t481_hauliers-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t370_bo_input_lct-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t484_tour_comments-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t427_holiday_rules-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,197] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t419_open_store_restrictions-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t240_hazard-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t306_spcondsubtype-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t241_ph_value-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t255_ars16audit-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t307_specialcondit-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t404_mde_suppliers-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t390_sapintfacetyp-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t186_new_ean-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t370_bo_input_lct-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t239_storage-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t485_timefactors-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t484_tour_comments-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t481_hauliers-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t240_hazard-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t306_spcondsubtype-1 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t427_holiday_rules-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t419_open_store_restrictions-3 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t175_kred_carriers-1 to the committed offset FetchPosition{offset=208248, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=27}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t175_kred_carriers-3 to the committed offset FetchPosition{offset=275699, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 0 rack: 0 isFenced: false)], epoch=62}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t177_dblogin-1 to the committed offset FetchPosition{offset=11, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=29}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t177_dblogin-3 to the committed offset FetchPosition{offset=6, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t182_ctw_ <prefix>-1 to the committed offset FetchPosition{offset=98439, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=29}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t182_ctw_ <prefix>-3 to the committed offset FetchPosition{offset=97242, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=67}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t183_splace_gate-1 to the committed offset FetchPosition{offset=105, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=34}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t183_splace_gate-3 to the committed offset FetchPosition{offset=203, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=32}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t184_sic_opendocs-1 to the committed offset FetchPosition{offset=1, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t184_sic_opendocs-3 to the committed offset FetchPosition{offset=6, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t189_carriers-1 to the committed offset FetchPosition{offset=3066, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=29}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t189_carriers-3 to the committed offset FetchPosition{offset=3090, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t230_inv_repheader-1 to the committed offset FetchPosition{offset=32, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t230_inv_repheader-3 to the committed offset FetchPosition{offset=30, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t231_inv_repdetail-1 to the committed offset FetchPosition{offset=347168, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=32}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t231_inv_repdetail-3 to the committed offset FetchPosition{offset=347841, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=32}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t300_bookingperiod-1 to the committed offset FetchPosition{offset=149, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 0 rack: 0 isFenced: false)], epoch=33}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t300_bookingperiod-3 to the committed offset FetchPosition{offset=82, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=31}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t417_order_stock_factors-1 to the committed offset FetchPosition{offset=74, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=34}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t417_order_stock_factors-3 to the committed offset FetchPosition{offset=79, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=29}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t440_bal_head-1 to the committed offset FetchPosition{offset=39688, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=33}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t440_bal_head-3 to the committed offset FetchPosition{offset=39611, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=31}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t441_bal_det-1 to the committed offset FetchPosition{offset=112713, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t441_bal_det-3 to the committed offset FetchPosition{offset=111453, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t443_efis_list-1 to the committed offset FetchPosition{offset=8720, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=31}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t443_efis_list-3 to the committed offset FetchPosition{offset=13640, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=29}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t480_tour_picklists-1 to the committed offset FetchPosition{offset=37768, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t480_tour_picklists-3 to the committed offset FetchPosition{offset=37938, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t480_tour_picklists-5 to the committed offset FetchPosition{offset=37597, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t480_tour_picklists-7 to the committed offset FetchPosition{offset=37860, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t483_rest_palettes-1 to the committed offset FetchPosition{offset=180, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=29}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,198] INFO [table-small-12-sink-iceberg|task-1] Setting offset for partition topic_t483_rest_palettes-3 to the committed offset FetchPosition{offset=161, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=32}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,199] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Successfully synced group in generation Generation{generationId=484, memberId='connector-consumer-table-small-12-sink-iceberg-0-48516cb7-2505-41e9-87c5-a517b0788cc9', protocol='roundrobin'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:843)
   [2025-09-04 15:01:56,200] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Adding newly assigned partitions: topic_t175_kred_carriers-0, topic_t175_kred_carriers-2, topic_t177_dblogin-0, topic_t177_dblogin-2, topic_t182_ctw_ <prefix>-0, topic_t182_ctw_ <prefix>-2, topic_t183_splace_gate-0, topic_t183_splace_gate-2, topic_t184_sic_opendocs-0, topic_t184_sic_opendocs-2, topic_t186_new_ean-0, topic_t186_new_ean-2, topic_t189_carriers-0, topic_t189_carriers-2, topic_t230_inv_repheader-0, topic_t230_inv_repheader-2, topic_t231_inv_repdetail-0, topic_t231_inv_repdetail-2, topic_t239_storage-0, topic_t239_storage-2, topic_t240_hazard-0, topic_t240_hazard-2, topic_t241_ph_value-0, topic_t241_ph_value-2, topic_t255_ars16audit-0, topic_t255_ars16audit-2, topic_t300_bookingperiod-0, topic_t300_bookingperiod-2, topic_t306_spcondsubtype-0, topic_t306_spcondsubtype-2, topic_t307_specialcon
 dit-0, topic_t307_specialcondit-2, topic_t370_bo_input_lct-0, topic_t370_bo_input_lct-2, topic_t390_sapintfacetyp-0, topic_t390_sapintfacetyp-2, topic_t404_mde_suppliers-0, topic_t404_mde_suppliers-2, topic_t417_order_stock_factors-0, topic_t417_order_stock_factors-2, topic_t419_open_store_restrictions-0, topic_t419_open_store_restrictions-2, topic_t427_holiday_rules-0, topic_t427_holiday_rules-2, topic_t440_bal_head-0, topic_t440_bal_head-2, topic_t441_bal_det-0, topic_t441_bal_det-2, topic_t443_efis_list-0, topic_t443_efis_list-2, topic_t480_tour_picklists-0, topic_t480_tour_picklists-2, topic_t480_tour_picklists-4, topic_t480_tour_picklists-6, topic_t481_hauliers-0, topic_t481_hauliers-2, topic_t483_rest_palettes-0, topic_t483_rest_palettes-2, topic_t484_tour_comments-0, topic_t484_tour_comments-2, topic_t485_timefactors-0, topic_t485_timefactors-2 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:58)
   [2025-09-04 15:01:56,200] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Notifying assignor about the new Assignment(partitions=[topic_t175_kred_carriers-0, topic_t175_kred_carriers-2, topic_t177_dblogin-0, topic_t177_dblogin-2, topic_t182_ctw_ <prefix>-0, topic_t182_ctw_ <prefix>-2, topic_t183_splace_gate-0, topic_t183_splace_gate-2, topic_t184_sic_opendocs-0, topic_t184_sic_opendocs-2, topic_t186_new_ean-0, topic_t186_new_ean-2, topic_t189_carriers-0, topic_t189_carriers-2, topic_t230_inv_repheader-0, topic_t230_inv_repheader-2, topic_t231_inv_repdetail-0, topic_t231_inv_repdetail-2, topic_t239_storage-0, topic_t239_storage-2, topic_t240_hazard-0, topic_t240_hazard-2, topic_t241_ph_value-0, topic_t241_ph_value-2, topic_t255_ars16audit-0, topic_t255_ars16audit-2, topic_t300_bookingperiod-0, topic_t300_bookingperiod-2, topic_t306_spcondsubtype-0, topic_t306_spcondsubtype-2,
  topic_t307_specialcondit-0, topic_t307_specialcondit-2, topic_t370_bo_input_lct-0, topic_t370_bo_input_lct-2, topic_t390_sapintfacetyp-0, topic_t390_sapintfacetyp-2, topic_t404_mde_suppliers-0, topic_t404_mde_suppliers-2, topic_t417_order_stock_factors-0, topic_t417_order_stock_factors-2, topic_t419_open_store_restrictions-0, topic_t419_open_store_restrictions-2, topic_t427_holiday_rules-0, topic_t427_holiday_rules-2, topic_t440_bal_head-0, topic_t440_bal_head-2, topic_t441_bal_det-0, topic_t441_bal_det-2, topic_t443_efis_list-0, topic_t443_efis_list-2, topic_t480_tour_picklists-0, topic_t480_tour_picklists-2, topic_t480_tour_picklists-4, topic_t480_tour_picklists-6, topic_t481_hauliers-0, topic_t481_hauliers-2, topic_t483_rest_palettes-0, topic_t483_rest_palettes-2, topic_t484_tour_comments-0, topic_t484_tour_comments-2, topic_t485_timefactors-0, topic_t485_timefactors-2]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:324)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t239_storage-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t485_timefactors-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t186_new_ean-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t481_hauliers-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t370_bo_input_lct-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t484_tour_comments-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t419_open_store_restrictions-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t240_hazard-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t306_spcondsubtype-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t427_holiday_rules-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t241_ph_value-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t255_ars16audit-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t307_specialcondit-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t390_sapintfacetyp-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t186_new_ean-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t239_storage-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t485_timefactors-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t370_bo_input_lct-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t481_hauliers-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t484_tour_comments-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t427_holiday_rules-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t240_hazard-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t306_spcondsubtype-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t419_open_store_restrictions-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,204] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t241_ph_value-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t255_ars16audit-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t307_specialcondit-2 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Found no committed offset for partition topic_t390_sapintfacetyp-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t175_kred_carriers-0 to the committed offset FetchPosition{offset=216866, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t175_kred_carriers-2 to the committed offset FetchPosition{offset=211397, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t177_dblogin-2 to the committed offset FetchPosition{offset=10, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=27}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t182_ctw_ <prefix>-0 to the committed offset FetchPosition{offset=99808, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t183_splace_gate-0 to the committed offset FetchPosition{offset=63, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=33}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t183_splace_gate-2 to the committed offset FetchPosition{offset=65, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=27}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t184_sic_opendocs-0 to the committed offset FetchPosition{offset=9, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 0 rack: 0 isFenced: false)], epoch=66}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t184_sic_opendocs-2 to the committed offset FetchPosition{offset=5, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=27}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t189_carriers-0 to the committed offset FetchPosition{offset=2886, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=32}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t189_carriers-2 to the committed offset FetchPosition{offset=2793, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=27}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t230_inv_repheader-2 to the committed offset FetchPosition{offset=36, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t231_inv_repdetail-0 to the committed offset FetchPosition{offset=350296, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=35}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t231_inv_repdetail-2 to the committed offset FetchPosition{offset=348821, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t300_bookingperiod-0 to the committed offset FetchPosition{offset=93, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 0 rack: 0 isFenced: false)], epoch=60}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t300_bookingperiod-2 to the committed offset FetchPosition{offset=112, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=33}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t404_mde_suppliers-2 to the committed offset FetchPosition{offset=3, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=32}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t417_order_stock_factors-2 to the committed offset FetchPosition{offset=85, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t440_bal_head-2 to the committed offset FetchPosition{offset=41760, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=27}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t441_bal_det-0 to the committed offset FetchPosition{offset=111709, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t443_efis_list-0 to the committed offset FetchPosition{offset=10877, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=38}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t443_efis_list-2 to the committed offset FetchPosition{offset=11971, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=37}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t480_tour_picklists-0 to the committed offset FetchPosition{offset=37680, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 0 rack: 0 isFenced: false)], epoch=68}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t480_tour_picklists-2 to the committed offset FetchPosition{offset=37686, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t480_tour_picklists-6 to the committed offset FetchPosition{offset=37979, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=65}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,205] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t483_rest_palettes-0 to the committed offset FetchPosition{offset=179, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=33}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t177_dblogin-0 to the committed offset FetchPosition{offset=15, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 5 rack: 2 isFenced: false)], epoch=38}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t182_ctw_ <prefix>-2 to the committed offset FetchPosition{offset=98444, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t230_inv_repheader-0 to the committed offset FetchPosition{offset=20, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=26}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t404_mde_suppliers-0 to the committed offset FetchPosition{offset=3, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 2 rack: 2 isFenced: false)], epoch=31}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t417_order_stock_factors-0 to the committed offset FetchPosition{offset=72, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t440_bal_head-0 to the committed offset FetchPosition{offset=39304, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.westeurope.azure.confluent.cloud:9092 (id: 4 rack: 1 isFenced: false)], epoch=28}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t441_bal_det-2 to the committed offset FetchPosition{offset=113208, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=30}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t480_tour_picklists-4 to the committed offset FetchPosition{offset=37697, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 3 rack: 0 isFenced: false)], epoch=31}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,206] INFO [table-small-12-sink-iceberg|task-0] Setting offset for partition topic_t483_rest_palettes-2 to the committed offset FetchPosition{offset=142, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[<coord>.azure.confluent.cloud:9092 (id: 1 rack: 1 isFenced: false)], epoch=35}} (org.apache.kafka.clients.consumer.internals.ConsumerUtils:209)
   [2025-09-04 15:01:56,230] INFO [table-small-12-sink-iceberg|task-0] Hadoop config initialized: org.apache.hadoop.hdfs.HdfsConfiguration (org.apache.iceberg.connect.CatalogUtils:88)
   [2025-09-04 15:01:56,231] INFO [table-small-12-sink-iceberg|task-0] Loading AuthManager implementation: org.apache.iceberg.rest.auth.OAuth2Manager (org.apache.iceberg.rest.auth.AuthManagers:105)
   [2025-09-04 15:01:56,233] INFO [table-small-12-sink-iceberg|task-0] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:01:56,405] INFO [table-small-12-sink-iceberg|task-0] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:01:56,415] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:01:56,415] INFO [table-small-12-sink-iceberg|task-0] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:01:56,415] INFO [table-small-12-sink-iceberg|task-0] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:01:56,416] INFO [table-small-12-sink-iceberg|task-0] AdminClientConfig values:
   [2025-09-04 15:01:56,416] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:56,417] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:56,417] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998116417 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:56,417] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:56,417] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:56,977] INFO [table-small-12-sink-iceberg|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:270)
   [2025-09-04 15:01:56,977] INFO [table-small-12-sink-iceberg|task-0] ProducerConfig values:
   [2025-09-04 15:01:56,977] INFO [table-small-12-sink-iceberg|task-0] Task elected leader, starting commit coordinator (org.apache.iceberg.connect.channel.CommitterImpl:72)
   [2025-09-04 15:01:56,978] INFO [table-small-12-sink-iceberg|task-0] [Producer clientId=c2ff3650-e1d8-4d7e-a80b-f507ac3b4d0d, transactionalId=coordinator-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-0] Instantiated a transactional producer. (org.apache.kafka.clients.producer.KafkaProducer:609)
   [2025-09-04 15:01:56,978] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:56,980] INFO [table-small-12-sink-iceberg|task-0] [Producer clientId=c2ff3650-e1d8-4d7e-a80b-f507ac3b4d0d, transactionalId=coordinator-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-0] Invoking InitProducerId for the first time in order to acquire a producer ID (org.apache.kafka.clients.producer.internals.TransactionManager:294)
   [2025-09-04 15:01:56,980] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:56,980] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998116980 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:56,980] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:56,980] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:57,523] INFO [table-small-12-sink-iceberg|task-0] ConsumerConfig values:
   [2025-09-04 15:01:57,523] INFO [table-small-12-sink-iceberg|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:270)
   [2025-09-04 15:01:57,524] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:57,526] INFO [table-small-12-sink-iceberg|task-0] AdminClientConfig values:
   [2025-09-04 15:01:57,526] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:57,526] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998117526 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:57,526] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:57,526] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, producer.security.protocol, listeners, status.storage.topic, listeners.https.ssl.keyst
 ore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:57,527] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:57,528] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:57,528] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998117528 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:57,528] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:57,528] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:57,529] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Subscribed to topic(s):  <prefix>.iceberg-control-small_12 (org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer:502)
   [2025-09-04 15:01:57,529] INFO [table-small-12-sink-iceberg|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:270)
   [2025-09-04 15:01:57,529] INFO [table-small-12-sink-iceberg|task-0] ProducerConfig values:
   [2025-09-04 15:01:57,529] INFO [table-small-12-sink-iceberg|task-0] Starting commit worker (org.apache.iceberg.connect.channel.CommitterImpl:79)
   [2025-09-04 15:01:57,530] INFO [table-small-12-sink-iceberg|task-0] [Producer clientId=62ab858b-df91-4911-a386-2563ce441263, transactionalId=worker-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-0] Instantiated a transactional producer. (org.apache.kafka.clients.producer.KafkaProducer:609)
   [2025-09-04 15:01:57,530] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:57,532] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:57,532] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998117532 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:57,532] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:57,532] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:57,533] INFO [table-small-12-sink-iceberg|task-0] [Producer clientId=62ab858b-df91-4911-a386-2563ce441263, transactionalId=worker-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-0] Invoking InitProducerId for the first time in order to acquire a producer ID (org.apache.kafka.clients.producer.internals.TransactionManager:294)
   [2025-09-04 15:01:57,555] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Cluster ID: <cluster> (org.apache.kafka.clients.Metadata:366)
   [2025-09-04 15:01:57,556] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:57,556] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Discovered group coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483647 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 15:01:57,577] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:57,577] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Request joining group due to: need to re-join with the given member-id: f98b462d-c6fa-4cfb-bf96-1b0683cf3c81-194ecd23-af3b-4ac5-a12c-f22c5e8af216 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:57,578] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Finished assignment for group at generation 324: {f98b462d-c6fa-4cfb-bf96-1b0683cf3c81-194ecd23-af3b-4ac5-a12c-f22c5e8af216=Assignment(partitions=[ <prefix>.iceberg-control-small_12-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:664)
   [2025-09-04 15:01:57,578] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Successfully joined group with generation Generation{generationId=324, memberId='f98b462d-c6fa-4cfb-bf96-1b0683cf3c81-194ecd23-af3b-4ac5-a12c-f22c5e8af216', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:01:57,581] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Adding newly assigned partitions:  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:58)
   [2025-09-04 15:01:57,581] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Notifying assignor about the new Assignment(partitions=[ <prefix>.iceberg-control-small_12-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:324)
   [2025-09-04 15:01:57,581] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Successfully synced group in generation Generation{generationId=324, memberId='f98b462d-c6fa-4cfb-bf96-1b0683cf3c81-194ecd23-af3b-4ac5-a12c-f22c5e8af216', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:843)
   [2025-09-04 15:01:58,082] INFO [table-small-12-sink-iceberg|task-0] ConsumerConfig values:
   [2025-09-04 15:01:58,083] INFO [table-small-12-sink-iceberg|task-0] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:270)
   [2025-09-04 15:01:58,084] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:58,086] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:58,086] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998118086 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:58,086] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:58,086] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, producer.security.protocol, listeners, status.storage.topic, listeners.https.ssl.keyst
 ore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:58,087] INFO [table-small-12-sink-iceberg|task-0] AdminClientConfig values:
   [2025-09-04 15:01:58,088] INFO [table-small-12-sink-iceberg|task-0] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:01:58,089] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Subscribed to topic(s):  <prefix>.iceberg-control-small_12 (org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer:502)
   [2025-09-04 15:01:58,089] INFO [table-small-12-sink-iceberg|task-0] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:01:58,089] INFO [table-small-12-sink-iceberg|task-0] Kafka startTimeMs: 1756998118089 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:01:58,089] INFO [table-small-12-sink-iceberg|task-0] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:01:58,089] INFO [table-small-12-sink-iceberg|task-0] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:01:58,100] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Cluster ID: <cluster> (org.apache.kafka.clients.Metadata:366)
   [2025-09-04 15:01:58,101] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:58,101] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Discovered group coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483642 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 15:01:58,102] INFO [table-small-12-sink-iceberg|task-0] Client telemetry registered with client instance id: IykVKPGmTmycKcw2k3ZJkg (org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter:481)
   [2025-09-04 15:01:58,122] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:01:58,122] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Request joining group due to: need to re-join with the given member-id: 312b4c5c-26d6-4978-b088-c0fa96b21187-06c06248-d3ae-41be-b2d4-91696b2c1967 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:01:58,125] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Finished assignment for group at generation 1: {312b4c5c-26d6-4978-b088-c0fa96b21187-06c06248-d3ae-41be-b2d4-91696b2c1967=Assignment(partitions=[ <prefix>.iceberg-control-small_12-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:664)
   [2025-09-04 15:01:58,125] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Successfully joined group with generation Generation{generationId=1, memberId='312b4c5c-26d6-4978-b088-c0fa96b21187-06c06248-d3ae-41be-b2d4-91696b2c1967', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:01:58,129] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Adding newly assigned partitions:  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:58)
   [2025-09-04 15:01:58,129] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Notifying assignor about the new Assignment(partitions=[ <prefix>.iceberg-control-small_12-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:324)
   [2025-09-04 15:01:58,129] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Successfully synced group in generation Generation{generationId=1, memberId='312b4c5c-26d6-4978-b088-c0fa96b21187-06c06248-d3ae-41be-b2d4-91696b2c1967', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:843)
   [2025-09-04 15:01:58,131] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=312b4c5c-26d6-4978-b088-c0fa96b21187, groupId=cg-control-872e2449-ebcd-4714-962b-69c499759dc1] Found no committed offset for partition  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:02:07,296] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to socket connection setup timeout. The timeout value is 10955 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:02:07,296] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to socket connection setup timeout. The timeout value is 9130 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:02:07,296] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to socket connection setup timeout. The timeout value is 8136 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:02:07,296] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to socket connection setup timeout. The timeout value is 8315 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:02:18,779] INFO [table-small-12-sink-iceberg|task-1] Hadoop config initialized: org.apache.hadoop.hdfs.HdfsConfiguration (org.apache.iceberg.connect.CatalogUtils:88)
   [2025-09-04 15:02:18,782] INFO [table-small-12-sink-iceberg|task-1] Loading AuthManager implementation: org.apache.iceberg.rest.auth.OAuth2Manager (org.apache.iceberg.rest.auth.AuthManagers:105)
   [2025-09-04 15:02:18,785] INFO [table-small-12-sink-iceberg|task-1] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:02:29,954] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-1] Node 0 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 15:02:29,954] INFO [table-small-12-sink-iceberg|task-1] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:02:29,990] INFO [table-small-12-sink-iceberg|task-1] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:02:29,990] INFO [table-small-12-sink-iceberg|task-1] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:02:29,990] INFO [table-small-12-sink-iceberg|task-1] Using overriden client-credential refresh AuthSession (org.apache.iceberg.rest.auth.OAuth2Util$AuthSession:472)
   [2025-09-04 15:02:29,991] INFO [table-small-12-sink-iceberg|task-1] AdminClientConfig values:
   [2025-09-04 15:02:29,992] INFO [table-small-12-sink-iceberg|task-1] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:02:29,994] INFO [table-small-12-sink-iceberg|task-1] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:02:29,994] INFO [table-small-12-sink-iceberg|task-1] Kafka startTimeMs: 1756998149994 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:02:29,994] INFO [table-small-12-sink-iceberg|task-1] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:02:29,994] INFO [table-small-12-sink-iceberg|task-1] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   
   + [2025-09-04 15:02:43,745] INFO Committed snapshot 4343445114214793138 (MergeAppend) (org.apache.iceberg.SnapshotProducer:481)**
   
   [2025-09-04 15:02:52,999] INFO [table-small-12-sink-iceberg|task-1] Starting commit worker (org.apache.iceberg.connect.channel.CommitterImpl:79)
   [2025-09-04 15:02:53,000] INFO [table-small-12-sink-iceberg|task-1] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:270)
   [2025-09-04 15:02:53,000] INFO [table-small-12-sink-iceberg|task-1] ProducerConfig values:
   [2025-09-04 15:02:53,001] INFO [table-small-12-sink-iceberg|task-1] [Producer clientId=f5fe3389-bf7f-489e-a336-0bde5eb178ca, transactionalId=worker-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-1] Instantiated a transactional producer. (org.apache.kafka.clients.producer.KafkaProducer:609)
   [2025-09-04 15:02:53,008] INFO [table-small-12-sink-iceberg|task-1] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:02:53,020] INFO [table-small-12-sink-iceberg|task-1] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:02:53,020] INFO [table-small-12-sink-iceberg|task-1] Kafka startTimeMs: 1756998173020 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:02:53,020] INFO [table-small-12-sink-iceberg|task-1] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:02:53,020] INFO [table-small-12-sink-iceberg|task-1] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:02:53,025] INFO [table-small-12-sink-iceberg|task-1] [Producer clientId=f5fe3389-bf7f-489e-a336-0bde5eb178ca, transactionalId=worker-txn-3bdb3242-eb09-49cd-b864-044f986e61f3-1] Invoking InitProducerId for the first time in order to acquire a producer ID (org.apache.kafka.clients.producer.internals.TransactionManager:294)
   [2025-09-04 15:02:59,100] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 30 due to node 2 being disconnected (elapsed time since creation: 60009ms, elapsed time since send: 60009ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:02:59,100] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:02:59,101] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:02:59,661] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:02:59,862] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:03:04,305] INFO [table-small-12-sink-iceberg|task-1] ConsumerConfig values:
   [2025-09-04 15:03:04,316] INFO [table-small-12-sink-iceberg|task-1] initializing Kafka metrics collector (org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector:270)
   [2025-09-04 15:03:04,319] INFO [table-small-12-sink-iceberg|task-1] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:03:04,338] INFO [table-small-12-sink-iceberg|task-1] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:03:04,338] INFO [table-small-12-sink-iceberg|task-1] Kafka startTimeMs: 1756998184338 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:03:04,338] INFO [table-small-12-sink-iceberg|task-1] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:03:04,338] INFO [table-small-12-sink-iceberg|task-1] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, producer.security.protocol, listeners, status.storage.topic, listeners.https.ssl.keyst
 ore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:03:04,339] INFO [table-small-12-sink-iceberg|task-1] AdminClientConfig values:
   [2025-09-04 15:03:04,340] INFO [table-small-12-sink-iceberg|task-1] Creating SSL context for keystore : null (org.apache.kafka.common.security.ssl.DefaultSslEngineFactory:249)
   [2025-09-04 15:03:04,343] INFO [table-small-12-sink-iceberg|task-1] Kafka version: 8.0.0-ce (org.apache.kafka.common.utils.AppInfoParser:132)
   [2025-09-04 15:03:04,343] INFO [table-small-12-sink-iceberg|task-1] These configurations '[listeners.https.ssl.truststore.password, consumer.sasl.mechanism, config.providers, rest.extension.classes, listeners.https.ssl.key.password, confluent.topic.replication.factor, status.storage.replication.factor, config.providers.file.class, consumer.security.protocol, offset.storage.topic, rest.advertised.listener, key.converter, listeners.https.ssl.enabled.protocols, consumer.sasl.jaas.config, config.storage.topic, rest.advertised.host.name, heartbeat.interval.ms, consumer.bootstrap.servers, config.storage.replication.factor, topic.creation.enable, key.converter.schemas.enable, value.converter.schemas.enable, admin.sasl.jaas.config, admin.bootstrap.servers, producer.sasl.jaas.config, producer.bootstrap.servers, group.id, rest.advertised.port, plugin.path, admin.security.protocol, confluent.license, admin.sasl.mechanism, value.converter, session.timeout.ms, producer.security.protocol, liste
 ners, status.storage.topic, listeners.https.ssl.keystore.location, rebalance.timeout.ms, listeners.https.ssl.keystore.password, producer.sasl.mechanism, offset.flush.interval.ms, listeners.https.ssl.truststore.location, offset.storage.replication.factor]' were supplied but are not used yet. (org.apache.kafka.common.config.AbstractConfig:385)
   [2025-09-04 15:03:04,344] INFO [table-small-12-sink-iceberg|task-1] Kafka commitId: 3dddb42a261b39b6 (org.apache.kafka.common.utils.AppInfoParser:133)
   [2025-09-04 15:03:04,344] INFO [table-small-12-sink-iceberg|task-1] Kafka startTimeMs: 1756998184343 (org.apache.kafka.common.utils.AppInfoParser:134)
   [2025-09-04 15:03:04,349] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Subscribed to topic(s):  <prefix>.iceberg-control-small_12 (org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer:502)
   [2025-09-04 15:03:04,374] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Cluster ID: <cluster> (org.apache.kafka.clients.Metadata:366)
   [2025-09-04 15:03:04,374] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Discovered group coordinator <coord>.azure.confluent.cloud:9092 (id: 2147483642 rack: null isFenced: false) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:937)
   [2025-09-04 15:03:04,375] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:03:04,375] INFO [table-small-12-sink-iceberg|task-1] Client telemetry registered with client instance id: g8kan9WjR_OR_fsCtRCQ0Q (org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter:481)
   [2025-09-04 15:03:04,394] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:605)
   [2025-09-04 15:03:04,394] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Request joining group due to: need to re-join with the given member-id: f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f-bb41be29-a65f-400d-972c-44ab7aa3f35b (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1103)
   [2025-09-04 15:03:04,396] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Finished assignment for group at generation 1: {f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f-bb41be29-a65f-400d-972c-44ab7aa3f35b=Assignment(partitions=[ <prefix>.iceberg-control-small_12-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:664)
   [2025-09-04 15:03:04,396] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Successfully joined group with generation Generation{generationId=1, memberId='f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f-bb41be29-a65f-400d-972c-44ab7aa3f35b', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:666)
   [2025-09-04 15:03:04,400] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Notifying assignor about the new Assignment(partitions=[ <prefix>.iceberg-control-small_12-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:324)
   [2025-09-04 15:03:04,400] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Successfully synced group in generation Generation{generationId=1, memberId='f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f-bb41be29-a65f-400d-972c-44ab7aa3f35b', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:843)
   [2025-09-04 15:03:04,401] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Adding newly assigned partitions:  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerRebalanceListenerInvoker:58)
   [2025-09-04 15:03:04,403] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=f0f6a38c-77b2-4ed8-bd8b-1c6671b0027f, groupId=cg-control-867bd890-e373-4fcd-8b23-e0f44b67412d] Found no committed offset for partition  <prefix>.iceberg-control-small_12-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1508)
   [2025-09-04 15:03:06,785] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:03:06,895] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:03:07,160] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:03:07,282] INFO [table-small-12-sink-iceberg|task-0] Loading custom FileIO implementation: org.apache.iceberg.azure.adlsv2.ADLSFileIO (org.apache.iceberg.CatalogUtil:376)
   [2025-09-04 15:04:00,211] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 52 due to node 2 being disconnected (elapsed time since creation: 60325ms, elapsed time since send: 60007ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:00,211] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:00,211] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:02,425] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 56 due to node 0 being disconnected (elapsed time since creation: 60002ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:02,425] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 57 due to node 1 being disconnected (elapsed time since creation: 60002ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:02,425] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 0 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:02,425] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:02,426] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=2006748031, epoch=1) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 59 due to node 4 being disconnected (elapsed time since creation: 60002ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 58 due to node 5 being disconnected (elapsed time since creation: 60002ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 76 due to node 5 being disconnected (elapsed time since creation: 3498ms, elapsed time since send: 3498ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1163553054, epoch=1) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1375755910, epoch=1) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:02,426] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=141207895, epoch=1) to node 0: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:09,471] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 15:04:11,965] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 15:04:17,581] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node -1 due to socket connection setup timeout. The timeout value is 24337 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:04:17,582] WARN [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   [2025-09-04 15:04:17,583] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Disconnecting from node 3 due to socket connection setup timeout. The timeout value is 23833 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:04:17,587] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Rebootstrapping with [<cluster>.azure.confluent.cloud/10.1.0.29:9092] (org.apache.kafka.clients.Metadata:315)
   [2025-09-04 15:04:23,730] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 0 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1448 due to node 0 being disconnected (elapsed time since creation: 68018ms, elapsed time since send: 68018ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1449 due to node 1 being disconnected (elapsed time since creation: 68018ms, elapsed time since send: 68018ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1447 due to node 2 being disconnected (elapsed time since creation: 68018ms, elapsed time since send: 68018ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1446 due to node 3 being disconnected (elapsed time since creation: 68018ms, elapsed time since send: 68018ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1451 due to node 4 being disconnected (elapsed time since creation: 68018ms, elapsed time since send: 68018ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:23,740] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1450 due to node 5 being disconnected (elapsed time since creation: 68018ms, elapsed time since send: 68018ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=514490741, epoch=1) to node 0: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:23,741] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:04:23,742] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=2264982, epoch=INITIAL) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   
   + [2025-09-04 15:04:55,247] INFO Received metrics report: CommitReport{tableName=polaris.raw.t440_bal_head, snapshotId=4343445114214793138, sequenceNumber=39188, operation=append, commitMetrics=CommitMetricsResult{totalDuration=TimerResult{timeUnit=NANOSECONDS, totalDuration=PT7M11.811166357S, count=1}, attempts=CounterResult{unit=COUNT, value=1}, addedDataFiles=CounterResult{unit=COUNT, value=2}, removedDataFiles=null, totalDataFiles=CounterResult{unit=COUNT, value=285}, addedDeleteFiles=null, addedEqualityDeleteFiles=null, addedPositionalDeleteFiles=null, addedDVs=null, removedDeleteFiles=null, removedEqualityDeleteFiles=null, removedPositionalDeleteFiles=null, removedDVs=null, totalDeleteFiles=CounterResult{unit=COUNT, value=0}, addedRecords=CounterResult{unit=COUNT, value=8}, removedRecords=null, totalRecords=CounterResult{unit=COUNT, value=1879583}, addedFilesSizeInBytes=CounterResult{unit=BYTES, value=22558}, removedFilesSizeInBytes=null, totalFilesSizeInBytes=CounterResult{
 unit=BYTES, value=75774415}, addedPositionalDeletes=null, removedPositionalDeletes=null, totalPositionalDeletes=CounterResult{unit=COUNT, value=0}, addedEqualityDeletes=null, removedEqualityDeletes=null, totalEqualityDeletes=CounterResult{unit=COUNT, value=0}, manifestsCreated=null, manifestsReplaced=null, manifestsKept=null, manifestEntriesProcessed=null}, metadata={iceberg-version=Apache Iceberg 1.9.2 (commit 071d5606bc6199a0be9b3f274ec7fbf111d88821)}} (org.apache.iceberg.metrics.LoggingMetricsReporter:38)
   
   [2025-09-04 15:04:55,252] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Disconnecting from node -1 due to socket connection setup timeout. The timeout value is 8744 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:04:55,253] WARN [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   [2025-09-04 15:05:01,902] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 78 due to node 2 being disconnected (elapsed time since creation: 60074ms, elapsed time since send: 60054ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:01,902] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:01,902] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:02,427] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 80 due to node 3 being disconnected (elapsed time since creation: 60001ms, elapsed time since send: 60001ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:02,427] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight METADATA request with correlation id 85 due to node 3 being disconnected (elapsed time since creation: 59889ms, elapsed time since send: 59889ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:02,427] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:02,427] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1529764225, epoch=2) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:02,567] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 82 due to node 1 being disconnected (elapsed time since creation: 60029ms, elapsed time since send: 60003ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:02,567] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:02,567] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=2006748031, epoch=INITIAL) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:02,580] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 84 due to node 4 being disconnected (elapsed time since creation: 60042ms, elapsed time since send: 60002ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:02,580] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:02,580] INFO [table-small-12-sink-iceberg|task-0] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1163553054, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:07,727] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node -1 due to socket connection setup timeout. The timeout value is 30000 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:05:07,727] WARN [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   [2025-09-04 15:05:14,267] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,267] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,267] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,268] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_COMPLETE (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,268] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,268] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,268] INFO [table-small-12-sink-iceberg|task-0] Sending event of type: DATA_WRITTEN (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:14,814] INFO [table-small-12-sink-iceberg|task-0] Handled event of type: START_COMMIT (org.apache.iceberg.connect.channel.Channel:133)
   [2025-09-04 15:05:20,388] INFO [table-small-12-sink-iceberg|task-1] Sending event of type: DATA_COMPLETE (org.apache.iceberg.connect.channel.Channel:88)
   [2025-09-04 15:05:20,418] INFO [table-small-12-sink-iceberg|task-1] Handled event of type: START_COMMIT (org.apache.iceberg.connect.channel.Channel:133)
   
   + This is now an entirely different Snapshot than the duplicate 2 just a few seconds after the duplicate snapshot was committed
   
   [2025-09-04 15:05:21,189] INFO Received metrics report: CommitReport{tableName=polaris.raw.t440_bal_head, snapshotId=2509078283058136613, sequenceNumber=39189, operation=append, commitMetrics=CommitMetricsResult{totalDuration=TimerResult{timeUnit=NANOSECONDS, totalDuration=PT0.595580864S, count=1}, attempts=CounterResult{unit=COUNT, value=1}, addedDataFiles=CounterResult{unit=COUNT, value=8}, removedDataFiles=null, totalDataFiles=CounterResult{unit=COUNT, value=293}, addedDeleteFiles=null, addedEqualityDeleteFiles=null, addedPositionalDeleteFiles=null, addedDVs=null, removedDeleteFiles=null, removedEqualityDeleteFiles=null, removedPositionalDeleteFiles=null, removedDVs=null, totalDeleteFiles=CounterResult{unit=COUNT, value=0}, addedRecords=CounterResult{unit=COUNT, value=105}, removedRecords=null, totalRecords=CounterResult{unit=COUNT, value=1879688}, addedFilesSizeInBytes=CounterResult{unit=BYTES, value=94898}, removedFilesSizeInBytes=null, totalFilesSizeInBytes=CounterResult{uni
 t=BYTES, value=75869313}, addedPositionalDeletes=null, removedPositionalDeletes=null, totalPositionalDeletes=CounterResult{unit=COUNT, value=0}, addedEqualityDeletes=null, removedEqualityDeletes=null, totalEqualityDeletes=CounterResult{unit=COUNT, value=0}, manifestsCreated=null, manifestsReplaced=null, manifestsKept=null, manifestEntriesProcessed=null}, metadata={iceberg-version=Apache Iceberg 1.9.2 (commit 071d5606bc6199a0be9b3f274ec7fbf111d88821)}} (org.apache.iceberg.metrics.LoggingMetricsReporter:38)
   [2025-09-04 15:05:21,202] INFO Commit complete to table raw.t440_bal_head, snapshot 2509078283058136613, commit ID b63a5266-3dd1-4a53-9888-396110938031, valid-through null (org.apache.iceberg.connect.channel.Coordinator:266)
   [2025-09-04 15:05:25,541] INFO [Consumer clientId=f98b462d-c6fa-4cfb-bf96-1b0683cf3c81, groupId=connect-table-small-12-sink-iceberg-coord] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:1191)
   [2025-09-04 15:05:31,799] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1460 due to node 0 being disconnected (elapsed time since creation: 67946ms, elapsed time since send: 67928ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:31,799] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1461 due to node 1 being disconnected (elapsed time since creation: 67946ms, elapsed time since send: 67922ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:31,799] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 0 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:31,799] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 1 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1459 due to node 2 being disconnected (elapsed time since creation: 67946ms, elapsed time since send: 67922ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1458 due to node 3 being disconnected (elapsed time since creation: 67946ms, elapsed time since send: 67928ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1463 due to node 4 being disconnected (elapsed time since creation: 67946ms, elapsed time since send: 67923ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Cancelled in-flight FETCH request with correlation id 1462 due to node 5 being disconnected (elapsed time since creation: 67946ms, elapsed time since send: 67924ms, throttle time: 0ms, request timeout: 60000ms) (org.apache.kafka.clients.NetworkClient:480)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 2 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 3 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 4 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node 5 due to request timeout. (org.apache.kafka.clients.NetworkClient:1024)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1574004371, epoch=INITIAL) to node 2: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=1777106785, epoch=INITIAL) to node 4: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=2264982, epoch=INITIAL) to node 1: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:31,800] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=514490741, epoch=INITIAL) to node 0: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:31,801] INFO [table-small-12-sink-iceberg|task-1] [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:31,802] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-1, groupId=connect-table-small-12-sink-iceberg] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: (org.apache.kafka.clients.FetchSessionHandler:618)
   [2025-09-04 15:05:32,825] INFO [Producer clientId=connector-dlq-producer-table-small-12-sink-iceberg-0] Cluster ID: <cluster> (org.apache.kafka.clients.Metadata:366)
   [2025-09-04 15:05:57,971] INFO [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Disconnecting from node -1 due to socket connection setup timeout. The timeout value is 29467 ms. (org.apache.kafka.clients.NetworkClient:1046)
   [2025-09-04 15:05:57,973] WARN [Consumer clientId=connector-consumer-table-small-12-sink-iceberg-0, groupId=connect-table-small-12-sink-iceberg] Bootstrap broker <cluster>.azure.confluent.cloud:9092 (id: -1 rack: null isFenced: false) disconnected (org.apache.kafka.clients.NetworkClient:1388)
   ```
   
   
   What seems odd is that if you search for snapshot ID 2368336716243636983 there are 3 logs (one of them being commit complete to table from Coordinator), but if you search snapshot ID 4343445114214793138 there are only 2 logs. Not sure how to interpret this but it seems it may be creating the Snapshot outside of Coordinator's logic and the Coordinator is actually not aware of this Snapshot being produced?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org