2024-01-09 11:02:23 [2024-01-09 00:02:23,249] INFO [Worker clientId=connect-1, groupId=1] Connector iceberg-sink config updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,251] INFO [Worker clientId=connect-1, groupId=1] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,251] INFO [Worker clientId=connect-1, groupId=1] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,273] INFO [Worker clientId=connect-1, groupId=1] Successfully joined group with generation Generation{generationId=2, memberId='connect-1-496637d2-4cdc-4a24-ac8c-4f7c1cb8bea9', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,281] INFO 10.213.28.1 - - [09/Jan/2024:00:02:23 +0000] "POST /connectors/ HTTP/1.1" 201 825 "-" "curl/7.81.0" 255 (org.apache.kafka.connect.runtime.rest.RestServer)
2024-01-09 11:02:23 [2024-01-09 00:02:23,292] INFO [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=2, memberId='connect-1-496637d2-4cdc-4a24-ac8c-4f7c1cb8bea9', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,292] INFO [Worker clientId=connect-1, groupId=1] Joined group at generation 2 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-496637d2-4cdc-4a24-ac8c-4f7c1cb8bea9', leaderUrl='http://10.213.28.5:8083/', offset=3, connectorIds=[iceberg-sink], taskIds=[], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,293] INFO [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 3 (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,296] INFO [Worker clientId=connect-1, groupId=1] Starting connector iceberg-sink (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,306] INFO Creating connector iceberg-sink of type io.tabular.iceberg.connect.IcebergSinkConnector (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,307] INFO SinkConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.deadletterqueue.context.headers.enable = false
2024-01-09 11:02:23     errors.deadletterqueue.topic.name = 
2024-01-09 11:02:23     errors.deadletterqueue.topic.replication.factor = 3
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     topics = [postgres.public.students]
2024-01-09 11:02:23     topics.regex = 
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.SinkConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,308] INFO EnrichedConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.deadletterqueue.context.headers.enable = false
2024-01-09 11:02:23     errors.deadletterqueue.topic.name = 
2024-01-09 11:02:23     errors.deadletterqueue.topic.replication.factor = 3
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     topics = [postgres.public.students]
2024-01-09 11:02:23     topics.regex = 
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,317] INFO Instantiated connector iceberg-sink with version 1.4.2-kc-0.6.5 of type class io.tabular.iceberg.connect.IcebergSinkConnector (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,318] INFO Finished creating connector iceberg-sink (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,319] INFO [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,327] INFO [Producer clientId=1--statuses] Resetting the last seen epoch of partition my_source_connect_statuses-0 to 0 since the associated topicId changed from null to KO99eZmqQNywnBMW7emMcA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,327] INFO [Producer clientId=1--statuses] Resetting the last seen epoch of partition my_source_connect_statuses-1 to 0 since the associated topicId changed from null to KO99eZmqQNywnBMW7emMcA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,327] INFO [Producer clientId=1--statuses] Resetting the last seen epoch of partition my_source_connect_statuses-4 to 0 since the associated topicId changed from null to KO99eZmqQNywnBMW7emMcA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,327] INFO [Producer clientId=1--statuses] Resetting the last seen epoch of partition my_source_connect_statuses-2 to 0 since the associated topicId changed from null to KO99eZmqQNywnBMW7emMcA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,327] INFO [Producer clientId=1--statuses] Resetting the last seen epoch of partition my_source_connect_statuses-3 to 0 since the associated topicId changed from null to KO99eZmqQNywnBMW7emMcA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,332] INFO SinkConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.deadletterqueue.context.headers.enable = false
2024-01-09 11:02:23     errors.deadletterqueue.topic.name = 
2024-01-09 11:02:23     errors.deadletterqueue.topic.replication.factor = 3
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     topics = [postgres.public.students]
2024-01-09 11:02:23     topics.regex = 
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.SinkConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,333] INFO EnrichedConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.deadletterqueue.context.headers.enable = false
2024-01-09 11:02:23     errors.deadletterqueue.topic.name = 
2024-01-09 11:02:23     errors.deadletterqueue.topic.replication.factor = 3
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     topics = [postgres.public.students]
2024-01-09 11:02:23     topics.regex = 
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,383] INFO [Worker clientId=connect-1, groupId=1] Tasks [iceberg-sink-0] configs updated (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,385] INFO [Worker clientId=connect-1, groupId=1] Rebalance started (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,386] INFO [Worker clientId=connect-1, groupId=1] (Re-)joining group (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,388] INFO [Worker clientId=connect-1, groupId=1] Successfully joined group with generation Generation{generationId=3, memberId='connect-1-496637d2-4cdc-4a24-ac8c-4f7c1cb8bea9', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,395] INFO [Worker clientId=connect-1, groupId=1] Successfully synced group in generation Generation{generationId=3, memberId='connect-1-496637d2-4cdc-4a24-ac8c-4f7c1cb8bea9', protocol='sessioned'} (org.apache.kafka.connect.runtime.distributed.WorkerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,395] INFO [Worker clientId=connect-1, groupId=1] Joined group at generation 3 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-496637d2-4cdc-4a24-ac8c-4f7c1cb8bea9', leaderUrl='http://10.213.28.5:8083/', offset=5, connectorIds=[iceberg-sink], taskIds=[iceberg-sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,397] INFO [Worker clientId=connect-1, groupId=1] Starting connectors and tasks using config offset 5 (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,398] INFO [Worker clientId=connect-1, groupId=1] Starting task iceberg-sink-0 (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,405] INFO Creating task iceberg-sink-0 (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,406] INFO ConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.ConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,406] INFO EnrichedConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,409] INFO TaskConfig values: 
2024-01-09 11:02:23     task.class = class io.tabular.iceberg.connect.IcebergSinkTask
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.TaskConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,409] INFO Instantiated task iceberg-sink-0 with version 1.4.2-kc-0.6.5 of type io.tabular.iceberg.connect.IcebergSinkTask (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,412] INFO StringConverterConfig values: 
2024-01-09 11:02:23     converter.encoding = UTF-8
2024-01-09 11:02:23     converter.type = key
2024-01-09 11:02:23  (org.apache.kafka.connect.storage.StringConverterConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,412] INFO JsonConverterConfig values: 
2024-01-09 11:02:23     converter.type = value
2024-01-09 11:02:23     decimal.format = BASE64
2024-01-09 11:02:23     schemas.cache.size = 1000
2024-01-09 11:02:23     schemas.enable = false
2024-01-09 11:02:23  (org.apache.kafka.connect.json.JsonConverterConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,413] INFO Set up the key converter class org.apache.kafka.connect.storage.StringConverter for task iceberg-sink-0 using the connector config (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,413] INFO Set up the value converter class org.apache.kafka.connect.json.JsonConverter for task iceberg-sink-0 using the connector config (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,413] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task iceberg-sink-0 using the worker config (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,421] INFO Initializing: org.apache.kafka.connect.runtime.TransformationChain{} (org.apache.kafka.connect.runtime.Worker)
2024-01-09 11:02:23 [2024-01-09 00:02:23,421] INFO SinkConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.deadletterqueue.context.headers.enable = false
2024-01-09 11:02:23     errors.deadletterqueue.topic.name = 
2024-01-09 11:02:23     errors.deadletterqueue.topic.replication.factor = 3
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     topics = [postgres.public.students]
2024-01-09 11:02:23     topics.regex = 
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.SinkConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,422] INFO EnrichedConnectorConfig values: 
2024-01-09 11:02:23     config.action.reload = restart
2024-01-09 11:02:23     connector.class = io.tabular.iceberg.connect.IcebergSinkConnector
2024-01-09 11:02:23     errors.deadletterqueue.context.headers.enable = false
2024-01-09 11:02:23     errors.deadletterqueue.topic.name = 
2024-01-09 11:02:23     errors.deadletterqueue.topic.replication.factor = 3
2024-01-09 11:02:23     errors.log.enable = false
2024-01-09 11:02:23     errors.log.include.messages = false
2024-01-09 11:02:23     errors.retry.delay.max.ms = 60000
2024-01-09 11:02:23     errors.retry.timeout = 0
2024-01-09 11:02:23     errors.tolerance = none
2024-01-09 11:02:23     header.converter = null
2024-01-09 11:02:23     key.converter = class org.apache.kafka.connect.storage.StringConverter
2024-01-09 11:02:23     name = iceberg-sink
2024-01-09 11:02:23     predicates = []
2024-01-09 11:02:23     tasks.max = 1
2024-01-09 11:02:23     topics = [postgres.public.students]
2024-01-09 11:02:23     topics.regex = 
2024-01-09 11:02:23     transforms = []
2024-01-09 11:02:23     value.converter = class org.apache.kafka.connect.json.JsonConverter
2024-01-09 11:02:23  (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,425] INFO ConsumerConfig values: 
2024-01-09 11:02:23     allow.auto.create.topics = true
2024-01-09 11:02:23     auto.commit.interval.ms = 5000
2024-01-09 11:02:23     auto.include.jmx.reporter = true
2024-01-09 11:02:23     auto.offset.reset = earliest
2024-01-09 11:02:23     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:23     check.crcs = true
2024-01-09 11:02:23     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:23     client.id = connector-consumer-iceberg-sink-0
2024-01-09 11:02:23     client.rack = 
2024-01-09 11:02:23     connections.max.idle.ms = 540000
2024-01-09 11:02:23     default.api.timeout.ms = 60000
2024-01-09 11:02:23     enable.auto.commit = false
2024-01-09 11:02:23     exclude.internal.topics = true
2024-01-09 11:02:23     fetch.max.bytes = 52428800
2024-01-09 11:02:23     fetch.max.wait.ms = 500
2024-01-09 11:02:23     fetch.min.bytes = 1
2024-01-09 11:02:23     group.id = connect-iceberg-sink
2024-01-09 11:02:23     group.instance.id = null
2024-01-09 11:02:23     heartbeat.interval.ms = 3000
2024-01-09 11:02:23     interceptor.classes = []
2024-01-09 11:02:23     internal.leave.group.on.close = true
2024-01-09 11:02:23     internal.throw.on.fetch.stable.offset.unsupported = false
2024-01-09 11:02:23     isolation.level = read_uncommitted
2024-01-09 11:02:23     key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2024-01-09 11:02:23     max.partition.fetch.bytes = 1048576
2024-01-09 11:02:23     max.poll.interval.ms = 300000
2024-01-09 11:02:23     max.poll.records = 500
2024-01-09 11:02:23     metadata.max.age.ms = 300000
2024-01-09 11:02:23     metric.reporters = []
2024-01-09 11:02:23     metrics.num.samples = 2
2024-01-09 11:02:23     metrics.recording.level = INFO
2024-01-09 11:02:23     metrics.sample.window.ms = 30000
2024-01-09 11:02:23     partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
2024-01-09 11:02:23     receive.buffer.bytes = 65536
2024-01-09 11:02:23     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:23     reconnect.backoff.ms = 50
2024-01-09 11:02:23     request.timeout.ms = 30000
2024-01-09 11:02:23     retry.backoff.ms = 100
2024-01-09 11:02:23     sasl.client.callback.handler.class = null
2024-01-09 11:02:23     sasl.jaas.config = null
2024-01-09 11:02:23     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:23     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:23     sasl.kerberos.service.name = null
2024-01-09 11:02:23     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:23     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:23     sasl.login.callback.handler.class = null
2024-01-09 11:02:23     sasl.login.class = null
2024-01-09 11:02:23     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:23     sasl.login.read.timeout.ms = null
2024-01-09 11:02:23     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:23     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:23     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:23     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:23     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:23     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:23     sasl.mechanism = GSSAPI
2024-01-09 11:02:23     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:23     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:23     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:23     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:23     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:23     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:23     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:23     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:23     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:23     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:23     security.protocol = PLAINTEXT
2024-01-09 11:02:23     security.providers = null
2024-01-09 11:02:23     send.buffer.bytes = 131072
2024-01-09 11:02:23     session.timeout.ms = 45000
2024-01-09 11:02:23     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:23     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:23     ssl.cipher.suites = null
2024-01-09 11:02:23     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:23     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:23     ssl.engine.factory.class = null
2024-01-09 11:02:23     ssl.key.password = null
2024-01-09 11:02:23     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:23     ssl.keystore.certificate.chain = null
2024-01-09 11:02:23     ssl.keystore.key = null
2024-01-09 11:02:23     ssl.keystore.location = null
2024-01-09 11:02:23     ssl.keystore.password = null
2024-01-09 11:02:23     ssl.keystore.type = JKS
2024-01-09 11:02:23     ssl.protocol = TLSv1.3
2024-01-09 11:02:23     ssl.provider = null
2024-01-09 11:02:23     ssl.secure.random.implementation = null
2024-01-09 11:02:23     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:23     ssl.truststore.certificates = null
2024-01-09 11:02:23     ssl.truststore.location = null
2024-01-09 11:02:23     ssl.truststore.password = null
2024-01-09 11:02:23     ssl.truststore.type = JKS
2024-01-09 11:02:23     value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2024-01-09 11:02:23  (org.apache.kafka.clients.consumer.ConsumerConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,434] WARN These configurations '[metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,434] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:23 [2024-01-09 00:02:23,434] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:23 [2024-01-09 00:02:23,434] INFO Kafka startTimeMs: 1704758543434 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:23 [2024-01-09 00:02:23,449] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Subscribed to topic(s): postgres.public.students (org.apache.kafka.clients.consumer.KafkaConsumer)
2024-01-09 11:02:23 [2024-01-09 00:02:23,451] INFO [Worker clientId=connect-1, groupId=1] Finished starting connectors and tasks (org.apache.kafka.connect.runtime.distributed.DistributedHerder)
2024-01-09 11:02:23 [2024-01-09 00:02:23,452] INFO IcebergSinkConfig values: 
2024-01-09 11:02:23     iceberg.catalog = iceberg
2024-01-09 11:02:23     iceberg.connect.group-id = null
2024-01-09 11:02:23     iceberg.control.commit.interval-ms = 1000
2024-01-09 11:02:23     iceberg.control.commit.threads = 32
2024-01-09 11:02:23     iceberg.control.commit.timeout-ms = 30000
2024-01-09 11:02:23     iceberg.control.group-id = null
2024-01-09 11:02:23     iceberg.control.topic = control-iceberg
2024-01-09 11:02:23     iceberg.hadoop-conf-dir = null
2024-01-09 11:02:23     iceberg.tables = [public.students]
2024-01-09 11:02:23     iceberg.tables.auto-create-enabled = true
2024-01-09 11:02:23     iceberg.tables.cdc-field = null
2024-01-09 11:02:23     iceberg.tables.default-commit-branch = null
2024-01-09 11:02:23     iceberg.tables.default-id-columns = null
2024-01-09 11:02:23     iceberg.tables.default-partition-by = null
2024-01-09 11:02:23     iceberg.tables.dynamic-enabled = false
2024-01-09 11:02:23     iceberg.tables.evolve-schema-enabled = false
2024-01-09 11:02:23     iceberg.tables.route-field = null
2024-01-09 11:02:23     iceberg.tables.schema-case-insensitive = false
2024-01-09 11:02:23     iceberg.tables.schema-force-optional = false
2024-01-09 11:02:23     iceberg.tables.upsert-mode-enabled = false
2024-01-09 11:02:23  (io.tabular.iceberg.connect.IcebergSinkConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,483] INFO JsonConverterConfig values: 
2024-01-09 11:02:23     converter.type = value
2024-01-09 11:02:23     decimal.format = BASE64
2024-01-09 11:02:23     schemas.cache.size = 1000
2024-01-09 11:02:23     schemas.enable = false
2024-01-09 11:02:23  (org.apache.kafka.connect.json.JsonConverterConfig)
2024-01-09 11:02:23 [2024-01-09 00:02:23,483] INFO WorkerSinkTask{id=iceberg-sink-0} Sink task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask)
2024-01-09 11:02:23 [2024-01-09 00:02:23,485] INFO WorkerSinkTask{id=iceberg-sink-0} Executing sink task (org.apache.kafka.connect.runtime.WorkerSinkTask)
2024-01-09 11:02:23 [2024-01-09 00:02:23,536] WARN [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Error while fetching metadata with correlation id 2 : {postgres.public.students=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
2024-01-09 11:02:23 [2024-01-09 00:02:23,536] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Cluster ID: cRkIvkUsTXyqhcNw1EVhSA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,537] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Discovered group coordinator kafka:9092 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,538] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,553] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Request joining group due to: need to re-join with the given member-id: connector-consumer-iceberg-sink-0-dead1db0-8770-4d88-8a63-7dd28f4b15cb (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,554] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,554] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,572] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Successfully joined group with generation Generation{generationId=1, memberId='connector-consumer-iceberg-sink-0-dead1db0-8770-4d88-8a63-7dd28f4b15cb', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,640] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Resetting the last seen epoch of partition postgres.public.students-0 to 0 since the associated topicId changed from null to wX7Cc8umQLStDVDJ8NY28A (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:23 [2024-01-09 00:02:23,644] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Finished assignment for group at generation 1: {connector-consumer-iceberg-sink-0-dead1db0-8770-4d88-8a63-7dd28f4b15cb=Assignment(partitions=[postgres.public.students-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,655] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Successfully synced group in generation Generation{generationId=1, memberId='connector-consumer-iceberg-sink-0-dead1db0-8770-4d88-8a63-7dd28f4b15cb', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,656] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Notifying assignor about the new Assignment(partitions=[postgres.public.students-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,656] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Adding newly assigned partitions: postgres.public.students-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,683] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Found no committed offset for partition postgres.public.students-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:23 [2024-01-09 00:02:23,685] INFO [Consumer clientId=connector-consumer-iceberg-sink-0, groupId=connect-iceberg-sink] Resetting offset for partition postgres.public.students-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka:9092 (id: 1 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState)
2024-01-09 11:02:23 [2024-01-09 00:02:23,769] INFO Hadoop config initialized: org.apache.hadoop.conf.Configuration (io.tabular.iceberg.connect.data.Utilities)
2024-01-09 11:02:24 [2024-01-09 00:02:24,906] INFO Loading custom FileIO implementation: org.apache.iceberg.io.ResolvingFileIO (org.apache.iceberg.CatalogUtil)
2024-01-09 11:02:24 [2024-01-09 00:02:24,920] INFO AdminClientConfig values: 
2024-01-09 11:02:24     auto.include.jmx.reporter = true
2024-01-09 11:02:24     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:24     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:24     client.id = 
2024-01-09 11:02:24     connections.max.idle.ms = 300000
2024-01-09 11:02:24     default.api.timeout.ms = 60000
2024-01-09 11:02:24     metadata.max.age.ms = 300000
2024-01-09 11:02:24     metric.reporters = []
2024-01-09 11:02:24     metrics.num.samples = 2
2024-01-09 11:02:24     metrics.recording.level = INFO
2024-01-09 11:02:24     metrics.sample.window.ms = 30000
2024-01-09 11:02:24     receive.buffer.bytes = 65536
2024-01-09 11:02:24     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:24     reconnect.backoff.ms = 50
2024-01-09 11:02:24     request.timeout.ms = 30000
2024-01-09 11:02:24     retries = 2147483647
2024-01-09 11:02:24     retry.backoff.ms = 100
2024-01-09 11:02:24     sasl.client.callback.handler.class = null
2024-01-09 11:02:24     sasl.jaas.config = null
2024-01-09 11:02:24     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:24     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:24     sasl.kerberos.service.name = null
2024-01-09 11:02:24     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:24     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:24     sasl.login.callback.handler.class = null
2024-01-09 11:02:24     sasl.login.class = null
2024-01-09 11:02:24     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:24     sasl.login.read.timeout.ms = null
2024-01-09 11:02:24     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:24     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:24     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:24     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:24     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:24     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:24     sasl.mechanism = GSSAPI
2024-01-09 11:02:24     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:24     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:24     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:24     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:24     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:24     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:24     security.protocol = PLAINTEXT
2024-01-09 11:02:24     security.providers = null
2024-01-09 11:02:24     send.buffer.bytes = 131072
2024-01-09 11:02:24     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:24     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:24     ssl.cipher.suites = null
2024-01-09 11:02:24     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:24     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:24     ssl.engine.factory.class = null
2024-01-09 11:02:24     ssl.key.password = null
2024-01-09 11:02:24     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:24     ssl.keystore.certificate.chain = null
2024-01-09 11:02:24     ssl.keystore.key = null
2024-01-09 11:02:24     ssl.keystore.location = null
2024-01-09 11:02:24     ssl.keystore.password = null
2024-01-09 11:02:24     ssl.keystore.type = JKS
2024-01-09 11:02:24     ssl.protocol = TLSv1.3
2024-01-09 11:02:24     ssl.provider = null
2024-01-09 11:02:24     ssl.secure.random.implementation = null
2024-01-09 11:02:24     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:24     ssl.truststore.certificates = null
2024-01-09 11:02:24     ssl.truststore.location = null
2024-01-09 11:02:24     ssl.truststore.password = null
2024-01-09 11:02:24     ssl.truststore.type = JKS
2024-01-09 11:02:24  (org.apache.kafka.clients.admin.AdminClientConfig)
2024-01-09 11:02:24 [2024-01-09 00:02:24,923] WARN These configurations '[config.storage.topic, rest.advertised.host.name, group.id, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig)
2024-01-09 11:02:24 [2024-01-09 00:02:24,923] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,923] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,923] INFO Kafka startTimeMs: 1704758544923 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,956] INFO App info kafka.admin.client for adminclient-2 unregistered (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,958] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics)
2024-01-09 11:02:24 [2024-01-09 00:02:24,959] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics)
2024-01-09 11:02:24 [2024-01-09 00:02:24,959] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics)
2024-01-09 11:02:24 [2024-01-09 00:02:24,960] INFO Task elected leader, starting commit coordinator (io.tabular.iceberg.connect.IcebergSinkTask)
2024-01-09 11:02:24 [2024-01-09 00:02:24,968] INFO ProducerConfig values: 
2024-01-09 11:02:24     acks = -1
2024-01-09 11:02:24     auto.include.jmx.reporter = true
2024-01-09 11:02:24     batch.size = 16384
2024-01-09 11:02:24     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:24     buffer.memory = 33554432
2024-01-09 11:02:24     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:24     client.id = 74ad7f32-fa51-41bd-a137-5782d1354269
2024-01-09 11:02:24     compression.type = none
2024-01-09 11:02:24     connections.max.idle.ms = 540000
2024-01-09 11:02:24     delivery.timeout.ms = 120000
2024-01-09 11:02:24     enable.idempotence = true
2024-01-09 11:02:24     interceptor.classes = []
2024-01-09 11:02:24     key.serializer = class org.apache.kafka.common.serialization.StringSerializer
2024-01-09 11:02:24     linger.ms = 0
2024-01-09 11:02:24     max.block.ms = 60000
2024-01-09 11:02:24     max.in.flight.requests.per.connection = 5
2024-01-09 11:02:24     max.request.size = 1048576
2024-01-09 11:02:24     metadata.max.age.ms = 300000
2024-01-09 11:02:24     metadata.max.idle.ms = 300000
2024-01-09 11:02:24     metric.reporters = []
2024-01-09 11:02:24     metrics.num.samples = 2
2024-01-09 11:02:24     metrics.recording.level = INFO
2024-01-09 11:02:24     metrics.sample.window.ms = 30000
2024-01-09 11:02:24     partitioner.adaptive.partitioning.enable = true
2024-01-09 11:02:24     partitioner.availability.timeout.ms = 0
2024-01-09 11:02:24     partitioner.class = null
2024-01-09 11:02:24     partitioner.ignore.keys = false
2024-01-09 11:02:24     receive.buffer.bytes = 32768
2024-01-09 11:02:24     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:24     reconnect.backoff.ms = 50
2024-01-09 11:02:24     request.timeout.ms = 30000
2024-01-09 11:02:24     retries = 2147483647
2024-01-09 11:02:24     retry.backoff.ms = 100
2024-01-09 11:02:24     sasl.client.callback.handler.class = null
2024-01-09 11:02:24     sasl.jaas.config = null
2024-01-09 11:02:24     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:24     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:24     sasl.kerberos.service.name = null
2024-01-09 11:02:24     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:24     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:24     sasl.login.callback.handler.class = null
2024-01-09 11:02:24     sasl.login.class = null
2024-01-09 11:02:24     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:24     sasl.login.read.timeout.ms = null
2024-01-09 11:02:24     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:24     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:24     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:24     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:24     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:24     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:24     sasl.mechanism = GSSAPI
2024-01-09 11:02:24     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:24     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:24     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:24     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:24     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:24     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:24     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:24     security.protocol = PLAINTEXT
2024-01-09 11:02:24     security.providers = null
2024-01-09 11:02:24     send.buffer.bytes = 131072
2024-01-09 11:02:24     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:24     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:24     ssl.cipher.suites = null
2024-01-09 11:02:24     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:24     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:24     ssl.engine.factory.class = null
2024-01-09 11:02:24     ssl.key.password = null
2024-01-09 11:02:24     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:24     ssl.keystore.certificate.chain = null
2024-01-09 11:02:24     ssl.keystore.key = null
2024-01-09 11:02:24     ssl.keystore.location = null
2024-01-09 11:02:24     ssl.keystore.password = null
2024-01-09 11:02:24     ssl.keystore.type = JKS
2024-01-09 11:02:24     ssl.protocol = TLSv1.3
2024-01-09 11:02:24     ssl.provider = null
2024-01-09 11:02:24     ssl.secure.random.implementation = null
2024-01-09 11:02:24     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:24     ssl.truststore.certificates = null
2024-01-09 11:02:24     ssl.truststore.location = null
2024-01-09 11:02:24     ssl.truststore.password = null
2024-01-09 11:02:24     ssl.truststore.type = JKS
2024-01-09 11:02:24     transaction.timeout.ms = 60000
2024-01-09 11:02:24     transactional.id = coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0
2024-01-09 11:02:24     value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
2024-01-09 11:02:24  (org.apache.kafka.clients.producer.ProducerConfig)
2024-01-09 11:02:24 [2024-01-09 00:02:24,982] INFO [Producer clientId=74ad7f32-fa51-41bd-a137-5782d1354269, transactionalId=coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Instantiated a transactional producer. (org.apache.kafka.clients.producer.KafkaProducer)
2024-01-09 11:02:24 [2024-01-09 00:02:24,986] WARN These configurations '[config.storage.topic, rest.advertised.host.name, group.id, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig)
2024-01-09 11:02:24 [2024-01-09 00:02:24,986] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,986] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,986] INFO Kafka startTimeMs: 1704758544986 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:24 [2024-01-09 00:02:24,992] INFO [Producer clientId=74ad7f32-fa51-41bd-a137-5782d1354269, transactionalId=coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Invoking InitProducerId for the first time in order to acquire a producer ID (org.apache.kafka.clients.producer.internals.TransactionManager)
2024-01-09 11:02:24 [2024-01-09 00:02:24,998] INFO [Producer clientId=74ad7f32-fa51-41bd-a137-5782d1354269, transactionalId=coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Cluster ID: cRkIvkUsTXyqhcNw1EVhSA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:25 [2024-01-09 00:02:25,631] INFO [Producer clientId=74ad7f32-fa51-41bd-a137-5782d1354269, transactionalId=coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Discovered transaction coordinator kafka:9092 (id: 1 rack: null) (org.apache.kafka.clients.producer.internals.TransactionManager)
2024-01-09 11:02:25 [2024-01-09 00:02:25,771] INFO [Producer clientId=74ad7f32-fa51-41bd-a137-5782d1354269, transactionalId=coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] ProducerId set to 0 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager)
2024-01-09 11:02:25 [2024-01-09 00:02:25,773] INFO ConsumerConfig values: 
2024-01-09 11:02:25     allow.auto.create.topics = true
2024-01-09 11:02:25     auto.commit.interval.ms = 5000
2024-01-09 11:02:25     auto.include.jmx.reporter = true
2024-01-09 11:02:25     auto.offset.reset = latest
2024-01-09 11:02:25     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:25     check.crcs = true
2024-01-09 11:02:25     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:25     client.id = 44caf88d-0dec-4ffb-81d1-c7a82cc85a16
2024-01-09 11:02:25     client.rack = 
2024-01-09 11:02:25     connections.max.idle.ms = 540000
2024-01-09 11:02:25     default.api.timeout.ms = 60000
2024-01-09 11:02:25     enable.auto.commit = false
2024-01-09 11:02:25     exclude.internal.topics = true
2024-01-09 11:02:25     fetch.max.bytes = 52428800
2024-01-09 11:02:25     fetch.max.wait.ms = 500
2024-01-09 11:02:25     fetch.min.bytes = 1
2024-01-09 11:02:25     group.id = cg-control-iceberg-sink-coord
2024-01-09 11:02:25     group.instance.id = null
2024-01-09 11:02:25     heartbeat.interval.ms = 3000
2024-01-09 11:02:25     interceptor.classes = []
2024-01-09 11:02:25     internal.leave.group.on.close = true
2024-01-09 11:02:25     internal.throw.on.fetch.stable.offset.unsupported = false
2024-01-09 11:02:25     isolation.level = read_committed
2024-01-09 11:02:25     key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
2024-01-09 11:02:25     max.partition.fetch.bytes = 1048576
2024-01-09 11:02:25     max.poll.interval.ms = 300000
2024-01-09 11:02:25     max.poll.records = 500
2024-01-09 11:02:25     metadata.max.age.ms = 300000
2024-01-09 11:02:25     metric.reporters = []
2024-01-09 11:02:25     metrics.num.samples = 2
2024-01-09 11:02:25     metrics.recording.level = INFO
2024-01-09 11:02:25     metrics.sample.window.ms = 30000
2024-01-09 11:02:25     partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
2024-01-09 11:02:25     receive.buffer.bytes = 65536
2024-01-09 11:02:25     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:25     reconnect.backoff.ms = 50
2024-01-09 11:02:25     request.timeout.ms = 30000
2024-01-09 11:02:25     retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.client.callback.handler.class = null
2024-01-09 11:02:25     sasl.jaas.config = null
2024-01-09 11:02:25     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:25     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:25     sasl.kerberos.service.name = null
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.callback.handler.class = null
2024-01-09 11:02:25     sasl.login.class = null
2024-01-09 11:02:25     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:25     sasl.login.read.timeout.ms = null
2024-01-09 11:02:25     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:25     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:25     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:25     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.mechanism = GSSAPI
2024-01-09 11:02:25     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:25     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:25     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:25     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:25     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:25     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:25     security.protocol = PLAINTEXT
2024-01-09 11:02:25     security.providers = null
2024-01-09 11:02:25     send.buffer.bytes = 131072
2024-01-09 11:02:25     session.timeout.ms = 45000
2024-01-09 11:02:25     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:25     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:25     ssl.cipher.suites = null
2024-01-09 11:02:25     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:25     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:25     ssl.engine.factory.class = null
2024-01-09 11:02:25     ssl.key.password = null
2024-01-09 11:02:25     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:25     ssl.keystore.certificate.chain = null
2024-01-09 11:02:25     ssl.keystore.key = null
2024-01-09 11:02:25     ssl.keystore.location = null
2024-01-09 11:02:25     ssl.keystore.password = null
2024-01-09 11:02:25     ssl.keystore.type = JKS
2024-01-09 11:02:25     ssl.protocol = TLSv1.3
2024-01-09 11:02:25     ssl.provider = null
2024-01-09 11:02:25     ssl.secure.random.implementation = null
2024-01-09 11:02:25     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:25     ssl.truststore.certificates = null
2024-01-09 11:02:25     ssl.truststore.location = null
2024-01-09 11:02:25     ssl.truststore.password = null
2024-01-09 11:02:25     ssl.truststore.type = JKS
2024-01-09 11:02:25     value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2024-01-09 11:02:25  (org.apache.kafka.clients.consumer.ConsumerConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,778] WARN These configurations '[config.storage.topic, rest.advertised.host.name, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,779] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,779] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,779] INFO Kafka startTimeMs: 1704758545779 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,779] INFO AdminClientConfig values: 
2024-01-09 11:02:25     auto.include.jmx.reporter = true
2024-01-09 11:02:25     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:25     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:25     client.id = 
2024-01-09 11:02:25     connections.max.idle.ms = 300000
2024-01-09 11:02:25     default.api.timeout.ms = 60000
2024-01-09 11:02:25     metadata.max.age.ms = 300000
2024-01-09 11:02:25     metric.reporters = []
2024-01-09 11:02:25     metrics.num.samples = 2
2024-01-09 11:02:25     metrics.recording.level = INFO
2024-01-09 11:02:25     metrics.sample.window.ms = 30000
2024-01-09 11:02:25     receive.buffer.bytes = 65536
2024-01-09 11:02:25     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:25     reconnect.backoff.ms = 50
2024-01-09 11:02:25     request.timeout.ms = 30000
2024-01-09 11:02:25     retries = 2147483647
2024-01-09 11:02:25     retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.client.callback.handler.class = null
2024-01-09 11:02:25     sasl.jaas.config = null
2024-01-09 11:02:25     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:25     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:25     sasl.kerberos.service.name = null
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.callback.handler.class = null
2024-01-09 11:02:25     sasl.login.class = null
2024-01-09 11:02:25     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:25     sasl.login.read.timeout.ms = null
2024-01-09 11:02:25     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:25     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:25     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:25     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.mechanism = GSSAPI
2024-01-09 11:02:25     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:25     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:25     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:25     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:25     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:25     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:25     security.protocol = PLAINTEXT
2024-01-09 11:02:25     security.providers = null
2024-01-09 11:02:25     send.buffer.bytes = 131072
2024-01-09 11:02:25     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:25     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:25     ssl.cipher.suites = null
2024-01-09 11:02:25     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:25     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:25     ssl.engine.factory.class = null
2024-01-09 11:02:25     ssl.key.password = null
2024-01-09 11:02:25     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:25     ssl.keystore.certificate.chain = null
2024-01-09 11:02:25     ssl.keystore.key = null
2024-01-09 11:02:25     ssl.keystore.location = null
2024-01-09 11:02:25     ssl.keystore.password = null
2024-01-09 11:02:25     ssl.keystore.type = JKS
2024-01-09 11:02:25     ssl.protocol = TLSv1.3
2024-01-09 11:02:25     ssl.provider = null
2024-01-09 11:02:25     ssl.secure.random.implementation = null
2024-01-09 11:02:25     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:25     ssl.truststore.certificates = null
2024-01-09 11:02:25     ssl.truststore.location = null
2024-01-09 11:02:25     ssl.truststore.password = null
2024-01-09 11:02:25     ssl.truststore.type = JKS
2024-01-09 11:02:25  (org.apache.kafka.clients.admin.AdminClientConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,783] WARN These configurations '[config.storage.topic, rest.advertised.host.name, group.id, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,783] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,783] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,783] INFO Kafka startTimeMs: 1704758545783 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,803] INFO Starting commit worker (io.tabular.iceberg.connect.IcebergSinkTask)
2024-01-09 11:02:25 [2024-01-09 00:02:25,805] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Subscribed to topic(s): control-iceberg (org.apache.kafka.clients.consumer.KafkaConsumer)
2024-01-09 11:02:25 [2024-01-09 00:02:25,810] INFO ProducerConfig values: 
2024-01-09 11:02:25     acks = -1
2024-01-09 11:02:25     auto.include.jmx.reporter = true
2024-01-09 11:02:25     batch.size = 16384
2024-01-09 11:02:25     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:25     buffer.memory = 33554432
2024-01-09 11:02:25     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:25     client.id = adb3fb40-6303-46f9-a50f-87525973dc04
2024-01-09 11:02:25     compression.type = none
2024-01-09 11:02:25     connections.max.idle.ms = 540000
2024-01-09 11:02:25     delivery.timeout.ms = 120000
2024-01-09 11:02:25     enable.idempotence = true
2024-01-09 11:02:25     interceptor.classes = []
2024-01-09 11:02:25     key.serializer = class org.apache.kafka.common.serialization.StringSerializer
2024-01-09 11:02:25     linger.ms = 0
2024-01-09 11:02:25     max.block.ms = 60000
2024-01-09 11:02:25     max.in.flight.requests.per.connection = 5
2024-01-09 11:02:25     max.request.size = 1048576
2024-01-09 11:02:25     metadata.max.age.ms = 300000
2024-01-09 11:02:25     metadata.max.idle.ms = 300000
2024-01-09 11:02:25     metric.reporters = []
2024-01-09 11:02:25     metrics.num.samples = 2
2024-01-09 11:02:25     metrics.recording.level = INFO
2024-01-09 11:02:25     metrics.sample.window.ms = 30000
2024-01-09 11:02:25     partitioner.adaptive.partitioning.enable = true
2024-01-09 11:02:25     partitioner.availability.timeout.ms = 0
2024-01-09 11:02:25     partitioner.class = null
2024-01-09 11:02:25     partitioner.ignore.keys = false
2024-01-09 11:02:25     receive.buffer.bytes = 32768
2024-01-09 11:02:25     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:25     reconnect.backoff.ms = 50
2024-01-09 11:02:25     request.timeout.ms = 30000
2024-01-09 11:02:25     retries = 2147483647
2024-01-09 11:02:25     retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.client.callback.handler.class = null
2024-01-09 11:02:25     sasl.jaas.config = null
2024-01-09 11:02:25     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:25     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:25     sasl.kerberos.service.name = null
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.callback.handler.class = null
2024-01-09 11:02:25     sasl.login.class = null
2024-01-09 11:02:25     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:25     sasl.login.read.timeout.ms = null
2024-01-09 11:02:25     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:25     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:25     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:25     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.mechanism = GSSAPI
2024-01-09 11:02:25     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:25     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:25     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:25     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:25     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:25     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:25     security.protocol = PLAINTEXT
2024-01-09 11:02:25     security.providers = null
2024-01-09 11:02:25     send.buffer.bytes = 131072
2024-01-09 11:02:25     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:25     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:25     ssl.cipher.suites = null
2024-01-09 11:02:25     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:25     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:25     ssl.engine.factory.class = null
2024-01-09 11:02:25     ssl.key.password = null
2024-01-09 11:02:25     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:25     ssl.keystore.certificate.chain = null
2024-01-09 11:02:25     ssl.keystore.key = null
2024-01-09 11:02:25     ssl.keystore.location = null
2024-01-09 11:02:25     ssl.keystore.password = null
2024-01-09 11:02:25     ssl.keystore.type = JKS
2024-01-09 11:02:25     ssl.protocol = TLSv1.3
2024-01-09 11:02:25     ssl.provider = null
2024-01-09 11:02:25     ssl.secure.random.implementation = null
2024-01-09 11:02:25     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:25     ssl.truststore.certificates = null
2024-01-09 11:02:25     ssl.truststore.location = null
2024-01-09 11:02:25     ssl.truststore.password = null
2024-01-09 11:02:25     ssl.truststore.type = JKS
2024-01-09 11:02:25     transaction.timeout.ms = 60000
2024-01-09 11:02:25     transactional.id = worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0
2024-01-09 11:02:25     value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
2024-01-09 11:02:25  (org.apache.kafka.clients.producer.ProducerConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,811] INFO [Producer clientId=adb3fb40-6303-46f9-a50f-87525973dc04, transactionalId=worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Instantiated a transactional producer. (org.apache.kafka.clients.producer.KafkaProducer)
2024-01-09 11:02:25 [2024-01-09 00:02:25,816] WARN These configurations '[config.storage.topic, rest.advertised.host.name, group.id, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.producer.ProducerConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,816] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,817] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,817] INFO Kafka startTimeMs: 1704758545816 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,818] INFO [Producer clientId=adb3fb40-6303-46f9-a50f-87525973dc04, transactionalId=worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Invoking InitProducerId for the first time in order to acquire a producer ID (org.apache.kafka.clients.producer.internals.TransactionManager)
2024-01-09 11:02:25 [2024-01-09 00:02:25,823] INFO [Producer clientId=adb3fb40-6303-46f9-a50f-87525973dc04, transactionalId=worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Cluster ID: cRkIvkUsTXyqhcNw1EVhSA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:25 [2024-01-09 00:02:25,824] INFO [Producer clientId=adb3fb40-6303-46f9-a50f-87525973dc04, transactionalId=worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Discovered transaction coordinator kafka:9092 (id: 1 rack: null) (org.apache.kafka.clients.producer.internals.TransactionManager)
2024-01-09 11:02:25 [2024-01-09 00:02:25,827] WARN [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Error while fetching metadata with correlation id 2 : {control-iceberg=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
2024-01-09 11:02:25 [2024-01-09 00:02:25,827] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Cluster ID: cRkIvkUsTXyqhcNw1EVhSA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:25 [2024-01-09 00:02:25,827] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Discovered group coordinator kafka:9092 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,829] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,836] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Request joining group due to: need to re-join with the given member-id: 44caf88d-0dec-4ffb-81d1-c7a82cc85a16-dc8ea30c-4469-43fc-870e-01687bcec533 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,837] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,837] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,841] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Successfully joined group with generation Generation{generationId=1, memberId='44caf88d-0dec-4ffb-81d1-c7a82cc85a16-dc8ea30c-4469-43fc-870e-01687bcec533', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,931] INFO [Producer clientId=adb3fb40-6303-46f9-a50f-87525973dc04, transactionalId=worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] ProducerId set to 1 with epoch 0 (org.apache.kafka.clients.producer.internals.TransactionManager)
2024-01-09 11:02:25 [2024-01-09 00:02:25,931] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Resetting the last seen epoch of partition control-iceberg-0 to 0 since the associated topicId changed from null to dstNfdljTGCRFMQsp4j30A (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:25 [2024-01-09 00:02:25,932] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Finished assignment for group at generation 1: {44caf88d-0dec-4ffb-81d1-c7a82cc85a16-dc8ea30c-4469-43fc-870e-01687bcec533=Assignment(partitions=[control-iceberg-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,932] INFO ConsumerConfig values: 
2024-01-09 11:02:25     allow.auto.create.topics = true
2024-01-09 11:02:25     auto.commit.interval.ms = 5000
2024-01-09 11:02:25     auto.include.jmx.reporter = true
2024-01-09 11:02:25     auto.offset.reset = latest
2024-01-09 11:02:25     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:25     check.crcs = true
2024-01-09 11:02:25     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:25     client.id = b7d2d1ab-5e43-4c9c-a153-e856dcd865d2
2024-01-09 11:02:25     client.rack = 
2024-01-09 11:02:25     connections.max.idle.ms = 540000
2024-01-09 11:02:25     default.api.timeout.ms = 60000
2024-01-09 11:02:25     enable.auto.commit = false
2024-01-09 11:02:25     exclude.internal.topics = true
2024-01-09 11:02:25     fetch.max.bytes = 52428800
2024-01-09 11:02:25     fetch.max.wait.ms = 500
2024-01-09 11:02:25     fetch.min.bytes = 1
2024-01-09 11:02:25     group.id = cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa
2024-01-09 11:02:25     group.instance.id = null
2024-01-09 11:02:25     heartbeat.interval.ms = 3000
2024-01-09 11:02:25     interceptor.classes = []
2024-01-09 11:02:25     internal.leave.group.on.close = true
2024-01-09 11:02:25     internal.throw.on.fetch.stable.offset.unsupported = false
2024-01-09 11:02:25     isolation.level = read_committed
2024-01-09 11:02:25     key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
2024-01-09 11:02:25     max.partition.fetch.bytes = 1048576
2024-01-09 11:02:25     max.poll.interval.ms = 300000
2024-01-09 11:02:25     max.poll.records = 500
2024-01-09 11:02:25     metadata.max.age.ms = 300000
2024-01-09 11:02:25     metric.reporters = []
2024-01-09 11:02:25     metrics.num.samples = 2
2024-01-09 11:02:25     metrics.recording.level = INFO
2024-01-09 11:02:25     metrics.sample.window.ms = 30000
2024-01-09 11:02:25     partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor]
2024-01-09 11:02:25     receive.buffer.bytes = 65536
2024-01-09 11:02:25     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:25     reconnect.backoff.ms = 50
2024-01-09 11:02:25     request.timeout.ms = 30000
2024-01-09 11:02:25     retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.client.callback.handler.class = null
2024-01-09 11:02:25     sasl.jaas.config = null
2024-01-09 11:02:25     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:25     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:25     sasl.kerberos.service.name = null
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.callback.handler.class = null
2024-01-09 11:02:25     sasl.login.class = null
2024-01-09 11:02:25     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:25     sasl.login.read.timeout.ms = null
2024-01-09 11:02:25     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:25     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:25     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:25     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.mechanism = GSSAPI
2024-01-09 11:02:25     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:25     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:25     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:25     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:25     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:25     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:25     security.protocol = PLAINTEXT
2024-01-09 11:02:25     security.providers = null
2024-01-09 11:02:25     send.buffer.bytes = 131072
2024-01-09 11:02:25     session.timeout.ms = 45000
2024-01-09 11:02:25     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:25     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:25     ssl.cipher.suites = null
2024-01-09 11:02:25     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:25     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:25     ssl.engine.factory.class = null
2024-01-09 11:02:25     ssl.key.password = null
2024-01-09 11:02:25     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:25     ssl.keystore.certificate.chain = null
2024-01-09 11:02:25     ssl.keystore.key = null
2024-01-09 11:02:25     ssl.keystore.location = null
2024-01-09 11:02:25     ssl.keystore.password = null
2024-01-09 11:02:25     ssl.keystore.type = JKS
2024-01-09 11:02:25     ssl.protocol = TLSv1.3
2024-01-09 11:02:25     ssl.provider = null
2024-01-09 11:02:25     ssl.secure.random.implementation = null
2024-01-09 11:02:25     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:25     ssl.truststore.certificates = null
2024-01-09 11:02:25     ssl.truststore.location = null
2024-01-09 11:02:25     ssl.truststore.password = null
2024-01-09 11:02:25     ssl.truststore.type = JKS
2024-01-09 11:02:25     value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2024-01-09 11:02:25  (org.apache.kafka.clients.consumer.ConsumerConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,938] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Successfully synced group in generation Generation{generationId=1, memberId='44caf88d-0dec-4ffb-81d1-c7a82cc85a16-dc8ea30c-4469-43fc-870e-01687bcec533', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,938] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Notifying assignor about the new Assignment(partitions=[control-iceberg-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,938] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Adding newly assigned partitions: control-iceberg-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,939] WARN These configurations '[config.storage.topic, rest.advertised.host.name, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.consumer.ConsumerConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,939] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,939] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,939] INFO Kafka startTimeMs: 1704758545939 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,940] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Found no committed offset for partition control-iceberg-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,940] INFO AdminClientConfig values: 
2024-01-09 11:02:25     auto.include.jmx.reporter = true
2024-01-09 11:02:25     bootstrap.servers = [kafka:9092]
2024-01-09 11:02:25     client.dns.lookup = use_all_dns_ips
2024-01-09 11:02:25     client.id = 
2024-01-09 11:02:25     connections.max.idle.ms = 300000
2024-01-09 11:02:25     default.api.timeout.ms = 60000
2024-01-09 11:02:25     metadata.max.age.ms = 300000
2024-01-09 11:02:25     metric.reporters = []
2024-01-09 11:02:25     metrics.num.samples = 2
2024-01-09 11:02:25     metrics.recording.level = INFO
2024-01-09 11:02:25     metrics.sample.window.ms = 30000
2024-01-09 11:02:25     receive.buffer.bytes = 65536
2024-01-09 11:02:25     reconnect.backoff.max.ms = 1000
2024-01-09 11:02:25     reconnect.backoff.ms = 50
2024-01-09 11:02:25     request.timeout.ms = 30000
2024-01-09 11:02:25     retries = 2147483647
2024-01-09 11:02:25     retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.client.callback.handler.class = null
2024-01-09 11:02:25     sasl.jaas.config = null
2024-01-09 11:02:25     sasl.kerberos.kinit.cmd = /usr/bin/kinit
2024-01-09 11:02:25     sasl.kerberos.min.time.before.relogin = 60000
2024-01-09 11:02:25     sasl.kerberos.service.name = null
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.jitter = 0.05
2024-01-09 11:02:25     sasl.kerberos.ticket.renew.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.callback.handler.class = null
2024-01-09 11:02:25     sasl.login.class = null
2024-01-09 11:02:25     sasl.login.connect.timeout.ms = null
2024-01-09 11:02:25     sasl.login.read.timeout.ms = null
2024-01-09 11:02:25     sasl.login.refresh.buffer.seconds = 300
2024-01-09 11:02:25     sasl.login.refresh.min.period.seconds = 60
2024-01-09 11:02:25     sasl.login.refresh.window.factor = 0.8
2024-01-09 11:02:25     sasl.login.refresh.window.jitter = 0.05
2024-01-09 11:02:25     sasl.login.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.login.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.mechanism = GSSAPI
2024-01-09 11:02:25     sasl.oauthbearer.clock.skew.seconds = 30
2024-01-09 11:02:25     sasl.oauthbearer.expected.audience = null
2024-01-09 11:02:25     sasl.oauthbearer.expected.issuer = null
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
2024-01-09 11:02:25     sasl.oauthbearer.jwks.endpoint.url = null
2024-01-09 11:02:25     sasl.oauthbearer.scope.claim.name = scope
2024-01-09 11:02:25     sasl.oauthbearer.sub.claim.name = sub
2024-01-09 11:02:25     sasl.oauthbearer.token.endpoint.url = null
2024-01-09 11:02:25     security.protocol = PLAINTEXT
2024-01-09 11:02:25     security.providers = null
2024-01-09 11:02:25     send.buffer.bytes = 131072
2024-01-09 11:02:25     socket.connection.setup.timeout.max.ms = 30000
2024-01-09 11:02:25     socket.connection.setup.timeout.ms = 10000
2024-01-09 11:02:25     ssl.cipher.suites = null
2024-01-09 11:02:25     ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
2024-01-09 11:02:25     ssl.endpoint.identification.algorithm = https
2024-01-09 11:02:25     ssl.engine.factory.class = null
2024-01-09 11:02:25     ssl.key.password = null
2024-01-09 11:02:25     ssl.keymanager.algorithm = SunX509
2024-01-09 11:02:25     ssl.keystore.certificate.chain = null
2024-01-09 11:02:25     ssl.keystore.key = null
2024-01-09 11:02:25     ssl.keystore.location = null
2024-01-09 11:02:25     ssl.keystore.password = null
2024-01-09 11:02:25     ssl.keystore.type = JKS
2024-01-09 11:02:25     ssl.protocol = TLSv1.3
2024-01-09 11:02:25     ssl.provider = null
2024-01-09 11:02:25     ssl.secure.random.implementation = null
2024-01-09 11:02:25     ssl.trustmanager.algorithm = PKIX
2024-01-09 11:02:25     ssl.truststore.certificates = null
2024-01-09 11:02:25     ssl.truststore.location = null
2024-01-09 11:02:25     ssl.truststore.password = null
2024-01-09 11:02:25     ssl.truststore.type = JKS
2024-01-09 11:02:25  (org.apache.kafka.clients.admin.AdminClientConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,942] INFO [Consumer clientId=44caf88d-0dec-4ffb-81d1-c7a82cc85a16, groupId=cg-control-iceberg-sink-coord] Resetting offset for partition control-iceberg-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka:9092 (id: 1 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState)
2024-01-09 11:02:25 [2024-01-09 00:02:25,944] WARN These configurations '[config.storage.topic, rest.advertised.host.name, group.id, listeners.https.ssl.truststore.password, status.storage.topic, plugin.path, config.storage.replication.factor, rest.port, status.storage.retention.ms, listeners.https.ssl.truststore.location, status.storage.replication.factor, offset.storage.replication.factor, offset.storage.topic, value.converter, errors.log.enable, key.converter]' were supplied but are not used yet. (org.apache.kafka.clients.admin.AdminClientConfig)
2024-01-09 11:02:25 [2024-01-09 00:02:25,944] INFO Kafka version: 7.4.3-ccs (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,944] INFO Kafka commitId: 58bc41cd9d6c788aee9a08c455ec7578fe9a71f2 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,944] INFO Kafka startTimeMs: 1704758545944 (org.apache.kafka.common.utils.AppInfoParser)
2024-01-09 11:02:25 [2024-01-09 00:02:25,959] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Subscribed to topic(s): control-iceberg (org.apache.kafka.clients.consumer.KafkaConsumer)
2024-01-09 11:02:25 [2024-01-09 00:02:25,962] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Resetting the last seen epoch of partition control-iceberg-0 to 0 since the associated topicId changed from null to dstNfdljTGCRFMQsp4j30A (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:25 [2024-01-09 00:02:25,962] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Cluster ID: cRkIvkUsTXyqhcNw1EVhSA (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:25 [2024-01-09 00:02:25,962] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Discovered group coordinator kafka:9092 (id: 2147483646 rack: null) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,963] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,967] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Request joining group due to: need to re-join with the given member-id: b7d2d1ab-5e43-4c9c-a153-e856dcd865d2-81517ef9-02df-4d50-bda3-c2da35d80cdf (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,967] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,968] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] (Re-)joining group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,971] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Successfully joined group with generation Generation{generationId=1, memberId='b7d2d1ab-5e43-4c9c-a153-e856dcd865d2-81517ef9-02df-4d50-bda3-c2da35d80cdf', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,971] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Finished assignment for group at generation 1: {b7d2d1ab-5e43-4c9c-a153-e856dcd865d2-81517ef9-02df-4d50-bda3-c2da35d80cdf=Assignment(partitions=[control-iceberg-0])} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,975] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Successfully synced group in generation Generation{generationId=1, memberId='b7d2d1ab-5e43-4c9c-a153-e856dcd865d2-81517ef9-02df-4d50-bda3-c2da35d80cdf', protocol='range'} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,975] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Notifying assignor about the new Assignment(partitions=[control-iceberg-0]) (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,975] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Adding newly assigned partitions: control-iceberg-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,976] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Found no committed offset for partition control-iceberg-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
2024-01-09 11:02:25 [2024-01-09 00:02:25,980] INFO [Consumer clientId=b7d2d1ab-5e43-4c9c-a153-e856dcd865d2, groupId=cg-control-951226c8-9096-4270-9cb0-a4f4ffaabefa] Resetting offset for partition control-iceberg-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka:9092 (id: 1 rack: null)], epoch=0}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState)
2024-01-09 11:02:27 [2024-01-09 00:02:27,867] INFO Sending event of type: COMMIT_REQUEST (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:02:27 [2024-01-09 00:02:27,900] INFO [Producer clientId=74ad7f32-fa51-41bd-a137-5782d1354269, transactionalId=coordinator-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Resetting the last seen epoch of partition control-iceberg-0 to 0 since the associated topicId changed from null to dstNfdljTGCRFMQsp4j30A (org.apache.kafka.clients.Metadata)
2024-01-09 11:02:58 [2024-01-09 00:02:58,043] INFO Commit timeout reached (io.tabular.iceberg.connect.channel.CommitState)
2024-01-09 11:02:58 [2024-01-09 00:02:58,078] INFO Sending event of type: COMMIT_COMPLETE (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:02:58 [2024-01-09 00:02:58,088] INFO Commit 7a7bd05e-68d6-43ad-8069-27900d257018 complete, committed to 0 table(s), vtts null (io.tabular.iceberg.connect.channel.Coordinator)
2024-01-09 11:02:58 [2024-01-09 00:02:58,088] INFO Sending event of type: COMMIT_REQUEST (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:03:28 [2024-01-09 00:03:28,137] INFO Commit timeout reached (io.tabular.iceberg.connect.channel.CommitState)
2024-01-09 11:03:28 [2024-01-09 00:03:28,140] INFO Sending event of type: COMMIT_COMPLETE (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:03:28 [2024-01-09 00:03:28,145] INFO Commit e04c349b-7825-4ce3-a6d8-3b1d144f3b89 complete, committed to 0 table(s), vtts null (io.tabular.iceberg.connect.channel.Coordinator)
2024-01-09 11:03:28 [2024-01-09 00:03:28,145] INFO Sending event of type: COMMIT_REQUEST (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:03:58 [2024-01-09 00:03:58,198] INFO Commit timeout reached (io.tabular.iceberg.connect.channel.CommitState)
2024-01-09 11:03:58 [2024-01-09 00:03:58,205] INFO Sending event of type: COMMIT_COMPLETE (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:03:58 [2024-01-09 00:03:58,212] INFO Commit a8a430ea-64e8-4221-83ee-33cf50ccfad2 complete, committed to 0 table(s), vtts null (io.tabular.iceberg.connect.channel.Coordinator)
2024-01-09 11:03:58 [2024-01-09 00:03:58,212] INFO Sending event of type: COMMIT_REQUEST (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:07 [2024-01-09 00:04:07,899] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition control-iceberg-0 to 0 since the associated topicId changed from null to dstNfdljTGCRFMQsp4j30A (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-0 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-10 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-20 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-40 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-30 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-9 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-11 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-31 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-39 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-13 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-18 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-22 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-8 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-32 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-43 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-29 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-34 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-1 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-6 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-41 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-27 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-48 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-5 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-15 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-35 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-25 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-46 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-26 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,900] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-36 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-44 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-16 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-4 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-17 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-45 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-3 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-37 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-24 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-38 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-33 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-23 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-28 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-2 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-12 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-19 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-14 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-47 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-49 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-42 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,901] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-7 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,902] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition __transaction_state-21 to 0 since the associated topicId changed from null to JuItLHc-QA2J-YHJnrirYQ (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:07 [2024-01-09 00:04:07,902] INFO [Worker clientId=connect-1, groupId=1] Resetting the last seen epoch of partition postgres.public.students-0 to 0 since the associated topicId changed from null to wX7Cc8umQLStDVDJ8NY28A (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:23 [2024-01-09 00:04:23,456] INFO Sending event of type: COMMIT_READY (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:23 [2024-01-09 00:04:23,459] INFO [Producer clientId=adb3fb40-6303-46f9-a50f-87525973dc04, transactionalId=worker-txn-ed452209-8d01-4e9a-b8f6-8236fb65575a-0] Resetting the last seen epoch of partition control-iceberg-0 to 0 since the associated topicId changed from null to dstNfdljTGCRFMQsp4j30A (org.apache.kafka.clients.Metadata)
2024-01-09 11:04:23 [2024-01-09 00:04:23,465] INFO Handled event of type: COMMIT_REQUEST (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:23 [2024-01-09 00:04:23,467] INFO Sending event of type: COMMIT_READY (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:23 [2024-01-09 00:04:23,471] INFO Commit 7d00acd6-5398-4e56-bcc6-0cfae041d03e not ready, received responses for 0 of 1 partitions, waiting for more (io.tabular.iceberg.connect.channel.CommitState)
2024-01-09 11:04:23 [2024-01-09 00:04:23,471] INFO Handled event of type: COMMIT_READY (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:23 [2024-01-09 00:04:23,472] INFO Handled event of type: COMMIT_REQUEST (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:23 [2024-01-09 00:04:23,474] INFO Sending event of type: COMMIT_READY (io.tabular.iceberg.connect.channel.Channel)
2024-01-09 11:04:23 [2024-01-09 00:04:23,475] INFO Commit 7d00acd6-5398-4e56-bcc6-0cfae041d03e not ready, received responses for 0 of 1 partitions, waiting for more (io.tabular.iceberg.connect.channel.CommitState)