06/11/2026 02:30:20.225 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7385.364990, idle connection 528538.000000, request 304999.946117 06/11/2026 02:30:20.226 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9742.066162, idle connection 528536.000000, request 304997.141361 06/11/2026 02:30:20.227 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7383.331299, idle connection 528536.000000, request 304997.917652 06/11/2026 02:30:20.227 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0 06/11/2026 02:30:20.229 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 06/11/2026 02:30:20.229 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 06/11/2026 02:30:20.229 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.229 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2039325712, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.229 7fd1feee1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2244 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2039325712, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.229 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7382.939453, idle connection 528561.000000, request 304999.945164 06/11/2026 02:30:20.230 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7382.475098, idle connection 528561.000000, request 304999.485970 06/11/2026 02:30:20.266 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0 06/11/2026 02:30:20.266 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/11/2026 02:30:20.266 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/11/2026 02:30:20.266 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.266 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30173291, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.266 7fd1feee1680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2244 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30173291, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.267 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7347.016846, idle connection 529737.000000, request 304999.945641 06/11/2026 02:30:20.267 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7346.555664, idle connection 529737.000000, request 304999.491215 06/11/2026 02:30:20.267 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 06/11/2026 02:30:20.267 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/11/2026 02:30:20.267 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/11/2026 02:30:20.267 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.268 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=373424439, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.268 7fd1feee1400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2244 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=373424439, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.268 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7467.006348, idle connection 528532.000000, request 304999.959707 06/11/2026 02:30:20.268 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 324 06/11/2026 02:30:20.268 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 06/11/2026 02:30:20.268 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 06/11/2026 02:30:20.268 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.268 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183965112, session_epoch=2310, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.268 7fd1ff7b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2321 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183965112, session_epoch=2310, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.269 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298188.364258, idle connection 530944.000000, request 304999.961138 06/11/2026 02:30:20.269 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7465.864258, idle connection 528531.000000, request 304998.820305 06/11/2026 02:30:20.269 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 06/11/2026 02:30:20.269 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 06/11/2026 02:30:20.269 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 06/11/2026 02:30:20.269 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.269 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=606318921, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.270 7fd1feee1180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2244 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=606318921, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.270 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7618.551514, idle connection 528531.000000, request 304999.943972 06/11/2026 02:30:20.270 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2250 06/11/2026 02:30:20.270 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/11/2026 02:30:20.270 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/11/2026 02:30:20.270 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.270 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157500104, session_epoch=3120, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.270 7fd200cb9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 3130 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157500104, session_epoch=3120, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.271 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4830.525879, idle connection 528735.000000, request 304999.953270 06/11/2026 02:30:20.271 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298186.024658, idle connection 530942.000000, request 304997.621298 06/11/2026 02:30:20.272 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7616.861084, idle connection 528529.000000, request 304998.261929 06/11/2026 02:30:20.272 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4829.304199, idle connection 528734.000000, request 304998.738527 06/11/2026 02:30:20.327 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet 06/11/2026 02:30:20.327 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 529169.000000, request 303797.703743 06/11/2026 02:30:20.327 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2294 06/11/2026 02:30:20.327 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7 06/11/2026 02:30:20.328 7fd1ff7b7ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2294 (1203.2198905944824 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=1, host='10.0.0.129', port=9092, rack=None)], cluster_id='EWBz-0BZSi28XBUvB9XmlA', controller_id=1, topics=[(error_code=0, topic='-uve-topic-27', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=5, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=10, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=20, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=15, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=25, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=26, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=9, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=11, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=4, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=16, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=17, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=3, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=24, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=23, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=28, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=13, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=18, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=22, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=8, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=2, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=12, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=29, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=19, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=14, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=1, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=6, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=7, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=21, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=27, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[])])]) 06/11/2026 02:30:20.329 7fd1ff7b7ea0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 06/11/2026 02:30:20.345 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8388.364258, idle connection 529164.000000, request 304398.965597 06/11/2026 02:30:20.345 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2290 06/11/2026 02:30:20.345 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.345 7fd1feee1ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2290 (601.5684604644775 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=453021441, topics=[]) 06/11/2026 02:30:20.345 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 453021441 with 0 response partitions (1 implied) 06/11/2026 02:30:20.406 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 46 06/11/2026 02:30:20.406 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/11/2026 02:30:20.406 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/11/2026 02:30:20.406 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.406 7fd1ff7b79a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1067229596, session_epoch=2259, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.406 7fd1ff7b79a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1067229596, session_epoch=2259, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.407 7fd1ff7b79a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.009766, idle connection 528562.000000, request 304999.950171 06/11/2026 02:30:20.407 7fd1ff7b79a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.471924, idle connection 528562.000000, request 304999.421120 06/11/2026 02:30:20.420 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 46 06/11/2026 02:30:20.421 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 06/11/2026 02:30:20.421 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 06/11/2026 02:30:20.421 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.421 7fd1ff7b7400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36601420, session_epoch=2263, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.421 7fd1ff7b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2274 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36601420, session_epoch=2263, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.421 7fd1ff7b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.795898, idle connection 527366.000000, request 304999.936819 06/11/2026 02:30:20.422 7fd1ff7b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.964111, idle connection 527365.000000, request 304999.111176 06/11/2026 02:30:20.454 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 06/11/2026 02:30:20.455 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 06/11/2026 02:30:20.455 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 06/11/2026 02:30:20.455 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.455 7fd1fd076220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1552867353, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.455 7fd1fd076220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1552867353, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.456 7fd1fd076220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8785.359375, idle connection 527364.000000, request 304999.943495 06/11/2026 02:30:20.456 7fd1fd076220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8784.886230, idle connection 527363.000000, request 304999.478579 06/11/2026 02:30:20.511 7fd1ff7b7d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2476.241699, idle connection 527966.000000, request 304398.821592 06/11/2026 02:30:20.512 7fd1ff7b7d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2268 06/11/2026 02:30:20.512 7fd1ff7b7d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.512 7fd1ff7b7d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2268 (601.7701625823975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=699941890, topics=[]) 06/11/2026 02:30:20.512 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 699941890 with 0 response partitions (1 implied) 06/11/2026 02:30:20.517 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 06/11/2026 02:30:20.517 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 06/11/2026 02:30:20.517 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 06/11/2026 02:30:20.517 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.518 7fd1feee15e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1863247622, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.518 7fd1feee15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1863247622, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.518 7fd1feee15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8725.604004, idle connection 527362.000000, request 304999.950886 06/11/2026 02:30:20.518 7fd1feee15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8725.185791, idle connection 527362.000000, request 304999.538183 06/11/2026 02:30:20.550 7fd1ff7b77c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297590.020020, idle connection 528458.000000, request 304394.009590 06/11/2026 02:30:20.551 7fd1ff7b77c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2417 06/11/2026 02:30:20.551 7fd1ff7b77c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.551 7fd1ff7b77c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2417 (606.5728664398193 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=783867533, topics=[]) 06/11/2026 02:30:20.551 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 783867533 with 0 response partitions (1 implied) 06/11/2026 02:30:20.551 7fd1ff5ca040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4121.941406, idle connection 527963.000000, request 304394.128561 06/11/2026 02:30:20.552 7fd1ff5ca040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2337 06/11/2026 02:30:20.552 7fd1ff5ca040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.552 7fd1ff5ca040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2337 (606.3258647918701 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=408511562, topics=[]) 06/11/2026 02:30:20.552 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 408511562 with 0 response partitions (1 implied) 06/11/2026 02:30:20.568 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet 06/11/2026 02:30:20.569 7fd1ff7b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 529168.000000, request 304397.502899 06/11/2026 02:30:20.569 7fd1ff7b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2281 06/11/2026 02:30:20.569 7fd1ff7b7860 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7 06/11/2026 02:30:20.570 7fd1ff7b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2281 (603.4586429595947 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=1, host='10.0.0.129', port=9092, rack=None)], cluster_id='EWBz-0BZSi28XBUvB9XmlA', controller_id=1, topics=[(error_code=0, topic='-uve-topic-25', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=5, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=10, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=20, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=15, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=25, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=26, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=9, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=11, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=4, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=16, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=17, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=3, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=24, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=23, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=28, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=13, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=18, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=22, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=8, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=2, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=12, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=29, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=19, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=14, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=1, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=6, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=7, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=21, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[]), (error_code=0, partition=27, leader=1, leader_epoch=0, replicas=[1], isr=[1], offline_replicas=[])])]) 06/11/2026 02:30:20.571 7fd1ff7b7860 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 06/11/2026 02:30:20.573 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 06/11/2026 02:30:20.573 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/11/2026 02:30:20.573 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/11/2026 02:30:20.573 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.573 7fd1fd076040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=971569581, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.573 7fd1fd076040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2244 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=971569581, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.574 7fd1fd076040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6329.788574, idle connection 528567.000000, request 304999.956846 06/11/2026 02:30:20.574 7fd1fd076040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6329.390137, idle connection 528567.000000, request 304999.562979 06/11/2026 02:30:20.629 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 06/11/2026 02:30:20.629 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/11/2026 02:30:20.629 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/11/2026 02:30:20.629 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.629 7fd1fd04ed60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117462653, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.630 7fd1fd04ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2244 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117462653, session_epoch=2234, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.630 7fd1fd04ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6275.758789, idle connection 527335.000000, request 304999.933720 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30560615, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30560615, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.630 7fd1fd076180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8708.440918, idle connection 527335.000000, request 304999.962091 06/11/2026 02:30:20.631 7fd1fd04ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6274.620605, idle connection 527333.000000, request 304998.817682 06/11/2026 02:30:20.631 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 46 06/11/2026 02:30:20.631 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/11/2026 02:30:20.631 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/11/2026 02:30:20.631 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.631 7fd1ff7b7180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=284419117, session_epoch=2263, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.631 7fd1ff7b7180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2274 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=284419117, session_epoch=2263, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.632 7fd1ff7b7180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298189.251709, idle connection 528553.000000, request 304999.962807 06/11/2026 02:30:20.632 7fd1fd076180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8707.057129, idle connection 527333.000000, request 304998.581409 06/11/2026 02:30:20.632 7fd1ff7b7180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298188.530762, idle connection 528552.000000, request 304999.245405 06/11/2026 02:30:20.635 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 363 06/11/2026 02:30:20.635 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/11/2026 02:30:20.636 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/11/2026 02:30:20.636 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.636 7fd1ff7b75e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1425713251, session_epoch=2329, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.636 7fd1ff7b75e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1425713251, session_epoch=2329, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.636 7fd1ff7b75e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299399.037109, idle connection 528564.000000, request 304999.966621 06/11/2026 02:30:20.636 7fd1ff7b75e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.730469, idle connection 528563.000000, request 304999.662638 06/11/2026 02:30:20.677 7fd1fd04ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4198.482666, idle connection 526750.000000, request 304398.026466 06/11/2026 02:30:20.677 7fd1fd04ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2313 06/11/2026 02:30:20.677 7fd1fd04ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.677 7fd1fd04ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2313 (602.515459060669 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=881790586, topics=[]) 06/11/2026 02:30:20.677 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 881790586 with 0 response partitions (1 implied) 06/11/2026 02:30:20.806 7fd1ff7b72c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8530.973389, idle connection 529117.000000, request 304389.467001 06/11/2026 02:30:20.806 7fd1ff7b72c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2241 06/11/2026 02:30:20.807 7fd1ff7b72c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.807 7fd1ff7b72c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2241 (611.149787902832 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2053942270, topics=[]) 06/11/2026 02:30:20.807 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2053942270 with 0 response partitions (1 implied) 06/11/2026 02:30:20.807 7fd1feee1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9130.354004, idle connection 527911.000000, request 304389.418840 06/11/2026 02:30:20.807 7fd200c34ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5534.003662, idle connection 527912.000000, request 304389.917850 06/11/2026 02:30:20.807 7fd200c34f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7944.378418, idle connection 527912.000000, request 304390.403986 06/11/2026 02:30:20.808 7fd1feee1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2241 06/11/2026 02:30:20.808 7fd1feee1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.808 7fd1feee1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2241 (611.3796234130859 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=742630394, topics=[]) 06/11/2026 02:30:20.808 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 742630394 with 0 response partitions (1 implied) 06/11/2026 02:30:20.808 7fd200c34ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.808 7fd200c34ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.808 7fd200c34ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (611.3381385803223 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1126479230, topics=[]) 06/11/2026 02:30:20.809 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1126479230 with 0 response partitions (1 implied) 06/11/2026 02:30:20.809 7fd200c34f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2241 06/11/2026 02:30:20.809 7fd200c34f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.809 7fd200c34f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2241 (611.5257740020752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=809374272, topics=[]) 06/11/2026 02:30:20.809 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 809374272 with 0 response partitions (1 implied) 06/11/2026 02:30:20.823 7fd1feee1ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5528.117676, idle connection 527937.000000, request 304397.922039 06/11/2026 02:30:20.823 7fd1feee1ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.823 7fd1feee1ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.823 7fd1feee1ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (602.4894714355469 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1609785995, topics=[]) 06/11/2026 02:30:20.823 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1609785995 with 0 response partitions (1 implied) 06/11/2026 02:30:20.827 7fd1feee1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7933.343018, idle connection 527934.000000, request 304395.828962 06/11/2026 02:30:20.827 7fd1feee1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2241 06/11/2026 02:30:20.827 7fd1feee1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.827 7fd1feee1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2241 (604.5937538146973 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1125318911, topics=[]) 06/11/2026 02:30:20.827 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1125318911 with 0 response partitions (1 implied) 06/11/2026 02:30:20.827 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9140.834473, idle connection 527934.000000, request 304395.905972 06/11/2026 02:30:20.828 7fd1feee17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2241 06/11/2026 02:30:20.828 7fd1feee17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.828 7fd1feee17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2241 (604.4855117797852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1452566083, topics=[]) 06/11/2026 02:30:20.828 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1452566083 with 0 response partitions (1 implied) 06/11/2026 02:30:20.830 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6780.433350, idle connection 527933.000000, request 304395.020962 06/11/2026 02:30:20.830 7fd1fd0760e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.830 7fd1fd0760e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.830 7fd1fd0760e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (605.3178310394287 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1691829900, topics=[]) 06/11/2026 02:30:20.830 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1691829900 with 0 response partitions (1 implied) 06/11/2026 02:30:20.830 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6781.784668, idle connection 527960.000000, request 304398.789883 06/11/2026 02:30:20.831 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.831 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.831 7fd1feee1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (601.6013622283936 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2039325712, topics=[]) 06/11/2026 02:30:20.831 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2039325712 with 0 response partitions (1 implied) 06/11/2026 02:30:20.869 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6744.643799, idle connection 529135.000000, request 304397.569656 06/11/2026 02:30:20.869 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.869 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.870 7fd1feee1680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (603.1153202056885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=30173291, topics=[]) 06/11/2026 02:30:20.870 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 30173291 with 0 response partitions (1 implied) 06/11/2026 02:30:20.872 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6862.745850, idle connection 527928.000000, request 304395.698309 06/11/2026 02:30:20.872 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.872 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.872 7fd1feee1400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (604.6762466430664 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=373424439, topics=[]) 06/11/2026 02:30:20.873 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 373424439 with 0 response partitions (1 implied) 06/11/2026 02:30:20.873 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297583.701660, idle connection 530339.000000, request 304395.298243 06/11/2026 02:30:20.874 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2321 06/11/2026 02:30:20.874 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.874 7fd1ff7b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2321 (605.2517890930176 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183965112, topics=[]) 06/11/2026 02:30:20.874 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1183965112 with 0 response partitions (1 implied) 06/11/2026 02:30:20.874 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7014.191895, idle connection 527926.000000, request 304395.590544 06/11/2026 02:30:20.874 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4226.802246, idle connection 528132.000000, request 304396.235228 06/11/2026 02:30:20.874 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:20.875 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.875 7fd1feee1180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (604.8634052276611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=606318921, topics=[]) 06/11/2026 02:30:20.875 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 606318921 with 0 response partitions (1 implied) 06/11/2026 02:30:20.875 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3130 06/11/2026 02:30:20.875 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:20.875 7fd200cb9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 3130 (604.5901775360107 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=157500104, topics=[]) 06/11/2026 02:30:20.875 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 157500104 with 0 response partitions (1 implied) 06/11/2026 02:30:20.929 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 101 06/11/2026 02:30:20.930 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/11/2026 02:30:20.930 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/11/2026 02:30:20.930 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.930 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2050894431, session_epoch=2284, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.930 7fd1ff7b7ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2295 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2050894431, session_epoch=2284, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.931 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.086182, idle connection 528565.000000, request 304999.790907 06/11/2026 02:30:20.933 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299395.776123, idle connection 528563.000000, request 304997.493982 06/11/2026 02:30:20.946 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 97 06/11/2026 02:30:20.946 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/11/2026 02:30:20.946 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/11/2026 02:30:20.946 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:20.946 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=453021441, session_epoch=2281, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.946 7fd1feee1ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2291 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=453021441, session_epoch=2281, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:20.947 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7786.474121, idle connection 528562.000000, request 304999.948502 06/11/2026 02:30:20.947 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7786.011719, idle connection 528562.000000, request 304999.492884 06/11/2026 02:30:21.008 7fd1ff7b79a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298796.809570, idle connection 527961.000000, request 304398.750067 06/11/2026 02:30:21.008 7fd1ff7b79a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2270 06/11/2026 02:30:21.008 7fd1ff7b79a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.008 7fd1ff7b79a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2270 (601.8350124359131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1067229596, topics=[]) 06/11/2026 02:30:21.009 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1067229596 with 0 response partitions (1 implied) 06/11/2026 02:30:21.023 7fd1ff7b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298797.271484, idle connection 526764.000000, request 304398.412228 06/11/2026 02:30:21.023 7fd1ff7b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/11/2026 02:30:21.023 7fd1ff7b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.023 7fd1ff7b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (602.1392345428467 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=36601420, topics=[]) 06/11/2026 02:30:21.024 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 36601420 with 0 response partitions (1 implied) 06/11/2026 02:30:21.057 7fd1fd076220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8183.525879, idle connection 526762.000000, request 304398.108482 06/11/2026 02:30:21.058 7fd1fd076220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:21.058 7fd1fd076220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.058 7fd1fd076220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (602.7252674102783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1552867353, topics=[]) 06/11/2026 02:30:21.059 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1552867353 with 0 response partitions (1 implied) 06/11/2026 02:30:21.112 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 119 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=699941890, session_epoch=2259, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2269 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=699941890, session_epoch=2259, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1874.431152, idle connection 527364.000000, request 304999.949932 06/11/2026 02:30:21.113 7fd1ff7b7d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1874.006104, idle connection 527363.000000, request 304999.531507 06/11/2026 02:30:21.119 7fd1feee15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8124.330078, idle connection 526761.000000, request 304398.677111 06/11/2026 02:30:21.119 7fd1feee15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:21.120 7fd1feee15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.120 7fd1feee15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (601.7999649047852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1863247622, topics=[]) 06/11/2026 02:30:21.120 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1863247622 with 0 response partitions (1 implied) 06/11/2026 02:30:21.151 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 733 06/11/2026 02:30:21.152 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 06/11/2026 02:30:21.152 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 06/11/2026 02:30:21.152 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.152 7fd1ff7b77c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783867533, session_epoch=2407, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.152 7fd1ff7b77c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2418 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783867533, session_epoch=2407, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.152 7fd1ff7b77c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296988.000000, idle connection 527856.000000, request 304999.947786 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 411 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=408511562, session_epoch=2328, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=408511562, session_epoch=2328, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.153 7fd1ff5ca040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3519.990234, idle connection 527361.000000, request 304999.956131 06/11/2026 02:30:21.154 7fd1ff7b77c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296986.596191, idle connection 527855.000000, request 304998.553276 06/11/2026 02:30:21.154 7fd1ff5ca040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3519.021973, idle connection 527360.000000, request 304998.990774 06/11/2026 02:30:21.171 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 187 06/11/2026 02:30:21.171 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/11/2026 02:30:21.171 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/11/2026 02:30:21.171 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.172 7fd1ff7b7860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1763408849, session_epoch=2271, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.172 7fd1ff7b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2282 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1763408849, session_epoch=2271, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.172 7fd1ff7b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.861084, idle connection 528565.000000, request 304999.951363 06/11/2026 02:30:21.172 7fd1ff7b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.452637, idle connection 528564.000000, request 304999.551058 06/11/2026 02:30:21.175 7fd1fd076040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5728.822510, idle connection 527966.000000, request 304398.991823 06/11/2026 02:30:21.175 7fd1fd076040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:21.175 7fd1fd076040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.175 7fd1fd076040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (601.4928817749023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=971569581, topics=[]) 06/11/2026 02:30:21.175 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 971569581 with 0 response partitions (1 implied) 06/11/2026 02:30:21.232 7fd1fd04ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5673.144043, idle connection 526732.000000, request 304397.332191 06/11/2026 02:30:21.233 7fd1fd04ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2244 06/11/2026 02:30:21.233 7fd1fd04ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.233 7fd1fd04ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2244 (603.4934520721436 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1117462653, topics=[]) 06/11/2026 02:30:21.233 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1117462653 with 0 response partitions (1 implied) 06/11/2026 02:30:21.234 7fd1fd076180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8105.306641, idle connection 526731.000000, request 304396.826744 06/11/2026 02:30:21.234 7fd1ff7b7180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297586.985596, idle connection 527950.000000, request 304397.694111 06/11/2026 02:30:21.234 7fd1fd076180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:21.234 7fd1fd076180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.234 7fd1fd076180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (603.8200855255127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=30560615, topics=[]) 06/11/2026 02:30:21.234 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 30560615 with 0 response partitions (1 implied) 06/11/2026 02:30:21.235 7fd1ff7b7180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/11/2026 02:30:21.235 7fd1ff7b7180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.235 7fd1ff7b7180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (603.3844947814941 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=284419117, topics=[]) 06/11/2026 02:30:21.235 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 284419117 with 0 response partitions (1 implied) 06/11/2026 02:30:21.237 7fd1ff7b75e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298798.426270, idle connection 527963.000000, request 304399.355888 06/11/2026 02:30:21.237 7fd1ff7b75e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2340 06/11/2026 02:30:21.237 7fd1ff7b75e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.237 7fd1ff7b75e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2340 (601.0174751281738 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1425713251, topics=[]) 06/11/2026 02:30:21.237 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1425713251 with 0 response partitions (1 implied) 06/11/2026 02:30:21.278 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 341 06/11/2026 02:30:21.278 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/11/2026 02:30:21.278 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/11/2026 02:30:21.279 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.279 7fd1fd04ee00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=881790586, session_epoch=2304, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.279 7fd1fd04ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2314 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=881790586, session_epoch=2304, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.279 7fd1fd04ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3596.256348, idle connection 526148.000000, request 304999.942541 06/11/2026 02:30:21.279 7fd1fd04ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3595.769287, idle connection 526148.000000, request 304999.462605 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2053942270, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2053942270, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.409 7fd1ff7b72c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7927.544434, idle connection 528514.000000, request 304999.946594 06/11/2026 02:30:21.410 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0 06/11/2026 02:30:21.410 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/11/2026 02:30:21.410 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/11/2026 02:30:21.410 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.411 7fd1feee1f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742630394, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.411 7fd1feee1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742630394, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.411 7fd1feee1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8526.486572, idle connection 527307.000000, request 304999.935389 06/11/2026 02:30:21.411 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 06/11/2026 02:30:21.411 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/11/2026 02:30:21.411 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/11/2026 02:30:21.411 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.412 7fd200c34ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126479230, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.412 7fd200c34ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126479230, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.412 7fd200c34ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4929.215820, idle connection 527307.000000, request 304999.864817 06/11/2026 02:30:21.412 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 06/11/2026 02:30:21.412 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/11/2026 02:30:21.412 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/11/2026 02:30:21.413 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.413 7fd200c34f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=809374272, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.413 7fd200c34f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=809374272, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.413 7fd200c34f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7338.768311, idle connection 527307.000000, request 304999.958992 06/11/2026 02:30:21.413 7fd1ff7b72c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7923.542969, idle connection 528510.000000, request 304995.949984 06/11/2026 02:30:21.414 7fd1feee1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8523.510986, idle connection 527304.000000, request 304996.972322 06/11/2026 02:30:21.414 7fd200c34ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4926.940674, idle connection 527305.000000, request 304997.597218 06/11/2026 02:30:21.415 7fd200c34f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7337.036865, idle connection 527305.000000, request 304998.232603 06/11/2026 02:30:21.424 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1609785995, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1609785995, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4926.003906, idle connection 527335.000000, request 304999.955893 06/11/2026 02:30:21.425 7fd1feee1ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4925.623535, idle connection 527334.000000, request 304999.579191 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1125318911, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1125318911, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.428 7fd1feee1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7331.471924, idle connection 527333.000000, request 304999.959707 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1452566083, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2242 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1452566083, session_epoch=2232, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.429 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8539.052490, idle connection 527333.000000, request 304999.964476 06/11/2026 02:30:21.429 7fd1feee1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7330.447998, idle connection 527332.000000, request 304998.938799 06/11/2026 02:30:21.430 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8538.436523, idle connection 527332.000000, request 304999.351978 06/11/2026 02:30:21.433 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 06/11/2026 02:30:21.433 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 06/11/2026 02:30:21.433 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 06/11/2026 02:30:21.433 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.433 7fd1fd0760e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1691829900, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.434 7fd1fd0760e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1691829900, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.434 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6176.230469, idle connection 527328.000000, request 304999.962568 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2039325712, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2039325712, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.434 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6177.711182, idle connection 527356.000000, request 304999.965668 06/11/2026 02:30:21.435 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6175.256836, idle connection 527328.000000, request 304998.992443 06/11/2026 02:30:21.435 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6177.082031, idle connection 527356.000000, request 304999.339342 06/11/2026 02:30:21.470 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0 06/11/2026 02:30:21.470 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/11/2026 02:30:21.470 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/11/2026 02:30:21.471 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.471 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30173291, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.471 7fd1feee1680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30173291, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.471 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6142.677246, idle connection 528533.000000, request 304999.949694 06/11/2026 02:30:21.471 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6142.229736, idle connection 528533.000000, request 304999.508858 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=373424439, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=373424439, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.473 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6261.473877, idle connection 527327.000000, request 304999.962807 06/11/2026 02:30:21.474 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6261.149658, idle connection 527326.000000, request 304999.640942 06/11/2026 02:30:21.474 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 324 06/11/2026 02:30:21.474 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 06/11/2026 02:30:21.474 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 06/11/2026 02:30:21.474 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.474 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183965112, session_epoch=2311, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.475 7fd1ff7b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2322 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183965112, session_epoch=2311, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.475 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296982.262207, idle connection 529738.000000, request 304999.965191 06/11/2026 02:30:21.475 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296981.936523, idle connection 529737.000000, request 304999.642372 06/11/2026 02:30:21.475 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 06/11/2026 02:30:21.475 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 06/11/2026 02:30:21.475 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 06/11/2026 02:30:21.476 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.476 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=606318921, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.476 7fd1feee1180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=606318921, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.476 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6412.570801, idle connection 527325.000000, request 304999.961138 06/11/2026 02:30:21.476 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2250 06/11/2026 02:30:21.476 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/11/2026 02:30:21.476 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/11/2026 02:30:21.476 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.476 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157500104, session_epoch=3121, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.476 7fd200cb9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 3131 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157500104, session_epoch=3121, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.477 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3624.570312, idle connection 527529.000000, request 304999.965191 06/11/2026 02:30:21.477 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6411.507080, idle connection 527324.000000, request 304998.899937 06/11/2026 02:30:21.477 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3623.937500, idle connection 527529.000000, request 304999.335051 06/11/2026 02:30:21.534 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298795.295166, idle connection 527962.000000, request 304397.004128 06/11/2026 02:30:21.534 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2295 06/11/2026 02:30:21.534 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.534 7fd1ff7b7ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2295 (603.628396987915 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2050894431, topics=[]) 06/11/2026 02:30:21.534 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2050894431 with 0 response partitions (1 implied) 06/11/2026 02:30:21.547 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7185.585938, idle connection 527961.000000, request 304399.059772 06/11/2026 02:30:21.548 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2291 06/11/2026 02:30:21.548 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.548 7fd1feee1ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2291 (601.449728012085 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=453021441, topics=[]) 06/11/2026 02:30:21.548 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 453021441 with 0 response partitions (1 implied) 06/11/2026 02:30:21.609 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 46 06/11/2026 02:30:21.609 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/11/2026 02:30:21.609 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/11/2026 02:30:21.609 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.609 7fd1ff7b79a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1067229596, session_epoch=2260, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.610 7fd1ff7b79a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1067229596, session_epoch=2260, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.610 7fd1ff7b79a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.977051, idle connection 527359.000000, request 304999.948263 06/11/2026 02:30:21.610 7fd1ff7b79a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.507568, idle connection 527359.000000, request 304999.485970 06/11/2026 02:30:21.624 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 46 06/11/2026 02:30:21.624 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 06/11/2026 02:30:21.624 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 06/11/2026 02:30:21.624 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.624 7fd1ff7b7400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36601420, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.624 7fd1ff7b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36601420, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.625 7fd1ff7b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298195.392334, idle connection 526162.000000, request 304999.952316 06/11/2026 02:30:21.625 7fd1ff7b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.954102, idle connection 526162.000000, request 304999.519348 06/11/2026 02:30:21.659 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 06/11/2026 02:30:21.659 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 06/11/2026 02:30:21.659 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 06/11/2026 02:30:21.659 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.659 7fd1fd076220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1552867353, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.659 7fd1fd076220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1552867353, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.660 7fd1fd076220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7581.443604, idle connection 526160.000000, request 304999.950647 06/11/2026 02:30:21.660 7fd1fd076220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7581.013672, idle connection 526160.000000, request 304999.526978 06/11/2026 02:30:21.714 7fd1ff7b7d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1273.359131, idle connection 526763.000000, request 304398.876429 06/11/2026 02:30:21.790 7fd1ff7b7d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2269 06/11/2026 02:30:21.791 7fd1ff7b7d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.791 7fd1ff7b7d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2269 (677.6010990142822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=699941890, topics=[]) 06/11/2026 02:30:21.791 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 699941890 with 0 response partitions (1 implied) 06/11/2026 02:30:21.791 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 06/11/2026 02:30:21.791 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 06/11/2026 02:30:21.791 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 06/11/2026 02:30:21.791 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.791 7fd1feee15e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1863247622, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.793 7fd1feee15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1863247622, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.793 7fd1feee15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7450.429443, idle connection 526087.000000, request 304999.931812 06/11/2026 02:30:21.793 7fd1ff7b77c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296346.903320, idle connection 527215.000000, request 304358.858347 06/11/2026 02:30:21.794 7fd1ff5ca040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2879.668945, idle connection 526721.000000, request 304359.638453 06/11/2026 02:30:21.794 7fd1ff7b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298776.833740, idle connection 527943.000000, request 304377.929211 06/11/2026 02:30:21.794 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 06/11/2026 02:30:21.794 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/11/2026 02:30:21.794 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/11/2026 02:30:21.794 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.794 7fd1fd076040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=971569581, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.795 7fd1fd076040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=971569581, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.795 7fd1fd076040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5108.010498, idle connection 527345.000000, request 304999.956846 06/11/2026 02:30:21.796 7fd1ff7b77c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2418 06/11/2026 02:30:21.796 7fd1ff7b77c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.796 7fd1ff7b77c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2418 (643.7475681304932 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=783867533, topics=[]) 06/11/2026 02:30:21.796 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 783867533 with 0 response partitions (1 implied) 06/11/2026 02:30:21.797 7fd1ff5ca040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2338 06/11/2026 02:30:21.797 7fd1ff5ca040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.797 7fd1ff5ca040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2338 (643.7177658081055 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=408511562, topics=[]) 06/11/2026 02:30:21.797 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 408511562 with 0 response partitions (1 implied) 06/11/2026 02:30:21.798 7fd1ff7b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2282 06/11/2026 02:30:21.798 7fd1ff7b7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.798 7fd1ff7b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2282 (625.9949207305908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1763408849, topics=[]) 06/11/2026 02:30:21.798 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1763408849 with 0 response partitions (1 implied) 06/11/2026 02:30:21.799 7fd1feee15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7444.863525, idle connection 526082.000000, request 304994.371414 06/11/2026 02:30:21.799 7fd1fd076040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5104.372070, idle connection 527342.000000, request 304996.322632 06/11/2026 02:30:21.834 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 06/11/2026 02:30:21.834 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/11/2026 02:30:21.834 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/11/2026 02:30:21.834 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.834 7fd1fd04ed60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117462653, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.835 7fd1fd04ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117462653, session_epoch=2235, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.835 7fd1fd04ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5070.711182, idle connection 526129.000000, request 304999.935627 06/11/2026 02:30:21.835 7fd1fd04ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5070.214600, idle connection 526129.000000, request 304999.446630 06/11/2026 02:30:21.835 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 06/11/2026 02:30:21.836 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/11/2026 02:30:21.836 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/11/2026 02:30:21.836 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.836 7fd1fd076180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30560615, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.836 7fd1fd076180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30560615, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.836 7fd1fd076180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7502.860840, idle connection 526129.000000, request 304999.961853 06/11/2026 02:30:21.836 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 46 06/11/2026 02:30:21.836 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/11/2026 02:30:21.836 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/11/2026 02:30:21.837 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.837 7fd1ff7b7180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=284419117, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.837 7fd1ff7b7180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=284419117, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.837 7fd1ff7b7180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296983.918701, idle connection 527347.000000, request 304999.962568 06/11/2026 02:30:21.837 7fd1fd076180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7501.670898, idle connection 526128.000000, request 304998.774290 06/11/2026 02:30:21.838 7fd1ff7b7180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296982.964355, idle connection 527346.000000, request 304999.011517 06/11/2026 02:30:21.838 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 363 06/11/2026 02:30:21.838 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/11/2026 02:30:21.838 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/11/2026 02:30:21.839 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:21.839 7fd1ff7b75e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1425713251, session_epoch=2330, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.839 7fd1ff7b75e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1425713251, session_epoch=2330, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:21.839 7fd1ff7b75e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298196.050293, idle connection 527361.000000, request 304999.962568 06/11/2026 02:30:21.839 7fd1ff7b75e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298195.745117, idle connection 527360.000000, request 304999.660492 06/11/2026 02:30:21.881 7fd1fd04ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2994.544922, idle connection 525546.000000, request 304398.231268 06/11/2026 02:30:21.881 7fd1fd04ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2314 06/11/2026 02:30:21.881 7fd1fd04ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:21.881 7fd1fd04ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2314 (602.501630783081 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=881790586, topics=[]) 06/11/2026 02:30:21.882 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 881790586 with 0 response partitions (1 implied) 06/11/2026 02:30:22.015 7fd1ff7b72c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7321.789795, idle connection 527908.000000, request 304394.187212 06/11/2026 02:30:22.016 7fd1ff7b72c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:22.016 7fd1ff7b72c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.016 7fd1ff7b72c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (606.4276695251465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2053942270, topics=[]) 06/11/2026 02:30:22.016 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2053942270 with 0 response partitions (1 implied) 06/11/2026 02:30:22.016 7fd1feee1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7921.040283, idle connection 526702.000000, request 304394.496679 06/11/2026 02:30:22.017 7fd200c34ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4324.682129, idle connection 526702.000000, request 304395.337582 06/11/2026 02:30:22.017 7fd200c34f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6735.048096, idle connection 526703.000000, request 304396.242380 06/11/2026 02:30:22.017 7fd1feee1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:22.017 7fd1feee1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.017 7fd1feee1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (606.2002182006836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=742630394, topics=[]) 06/11/2026 02:30:22.017 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 742630394 with 0 response partitions (1 implied) 06/11/2026 02:30:22.017 7fd200c34ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.018 7fd200c34ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.018 7fd200c34ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (605.7310104370117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1126479230, topics=[]) 06/11/2026 02:30:22.018 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1126479230 with 0 response partitions (1 implied) 06/11/2026 02:30:22.018 7fd200c34f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:22.018 7fd200c34f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.018 7fd200c34f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (605.327844619751 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=809374272, topics=[]) 06/11/2026 02:30:22.018 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 809374272 with 0 response partitions (1 implied) 06/11/2026 02:30:22.026 7fd1feee1ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4325.133545, idle connection 526734.000000, request 304399.080276 06/11/2026 02:30:22.026 7fd1feee1ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.026 7fd1feee1ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.026 7fd1feee1ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (601.4797687530518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1609785995, topics=[]) 06/11/2026 02:30:22.027 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1609785995 with 0 response partitions (1 implied) 06/11/2026 02:30:22.030 7fd1feee1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6729.758789, idle connection 526731.000000, request 304398.244619 06/11/2026 02:30:22.030 7fd1feee1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:22.030 7fd1feee1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.031 7fd1feee1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (602.1780967712402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1125318911, topics=[]) 06/11/2026 02:30:22.031 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1125318911 with 0 response partitions (1 implied) 06/11/2026 02:30:22.031 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7937.214600, idle connection 526731.000000, request 304398.125648 06/11/2026 02:30:22.031 7fd1feee17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2242 06/11/2026 02:30:22.031 7fd1feee17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.031 7fd1feee17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2242 (602.2303104400635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1452566083, topics=[]) 06/11/2026 02:30:22.031 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1452566083 with 0 response partitions (1 implied) 06/11/2026 02:30:22.035 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5574.482910, idle connection 526727.000000, request 304398.213863 06/11/2026 02:30:22.036 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5576.393066, idle connection 526755.000000, request 304398.648024 06/11/2026 02:30:22.036 7fd1fd0760e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.036 7fd1fd0760e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.036 7fd1fd0760e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (602.4148464202881 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1691829900, topics=[]) 06/11/2026 02:30:22.036 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1691829900 with 0 response partitions (1 implied) 06/11/2026 02:30:22.036 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.037 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.037 7fd1feee1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (602.4572849273682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2039325712, topics=[]) 06/11/2026 02:30:22.037 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2039325712 with 0 response partitions (1 implied) 06/11/2026 02:30:22.072 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5541.721680, idle connection 527932.000000, request 304398.989201 06/11/2026 02:30:22.072 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.072 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.073 7fd1feee1680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (601.6290187835693 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=30173291, topics=[]) 06/11/2026 02:30:22.073 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 30173291 with 0 response partitions (1 implied) 06/11/2026 02:30:22.074 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5660.756348, idle connection 526726.000000, request 304399.242640 06/11/2026 02:30:22.074 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.074 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.075 7fd1feee1400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (601.224422454834 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=373424439, topics=[]) 06/11/2026 02:30:22.075 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 373424439 with 0 response partitions (1 implied) 06/11/2026 02:30:22.076 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296380.783447, idle connection 529136.000000, request 304398.484468 06/11/2026 02:30:22.076 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2322 06/11/2026 02:30:22.077 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.077 7fd1ff7b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2322 (601.9227504730225 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183965112, topics=[]) 06/11/2026 02:30:22.077 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1183965112 with 0 response partitions (1 implied) 06/11/2026 02:30:22.077 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5810.934082, idle connection 526723.000000, request 304398.323774 06/11/2026 02:30:22.078 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.078 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.078 7fd1feee1180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (602.043867111206 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=606318921, topics=[]) 06/11/2026 02:30:22.078 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 606318921 with 0 response partitions (1 implied) 06/11/2026 02:30:22.078 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3022.922607, idle connection 526928.000000, request 304398.318052 06/11/2026 02:30:22.078 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3131 06/11/2026 02:30:22.078 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.079 7fd200cb9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 3131 (602.027416229248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=157500104, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2251, last_stable_offset=2251, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x08\xca\x00\x00\x00\xfb\x00\x00\x00\x00\x02\xf5~\xc2f\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x90\x03\x00\x00\x00\xd2\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/11/2026 02:30:22.079 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 157500104 with 1 response partitions (0 implied) 06/11/2026 02:30:22.079 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 263 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2250 06/11/2026 02:30:22.079 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2250 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/11/2026 02:30:22.079 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 2251 (leader epoch 0) 06/11/2026 02:30:22.135 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 101 06/11/2026 02:30:22.135 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/11/2026 02:30:22.135 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/11/2026 02:30:22.135 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.135 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2050894431, session_epoch=2285, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.136 7fd1ff7b7ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2296 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2050894431, session_epoch=2285, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.136 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.131836, idle connection 527360.000000, request 304999.928474 06/11/2026 02:30:22.136 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298192.641113, idle connection 527359.000000, request 304999.446630 06/11/2026 02:30:22.149 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 97 06/11/2026 02:30:22.149 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/11/2026 02:30:22.149 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/11/2026 02:30:22.149 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.149 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=453021441, session_epoch=2282, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.150 7fd1feee1ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2292 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=453021441, session_epoch=2282, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.150 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6583.285156, idle connection 527359.000000, request 304999.931097 06/11/2026 02:30:22.150 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6582.578369, idle connection 527358.000000, request 304999.235153 06/11/2026 02:30:22.180 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2251 06/11/2026 02:30:22.180 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/11/2026 02:30:22.180 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/11/2026 02:30:22.180 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.180 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157500104, session_epoch=3122, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2251, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/11/2026 02:30:22.180 7fd200cb9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 3132 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157500104, session_epoch=3122, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2251, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/11/2026 02:30:22.181 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2920.479492, idle connection 526825.000000, request 304999.947786 06/11/2026 02:30:22.181 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2919.980225, idle connection 526825.000000, request 304999.456882 06/11/2026 02:30:22.211 7fd1ff7b79a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297593.997070, idle connection 526758.000000, request 304398.967981 06/11/2026 02:30:22.211 7fd1ff7b79a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2271 06/11/2026 02:30:22.211 7fd1ff7b79a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.211 7fd1ff7b79a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2271 (601.621150970459 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1067229596, topics=[]) 06/11/2026 02:30:22.211 7fd1ff7b79a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1067229596 with 0 response partitions (1 implied) 06/11/2026 02:30:22.293 7fd1ff7b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297526.532471, idle connection 525493.000000, request 304331.088781 06/11/2026 02:30:22.294 7fd1ff7b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/11/2026 02:30:22.294 7fd1ff7b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.294 7fd1ff7b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (669.5382595062256 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=36601420, topics=[]) 06/11/2026 02:30:22.294 7fd1ff7b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 36601420 with 0 response partitions (1 implied) 06/11/2026 02:30:22.294 7fd1fd076220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6946.458740, idle connection 525525.000000, request 304364.969969 06/11/2026 02:30:22.295 7fd1fd076220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2243 06/11/2026 02:30:22.295 7fd1fd076220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.295 7fd1fd076220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2243 (635.4122161865234 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1552867353, topics=[]) 06/11/2026 02:30:22.295 7fd1fd076220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1552867353 with 0 response partitions (1 implied) 06/11/2026 02:30:22.391 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 119 06/11/2026 02:30:22.391 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/11/2026 02:30:22.392 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/11/2026 02:30:22.392 7fd1ff7b7d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.392 7fd1ff7b7d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=699941890, session_epoch=2260, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.392 7fd1ff7b7d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=699941890, session_epoch=2260, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.392 7fd1ff7b7d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 595.474365, idle connection 526085.000000, request 304999.948263 06/11/2026 02:30:22.393 7fd1ff7b7d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 594.953369, idle connection 526084.000000, request 304999.434948 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 733 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783867533, session_epoch=2408, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2419 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783867533, session_epoch=2408, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.397 7fd1ff7b77c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295743.041260, idle connection 526611.000000, request 304999.957561 06/11/2026 02:30:22.398 7fd1ff7b77c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295742.681396, idle connection 526611.000000, request 304999.601603 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 411 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=408511562, session_epoch=2329, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=408511562, session_epoch=2329, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.398 7fd1ff5ca040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2274.914062, idle connection 526116.000000, request 304999.960899 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 187 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1763408849, session_epoch=2272, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2283 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1763408849, session_epoch=2272, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.399 7fd1ff7b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298171.628906, idle connection 527338.000000, request 304999.966145 06/11/2026 02:30:22.399 7fd1ff5ca040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2273.860107, idle connection 526115.000000, request 304998.909950 06/11/2026 02:30:22.400 7fd1feee15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6843.906250, idle connection 525481.000000, request 304393.418312 06/11/2026 02:30:22.400 7fd1fd076040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4503.646484, idle connection 526741.000000, request 304395.596266 06/11/2026 02:30:22.400 7fd1ff7b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298170.666748, idle connection 527337.000000, request 304999.006271 06/11/2026 02:30:22.400 7fd1feee15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2243 06/11/2026 02:30:22.400 7fd1feee15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.401 7fd1feee15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2243 (607.508659362793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1863247622, topics=[]) 06/11/2026 02:30:22.401 7fd1feee15e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1863247622 with 0 response partitions (1 implied) 06/11/2026 02:30:22.401 7fd1fd076040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.401 7fd1fd076040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.401 7fd1fd076040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (605.748176574707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=971569581, topics=[]) 06/11/2026 02:30:22.401 7fd1fd076040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 971569581 with 0 response partitions (1 implied) 06/11/2026 02:30:22.437 7fd1fd04ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4468.944092, idle connection 525528.000000, request 304398.169041 06/11/2026 02:30:22.437 7fd1fd04ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2245 06/11/2026 02:30:22.437 7fd1fd04ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.437 7fd1fd04ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2245 (602.4830341339111 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1117462653, topics=[]) 06/11/2026 02:30:22.437 7fd1fd04ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1117462653 with 0 response partitions (1 implied) 06/11/2026 02:30:22.438 7fd1fd076180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6900.730713, idle connection 525527.000000, request 304397.830486 06/11/2026 02:30:22.438 7fd1fd076180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2243 06/11/2026 02:30:22.438 7fd1fd076180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.439 7fd1fd076180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2243 (602.5495529174805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=30560615, topics=[]) 06/11/2026 02:30:22.439 7fd1fd076180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 30560615 with 0 response partitions (1 implied) 06/11/2026 02:30:22.439 7fd1ff7b7180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296381.876465, idle connection 526745.000000, request 304397.921324 06/11/2026 02:30:22.439 7fd1ff7b7180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/11/2026 02:30:22.439 7fd1ff7b7180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.439 7fd1ff7b7180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (602.4465560913086 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=284419117, topics=[]) 06/11/2026 02:30:22.439 7fd1ff7b7180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 284419117 with 0 response partitions (1 implied) 06/11/2026 02:30:22.440 7fd1ff7b75e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297595.260986, idle connection 526760.000000, request 304399.173260 06/11/2026 02:30:22.440 7fd1ff7b75e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2341 06/11/2026 02:30:22.440 7fd1ff7b75e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.440 7fd1ff7b75e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2341 (601.1810302734375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1425713251, topics=[]) 06/11/2026 02:30:22.440 7fd1ff7b75e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1425713251 with 0 response partitions (1 implied) 06/11/2026 02:30:22.483 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 341 06/11/2026 02:30:22.483 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/11/2026 02:30:22.483 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/11/2026 02:30:22.483 7fd1fd04ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.483 7fd1fd04ee00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=881790586, session_epoch=2305, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.483 7fd1fd04ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2315 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=881790586, session_epoch=2305, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.484 7fd1fd04ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2391.609619, idle connection 524943.000000, request 304999.935389 06/11/2026 02:30:22.484 7fd1fd04ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2391.040039, idle connection 524943.000000, request 304999.372482 06/11/2026 02:30:22.617 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0 06/11/2026 02:30:22.618 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/11/2026 02:30:22.618 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/11/2026 02:30:22.618 7fd1ff7b72c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.618 7fd1ff7b72c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2053942270, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.618 7fd1ff7b72c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2053942270, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.618 7fd1ff7b72c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6718.572998, idle connection 527305.000000, request 304999.923229 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742630394, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742630394, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.619 7fd1feee1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7318.190674, idle connection 526099.000000, request 304999.957323 06/11/2026 02:30:22.619 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 06/11/2026 02:30:22.620 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/11/2026 02:30:22.620 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/11/2026 02:30:22.620 7fd200c34ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.620 7fd200c34ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126479230, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.620 7fd200c34ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126479230, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.620 7fd200c34ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3721.034912, idle connection 526099.000000, request 304999.944687 06/11/2026 02:30:22.620 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 06/11/2026 02:30:22.620 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/11/2026 02:30:22.620 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/11/2026 02:30:22.621 7fd200c34f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.621 7fd200c34f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=809374272, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.621 7fd200c34f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=809374272, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.621 7fd200c34f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6130.876709, idle connection 526099.000000, request 304999.964714 06/11/2026 02:30:22.621 7fd1ff7b72c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6715.744385, idle connection 527302.000000, request 304997.124195 06/11/2026 02:30:22.622 7fd1feee1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7315.726318, idle connection 526096.000000, request 304997.498274 06/11/2026 02:30:22.622 7fd200c34ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3719.132080, idle connection 526097.000000, request 304998.050213 06/11/2026 02:30:22.622 7fd200c34f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6129.262939, idle connection 526097.000000, request 304998.353958 06/11/2026 02:30:22.628 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0 06/11/2026 02:30:22.628 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/11/2026 02:30:22.628 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/11/2026 02:30:22.628 7fd1feee1ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.629 7fd1feee1ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1609785995, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.629 7fd1feee1ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1609785995, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.629 7fd1feee1ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3722.132324, idle connection 526131.000000, request 304999.949694 06/11/2026 02:30:22.629 7fd1feee1ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3721.667725, idle connection 526130.000000, request 304999.489784 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1125318911, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1125318911, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.632 7fd1feee1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6127.356445, idle connection 526128.000000, request 304999.954462 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1452566083, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2243 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1452566083, session_epoch=2233, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.633 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7334.931885, idle connection 526128.000000, request 304999.951124 06/11/2026 02:30:22.634 7fd1feee1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6126.131836, idle connection 526127.000000, request 304998.728514 06/11/2026 02:30:22.634 7fd1feee17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7334.010010, idle connection 526128.000000, request 304999.036551 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1691829900, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1691829900, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.637 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4972.556152, idle connection 526125.000000, request 304999.959707 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2039325712, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2039325712, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.638 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4973.805420, idle connection 526152.000000, request 304999.951124 06/11/2026 02:30:22.639 7fd1fd0760e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4971.284424, idle connection 526124.000000, request 304998.691082 06/11/2026 02:30:22.639 7fd1feee1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4973.000244, idle connection 526152.000000, request 304999.150276 06/11/2026 02:30:22.673 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0 06/11/2026 02:30:22.673 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/11/2026 02:30:22.673 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/11/2026 02:30:22.673 7fd1feee1680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.674 7fd1feee1680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30173291, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.674 7fd1feee1680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=30173291, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.674 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4939.723877, idle connection 527330.000000, request 304999.942541 06/11/2026 02:30:22.674 7fd1feee1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4939.185791, idle connection 527330.000000, request 304999.413967 06/11/2026 02:30:22.675 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 06/11/2026 02:30:22.675 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/11/2026 02:30:22.675 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/11/2026 02:30:22.675 7fd1feee1400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.675 7fd1feee1400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=373424439, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.675 7fd1feee1400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=373424439, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.676 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5059.296143, idle connection 526124.000000, request 304999.957800 06/11/2026 02:30:22.676 7fd1feee1400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5058.936279, idle connection 526124.000000, request 304999.600172 06/11/2026 02:30:22.677 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 324 06/11/2026 02:30:22.677 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 06/11/2026 02:30:22.677 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 06/11/2026 02:30:22.677 7fd1ff7b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.677 7fd1ff7b7b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183965112, session_epoch=2312, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.678 7fd1ff7b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2323 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183965112, session_epoch=2312, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.678 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295779.225342, idle connection 528535.000000, request 304999.935865 06/11/2026 02:30:22.678 7fd1ff7b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295778.801025, idle connection 528534.000000, request 304999.519587 06/11/2026 02:30:22.678 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 06/11/2026 02:30:22.678 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 06/11/2026 02:30:22.679 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 06/11/2026 02:30:22.679 7fd1feee1180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/11/2026 02:30:22.679 7fd1feee1180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=606318921, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.679 7fd1feee1180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=606318921, session_epoch=2236, topics=[], forgotten_topics_data=[]) 06/11/2026 02:30:22.679 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5209.429199, idle connection 526122.000000, request 304999.947786 06/11/2026 02:30:22.679 7fd1feee1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5208.958740, idle connection 526121.000000, request 304999.484539 06/11/2026 02:30:22.737 7fd1ff7b7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297592.109619, idle connection 526759.000000, request 304398.907900 06/11/2026 02:30:22.737 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2296 06/11/2026 02:30:22.737 7fd1ff7b7ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.737 7fd1ff7b7ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2296 (601.6368865966797 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2050894431, topics=[]) 06/11/2026 02:30:22.738 7fd1ff7b7ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2050894431 with 0 response partitions (1 implied) 06/11/2026 02:30:22.751 7fd1feee1ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5982.102295, idle connection 526758.000000, request 304398.752213 06/11/2026 02:30:22.751 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2292 06/11/2026 02:30:22.751 7fd1feee1ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.751 7fd1feee1ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2292 (601.6979217529297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=453021441, topics=[]) 06/11/2026 02:30:22.752 7fd1feee1ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 453021441 with 0 response partitions (1 implied) 06/11/2026 02:30:22.782 7fd200cb9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2319.520020, idle connection 526224.000000, request 304398.988724 06/11/2026 02:30:22.782 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3132 06/11/2026 02:30:22.782 7fd200cb9400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/11/2026 02:30:22.782 7fd200cb9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 3132 (601.5560626983643 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=157500104, topics=[]) 06/11/2026 02:30:22.782 7fd200cb9400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 157500104 with 0 response partitions (1 implied)