12/04/2025 02:27:43.945 7fa13f45a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 754 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1927942566, session_epoch=750, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:43.946 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85429.747070, idle connection 263041.000000, request 304999.939203 12/04/2025 02:27:43.947 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85429.257812, idle connection 263040.000000, request 304999.461174 12/04/2025 02:27:43.981 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 28 12/04/2025 02:27:43.981 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 12/04/2025 02:27:43.981 7fa140971b80 [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)]) 12/04/2025 02:27:43.981 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:43.981 7fa140971b80 [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=274107694, session_epoch=683, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:43.981 7fa140971b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=274107694, session_epoch=683, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:43.981 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85091.315674, idle connection 262098.000000, request 304999.946356 12/04/2025 02:27:43.982 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85090.950684, idle connection 262098.000000, request 304999.588490 12/04/2025 02:27:43.983 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85035.086670, idle connection 262641.000000, request 304397.576571 12/04/2025 02:27:43.984 7fa140971e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 709 12/04/2025 02:27:43.984 7fa140971e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:43.984 7fa140971e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 709 (602.7951240539551 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1411295424, topics=[]) 12/04/2025 02:27:43.984 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1411295424 with 0 response partitions (1 implied) 12/04/2025 02:27:43.984 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85007.158447, idle connection 263014.000000, request 304397.516966 12/04/2025 02:27:43.985 7fa13d3b0720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 12/04/2025 02:27:43.985 7fa13d3b0720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:43.985 7fa13d3b0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (602.7991771697998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1034165134, topics=[]) 12/04/2025 02:27:43.985 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1034165134 with 0 response partitions (1 implied) 12/04/2025 02:27:43.985 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84539.528809, idle connection 262156.000000, request 304397.465229 12/04/2025 02:27:43.985 7fa1409717c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 705 12/04/2025 02:27:43.985 7fa1409717c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:43.985 7fa1409717c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 705 (602.8285026550293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2021726156, topics=[]) 12/04/2025 02:27:43.985 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2021726156 with 0 response partitions (1 implied) 12/04/2025 02:27:44.080 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84821.712402, idle connection 262664.000000, request 304399.150848 12/04/2025 02:27:44.080 7fa140971860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 12/04/2025 02:27:44.080 7fa140971860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.080 7fa140971860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 694 (601.365327835083 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=622416178, topics=[]) 12/04/2025 02:27:44.080 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 622416178 with 0 response partitions (1 implied) 12/04/2025 02:27:44.083 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84530.374023, idle connection 262229.000000, request 304398.364544 12/04/2025 02:27:44.083 7fa13d490e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 12/04/2025 02:27:44.083 7fa13d490e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.083 7fa13d490e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.9542217254639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=21050150, topics=[]) 12/04/2025 02:27:44.083 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 21050150 with 0 response partitions (1 implied) 12/04/2025 02:27:44.083 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 359 12/04/2025 02:27:44.083 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/04/2025 02:27:44.084 7fa140971c20 [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)]) 12/04/2025 02:27:44.084 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.084 7fa140971c20 [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=1723932039, session_epoch=740, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.084 7fa140971c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 744 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1723932039, session_epoch=740, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.084 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85334.797607, idle connection 262616.000000, request 304999.950409 12/04/2025 02:27:44.084 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85334.380127, idle connection 262615.000000, request 304999.547243 12/04/2025 02:27:44.174 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 63 12/04/2025 02:27:44.174 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 12/04/2025 02:27:44.175 7fa13da7c2c0 [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)]) 12/04/2025 02:27:44.175 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.175 7fa13da7c2c0 [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=1394563909, session_epoch=688, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.175 7fa13da7c2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394563909, session_epoch=688, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.175 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85039.744873, idle connection 262238.000000, request 304999.953508 12/04/2025 02:27:44.175 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85039.367676, idle connection 262238.000000, request 304999.583244 12/04/2025 02:27:44.176 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 19 12/04/2025 02:27:44.176 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 12/04/2025 02:27:44.176 7fa140971040 [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)]) 12/04/2025 02:27:44.176 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.176 7fa140971040 [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=1260842402, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.176 7fa140971040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1260842402, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.176 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83863.957764, idle connection 262508.000000, request 304999.965191 12/04/2025 02:27:44.176 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83863.673340, idle connection 262508.000000, request 304999.682665 12/04/2025 02:27:44.177 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 130 12/04/2025 02:27:44.177 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 12/04/2025 02:27:44.177 7fa13f45a720 [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)]) 12/04/2025 02:27:44.177 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.177 7fa13f45a720 [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=1013433983, session_epoch=702, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.177 7fa13f45a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 706 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1013433983, session_epoch=702, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.177 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84909.997803, idle connection 262116.000000, request 304999.966145 12/04/2025 02:27:44.177 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84909.725342, idle connection 262115.000000, request 304999.696255 12/04/2025 02:27:44.178 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 26 12/04/2025 02:27:44.179 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/04/2025 02:27:44.179 7fa140971400 [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)]) 12/04/2025 02:27:44.179 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.179 7fa140971400 [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=1802323540, session_epoch=687, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.179 7fa140971400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1802323540, session_epoch=687, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.179 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83961.466553, idle connection 261807.000000, request 304999.967575 12/04/2025 02:27:44.179 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84694.927490, idle connection 262641.000000, request 304398.232698 12/04/2025 02:27:44.179 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83961.063477, idle connection 261807.000000, request 304999.567032 12/04/2025 02:27:44.180 7fa13d4907c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 12/04/2025 02:27:44.180 7fa13d4907c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.180 7fa13d4907c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (602.3285388946533 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=636053439, topics=[]) 12/04/2025 02:27:44.180 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 636053439 with 0 response partitions (1 implied) 12/04/2025 02:27:44.186 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83836.512207, idle connection 261670.000000, request 304399.021864 12/04/2025 02:27:44.186 7fa13d632ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 12/04/2025 02:27:44.186 7fa13d632ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.186 7fa13d632ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 720 (601.3238430023193 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=731615446, topics=[]) 12/04/2025 02:27:44.187 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 731615446 with 0 response partitions (1 implied) 12/04/2025 02:27:44.188 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 12/04/2025 02:27:44.188 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 12/04/2025 02:27:44.188 7fa13d4909a0 [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)]) 12/04/2025 02:27:44.189 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.189 7fa13d4909a0 [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=1403412451, session_epoch=677, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.189 7fa13d4909a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1403412451, session_epoch=677, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.189 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83919.899658, idle connection 262580.000000, request 304999.966145 12/04/2025 02:27:44.189 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83919.606689, idle connection 262579.000000, request 304999.675512 12/04/2025 02:27:44.196 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83736.411621, idle connection 262053.000000, request 304399.311304 12/04/2025 02:27:44.196 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1026 12/04/2025 02:27:44.196 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.197 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1026 (601.0074615478516 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=265308676, topics=[]) 12/04/2025 02:27:44.197 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 265308676 with 0 response partitions (1 implied) 12/04/2025 02:27:44.283 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85181.633789, idle connection 261887.000000, request 304399.133921 12/04/2025 02:27:44.283 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742 12/04/2025 02:27:44.283 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.283 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 742 (601.3858318328857 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=716602182, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=290, last_stable_offset=290, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01 \x00\x00\x02\x17\x00\x00\x00\x00\x02\xf37\xd0\xca\x00\x00\x00\x00\x00\x01\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\x02\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 12/04/2025 02:27:44.283 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 716602182 with 1 response partitions (0 implied) 12/04/2025 02:27:44.284 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 288 12/04/2025 02:27:44.284 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 288 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) 12/04/2025 02:27:44.284 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 290 (leader epoch 0) 12/04/2025 02:27:44.286 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84095.325195, idle connection 261521.000000, request 304399.305344 12/04/2025 02:27:44.287 7fa13da5d2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 12/04/2025 02:27:44.287 7fa13da5d2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.287 7fa13da5d2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 686 (601.0317802429199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=410778758, topics=[]) 12/04/2025 02:27:44.287 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 410778758 with 0 response partitions (1 implied) 12/04/2025 02:27:44.340 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 47 12/04/2025 02:27:44.341 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/04/2025 02:27:44.341 7fa140971f40 [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)]) 12/04/2025 02:27:44.341 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.341 7fa140971f40 [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=1323793449, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.341 7fa140971f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1323793449, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.341 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84474.668701, idle connection 262209.000000, request 304999.949932 12/04/2025 02:27:44.341 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84474.259033, idle connection 262209.000000, request 304999.548435 12/04/2025 02:27:44.343 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 164 12/04/2025 02:27:44.343 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/04/2025 02:27:44.343 7fa13f45ac20 [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)]) 12/04/2025 02:27:44.343 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.343 7fa13f45ac20 [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=1207096404, session_epoch=714, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.344 7fa13f45ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 718 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1207096404, session_epoch=714, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.344 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84927.506104, idle connection 262666.000000, request 304999.963045 12/04/2025 02:27:44.344 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84927.196045, idle connection 262666.000000, request 304999.656200 12/04/2025 02:27:44.384 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 290 12/04/2025 02:27:44.385 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/04/2025 02:27:44.385 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-27', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 12/04/2025 02:27:44.385 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.385 7fa13f45a540 [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=716602182, session_epoch=739, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=290, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/04/2025 02:27:44.385 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 743 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=716602182, session_epoch=739, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=290, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/04/2025 02:27:44.385 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85079.221680, idle connection 261785.000000, request 304999.951363 12/04/2025 02:27:44.386 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85078.822021, idle connection 261784.000000, request 304999.558449 12/04/2025 02:27:44.407 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84865.762451, idle connection 262591.000000, request 304399.098635 12/04/2025 02:27:44.407 7fa140971220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 702 12/04/2025 02:27:44.407 7fa140971220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.408 7fa140971220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 702 (601.3107299804688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=67958313, topics=[]) 12/04/2025 02:27:44.408 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 67958313 with 0 response partitions (1 implied) 12/04/2025 02:27:44.466 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84380.321289, idle connection 262710.000000, request 304399.078369 12/04/2025 02:27:44.466 7fa13f45a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 740 12/04/2025 02:27:44.466 7fa13f45a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.466 7fa13f45a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 740 (601.3691425323486 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=310805383, topics=[]) 12/04/2025 02:27:44.466 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 310805383 with 0 response partitions (1 implied) 12/04/2025 02:27:44.484 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199 12/04/2025 02:27:44.484 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/04/2025 02:27:44.484 7fa13f45a0e0 [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)]) 12/04/2025 02:27:44.484 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.484 7fa13f45a0e0 [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=268076184, session_epoch=719, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.485 7fa13f45a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=268076184, session_epoch=719, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.485 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84442.304688, idle connection 261686.000000, request 304999.954224 12/04/2025 02:27:44.485 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84441.925781, idle connection 261685.000000, request 304999.581575 12/04/2025 02:27:44.488 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84403.216309, idle connection 261808.000000, request 304399.261951 12/04/2025 02:27:44.488 7fa13da7c720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 12/04/2025 02:27:44.488 7fa13da7c720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.488 7fa13da7c720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (601.0911464691162 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1649154843, topics=[]) 12/04/2025 02:27:44.488 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1649154843 with 0 response partitions (1 implied) 12/04/2025 02:27:44.492 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84488.448486, idle connection 261886.000000, request 304397.736549 12/04/2025 02:27:44.493 7fa13d490400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 12/04/2025 02:27:44.493 7fa13d490400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.493 7fa13d490400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 691 (602.5831699371338 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1269968249, topics=[]) 12/04/2025 02:27:44.493 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1269968249 with 0 response partitions (1 implied) 12/04/2025 02:27:44.493 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84491.267578, idle connection 261892.000000, request 304397.794724 12/04/2025 02:27:44.493 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83293.537842, idle connection 261919.000000, request 304398.612261 12/04/2025 02:27:44.493 7fa13d632d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 12/04/2025 02:27:44.493 7fa13d632d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.493 7fa13d632d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 681 (602.5867462158203 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=404048884, topics=[]) 12/04/2025 02:27:44.493 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 404048884 with 0 response partitions (1 implied) 12/04/2025 02:27:44.494 7fa13d632c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 12/04/2025 02:27:44.494 7fa13d632c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.494 7fa13d632c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 681 (602.0755767822266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=806440775, topics=[]) 12/04/2025 02:27:44.494 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 806440775 with 0 response partitions (1 implied) 12/04/2025 02:27:44.494 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 27 12/04/2025 02:27:44.494 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/04/2025 02:27:44.494 7fa140971360 [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)]) 12/04/2025 02:27:44.494 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.494 7fa140971360 [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=2097179136, session_epoch=683, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.494 7fa140971360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2097179136, session_epoch=683, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.495 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84116.600098, idle connection 261890.000000, request 304999.963999 12/04/2025 02:27:44.495 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 91 12/04/2025 02:27:44.495 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 12/04/2025 02:27:44.495 7fa1409719a0 [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)]) 12/04/2025 02:27:44.495 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.495 7fa1409719a0 [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=936803464, session_epoch=695, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.495 7fa1409719a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 699 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=936803464, session_epoch=695, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.495 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84487.658447, idle connection 261884.000000, request 304999.967337 12/04/2025 02:27:44.495 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84115.697754, idle connection 261889.000000, request 304999.064445 12/04/2025 02:27:44.496 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 109 12/04/2025 02:27:44.496 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 12/04/2025 02:27:44.496 7fa13f45acc0 [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)]) 12/04/2025 02:27:44.496 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.496 7fa13f45acc0 [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=1570595728, session_epoch=701, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.496 7fa13f45acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 705 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1570595728, session_epoch=701, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.496 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84460.357910, idle connection 262186.000000, request 304999.966383 12/04/2025 02:27:44.496 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84486.485352, idle connection 261883.000000, request 304998.796225 12/04/2025 02:27:44.497 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84459.693115, idle connection 262186.000000, request 304999.304771 12/04/2025 02:27:44.547 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84828.787598, idle connection 262440.000000, request 304398.982763 12/04/2025 02:27:44.549 7fa13f45a220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 754 12/04/2025 02:27:44.549 7fa13f45a220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.550 7fa13f45a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 754 (603.2543182373047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927942566, topics=[]) 12/04/2025 02:27:44.550 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927942566 with 0 response partitions (1 implied) 12/04/2025 02:27:44.582 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84490.560303, idle connection 261498.000000, request 304399.188042 12/04/2025 02:27:44.582 7fa140971b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 12/04/2025 02:27:44.582 7fa140971b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.583 7fa140971b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (601.3035774230957 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=274107694, topics=[]) 12/04/2025 02:27:44.583 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 274107694 with 0 response partitions (1 implied) 12/04/2025 02:27:44.585 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 150 12/04/2025 02:27:44.585 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/04/2025 02:27:44.585 7fa140971e00 [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)]) 12/04/2025 02:27:44.585 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.585 7fa140971e00 [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=1411295424, session_epoch=706, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.585 7fa140971e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 710 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1411295424, session_epoch=706, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.586 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84432.781738, idle connection 262039.000000, request 304999.941826 12/04/2025 02:27:44.586 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 42 12/04/2025 02:27:44.586 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 12/04/2025 02:27:44.586 7fa13d3b0720 [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)]) 12/04/2025 02:27:44.586 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.586 7fa13d3b0720 [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=1034165134, session_epoch=690, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.586 7fa13d3b0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1034165134, session_epoch=690, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.586 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84405.129883, idle connection 262412.000000, request 304999.964237 12/04/2025 02:27:44.587 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 108 12/04/2025 02:27:44.587 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/04/2025 02:27:44.587 7fa1409717c0 [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)]) 12/04/2025 02:27:44.587 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.587 7fa1409717c0 [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=2021726156, session_epoch=702, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.587 7fa1409717c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 706 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2021726156, session_epoch=702, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.587 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83937.368408, idle connection 261554.000000, request 304999.964476 12/04/2025 02:27:44.588 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84430.904785, idle connection 262037.000000, request 304998.072863 12/04/2025 02:27:44.588 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84403.666260, idle connection 262411.000000, request 304998.503923 12/04/2025 02:27:44.588 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83936.341309, idle connection 261553.000000, request 304998.940468 12/04/2025 02:27:44.681 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 12/04/2025 02:27:44.681 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 12/04/2025 02:27:44.681 7fa140971860 [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)]) 12/04/2025 02:27:44.681 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.681 7fa140971860 [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=622416178, session_epoch=691, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.681 7fa140971860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=622416178, session_epoch=691, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.681 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84220.022217, idle connection 262063.000000, request 304999.952316 12/04/2025 02:27:44.682 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84219.583252, idle connection 262062.000000, request 304999.520302 12/04/2025 02:27:44.683 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 25 12/04/2025 02:27:44.684 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 12/04/2025 02:27:44.684 7fa13d490e00 [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)]) 12/04/2025 02:27:44.684 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.684 7fa13d490e00 [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=21050150, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.684 7fa13d490e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=21050150, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.684 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83929.208252, idle connection 261628.000000, request 304999.962091 12/04/2025 02:27:44.684 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83928.907227, idle connection 261628.000000, request 304999.663591 12/04/2025 02:27:44.685 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84734.107910, idle connection 262015.000000, request 304399.275780 12/04/2025 02:27:44.685 7fa140971c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 744 12/04/2025 02:27:44.685 7fa140971c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.685 7fa140971c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 744 (601.0570526123047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1723932039, topics=[]) 12/04/2025 02:27:44.685 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1723932039 with 0 response partitions (1 implied) 12/04/2025 02:27:44.776 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84438.812256, idle connection 261637.000000, request 304399.008989 12/04/2025 02:27:44.777 7fa13da7c2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 12/04/2025 02:27:44.777 7fa13da7c2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.777 7fa13da7c2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 692 (602.0498275756836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394563909, topics=[]) 12/04/2025 02:27:44.777 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394563909 with 0 response partitions (1 implied) 12/04/2025 02:27:44.777 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83262.557861, idle connection 261907.000000, request 304398.562431 12/04/2025 02:27:44.778 7fa140971040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 12/04/2025 02:27:44.778 7fa140971040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.778 7fa140971040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.7744541168213 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1260842402, topics=[]) 12/04/2025 02:27:44.778 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1260842402 with 0 response partitions (1 implied) 12/04/2025 02:27:44.778 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84309.051025, idle connection 261515.000000, request 304399.018526 12/04/2025 02:27:44.778 7fa13f45a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 706 12/04/2025 02:27:44.778 7fa13f45a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.778 7fa13f45a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 706 (601.2768745422363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1013433983, topics=[]) 12/04/2025 02:27:44.779 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1013433983 with 0 response partitions (1 implied) 12/04/2025 02:27:44.780 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 6 12/04/2025 02:27:44.780 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 12/04/2025 02:27:44.780 7fa13d4907c0 [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)]) 12/04/2025 02:27:44.780 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.780 7fa13d4907c0 [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=636053439, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.780 7fa13d4907c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=636053439, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.781 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84093.293701, idle connection 262040.000000, request 304999.945641 12/04/2025 02:27:44.781 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83359.405029, idle connection 261205.000000, request 304397.904634 12/04/2025 02:27:44.781 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84092.633789, idle connection 262039.000000, request 304999.290705 12/04/2025 02:27:44.782 7fa140971400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 12/04/2025 02:27:44.782 7fa140971400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.782 7fa140971400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 691 (602.9336452484131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1802323540, topics=[]) 12/04/2025 02:27:44.782 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1802323540 with 0 response partitions (1 implied) 12/04/2025 02:27:44.787 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 12/04/2025 02:27:44.787 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/04/2025 02:27:44.787 7fa13d632ea0 [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)]) 12/04/2025 02:27:44.787 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.788 7fa13d632ea0 [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=731615446, session_epoch=717, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.788 7fa13d632ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 721 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=731615446, session_epoch=717, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.788 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83234.733643, idle connection 261069.000000, request 304999.952078 12/04/2025 02:27:44.788 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83234.324707, idle connection 261068.000000, request 304999.548197 12/04/2025 02:27:44.790 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83318.416992, idle connection 261978.000000, request 304398.481846 12/04/2025 02:27:44.791 7fa13d4909a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 12/04/2025 02:27:44.791 7fa13d4909a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.791 7fa13d4909a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 681 (601.931095123291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1403412451, topics=[]) 12/04/2025 02:27:44.791 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1403412451 with 0 response partitions (1 implied) 12/04/2025 02:27:44.798 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3748 12/04/2025 02:27:44.799 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/04/2025 02:27:44.799 7fa13d3dbae0 [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)]) 12/04/2025 02:27:44.799 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.799 7fa13d3dbae0 [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=265308676, session_epoch=1023, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.799 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1027 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=265308676, session_epoch=1023, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.799 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83133.496094, idle connection 261450.000000, request 304999.944925 12/04/2025 02:27:44.800 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83132.986084, idle connection 261449.000000, request 304999.442577 12/04/2025 02:27:44.887 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 18 12/04/2025 02:27:44.888 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/04/2025 02:27:44.888 7fa13da5d2c0 [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)]) 12/04/2025 02:27:44.888 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:44.888 7fa13da5d2c0 [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=410778758, session_epoch=683, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.888 7fa13da5d2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=410778758, session_epoch=683, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:44.888 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83493.640869, idle connection 260919.000000, request 304999.933720 12/04/2025 02:27:44.889 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83493.110596, idle connection 260919.000000, request 304999.417782 12/04/2025 02:27:44.942 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83873.732422, idle connection 261608.000000, request 304399.005175 12/04/2025 02:27:44.943 7fa140971f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 12/04/2025 02:27:44.943 7fa140971f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.943 7fa140971f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (601.7074584960938 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1323793449, topics=[]) 12/04/2025 02:27:44.943 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1323793449 with 0 response partitions (1 implied) 12/04/2025 02:27:44.944 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84326.910156, idle connection 262066.000000, request 304399.365902 12/04/2025 02:27:44.944 7fa13f45ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 718 12/04/2025 02:27:44.945 7fa13f45ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.945 7fa13f45ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 718 (600.9774208068848 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1207096404, topics=[]) 12/04/2025 02:27:44.945 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1207096404 with 0 response partitions (1 implied) 12/04/2025 02:27:44.986 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84478.333252, idle connection 261184.000000, request 304399.055004 12/04/2025 02:27:44.986 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743 12/04/2025 02:27:44.987 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:44.987 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 743 (601.5579700469971 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=716602182, topics=[]) 12/04/2025 02:27:44.987 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 716602182 with 0 response partitions (1 implied) 12/04/2025 02:27:45.008 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 90 12/04/2025 02:27:45.008 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/04/2025 02:27:45.008 7fa140971220 [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)]) 12/04/2025 02:27:45.008 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.009 7fa140971220 [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=67958313, session_epoch=699, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.009 7fa140971220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 703 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=67958313, session_epoch=699, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.009 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84264.044922, idle connection 261989.000000, request 304999.937773 12/04/2025 02:27:45.009 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84263.534424, idle connection 261988.000000, request 304999.439955 12/04/2025 02:27:45.067 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 309 12/04/2025 02:27:45.067 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 12/04/2025 02:27:45.067 7fa13f45a360 [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)]) 12/04/2025 02:27:45.067 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.067 7fa13f45a360 [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=310805383, session_epoch=737, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.067 7fa13f45a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 741 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=310805383, session_epoch=737, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.067 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83778.487305, idle connection 262109.000000, request 304999.935627 12/04/2025 02:27:45.068 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83777.960449, idle connection 262108.000000, request 304999.421358 12/04/2025 02:27:45.087 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83840.272949, idle connection 261084.000000, request 304397.917747 12/04/2025 02:27:45.087 7fa13f45a0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 723 12/04/2025 02:27:45.087 7fa13f45a0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.087 7fa13f45a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 723 (602.6153564453125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=268076184, topics=[]) 12/04/2025 02:27:45.087 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 268076184 with 0 response partitions (1 implied) 12/04/2025 02:27:45.088 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 24 12/04/2025 02:27:45.089 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 12/04/2025 02:27:45.089 7fa13da7c720 [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)]) 12/04/2025 02:27:45.089 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.089 7fa13da7c720 [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=1649154843, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.089 7fa13da7c720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1649154843, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.089 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83801.921875, idle connection 261207.000000, request 304999.959707 12/04/2025 02:27:45.089 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83801.536621, idle connection 261207.000000, request 304999.577761 12/04/2025 02:27:45.093 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 12/04/2025 02:27:45.093 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 12/04/2025 02:27:45.093 7fa13d490400 [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)]) 12/04/2025 02:27:45.093 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.093 7fa13d490400 [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=1269968249, session_epoch=688, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.094 7fa13d490400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1269968249, session_epoch=688, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.094 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83887.166016, idle connection 261285.000000, request 304999.960184 12/04/2025 02:27:45.094 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/04/2025 02:27:45.094 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 12/04/2025 02:27:45.094 7fa13d632d60 [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)]) 12/04/2025 02:27:45.094 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.094 7fa13d632d60 [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=404048884, session_epoch=678, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.094 7fa13d632d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=404048884, session_epoch=678, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.094 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83889.896240, idle connection 261291.000000, request 304999.963760 12/04/2025 02:27:45.095 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83886.131836, idle connection 261284.000000, request 304998.929739 12/04/2025 02:27:45.095 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/04/2025 02:27:45.095 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 12/04/2025 02:27:45.095 7fa13d632c20 [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)]) 12/04/2025 02:27:45.095 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.095 7fa13d632c20 [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=806440775, session_epoch=678, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.095 7fa13d632c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=806440775, session_epoch=678, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.095 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82691.218506, idle connection 261317.000000, request 304999.963999 12/04/2025 02:27:45.096 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83888.542480, idle connection 261290.000000, request 304998.612642 12/04/2025 02:27:45.096 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82690.555420, idle connection 261316.000000, request 304999.303579 12/04/2025 02:27:45.097 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83514.559326, idle connection 261288.000000, request 304397.924423 12/04/2025 02:27:45.097 7fa140971360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 12/04/2025 02:27:45.097 7fa140971360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.097 7fa140971360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (602.4436950683594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2097179136, topics=[]) 12/04/2025 02:27:45.097 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2097179136 with 0 response partitions (1 implied) 12/04/2025 02:27:45.097 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83885.546387, idle connection 261282.000000, request 304397.855997 12/04/2025 02:27:45.097 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83859.015625, idle connection 261585.000000, request 304398.627043 12/04/2025 02:27:45.098 7fa1409719a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 699 12/04/2025 02:27:45.098 7fa1409719a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.098 7fa1409719a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 699 (602.5519371032715 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=936803464, topics=[]) 12/04/2025 02:27:45.098 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 936803464 with 0 response partitions (1 implied) 12/04/2025 02:27:45.098 7fa13f45acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 705 12/04/2025 02:27:45.098 7fa13f45acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.098 7fa13f45acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 705 (602.1244525909424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1570595728, topics=[]) 12/04/2025 02:27:45.098 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1570595728 with 0 response partitions (1 implied) 12/04/2025 02:27:45.150 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 456 12/04/2025 02:27:45.150 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 12/04/2025 02:27:45.150 7fa13f45a220 [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)]) 12/04/2025 02:27:45.151 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.151 7fa13f45a220 [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=1927942566, session_epoch=751, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.151 7fa13f45a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 755 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1927942566, session_epoch=751, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.151 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84225.205566, idle connection 261836.000000, request 304999.951124 12/04/2025 02:27:45.151 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84224.766846, idle connection 261836.000000, request 304999.519348 12/04/2025 02:27:45.183 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 28 12/04/2025 02:27:45.183 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 12/04/2025 02:27:45.183 7fa140971b80 [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)]) 12/04/2025 02:27:45.183 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.183 7fa140971b80 [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=274107694, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.184 7fa140971b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=274107694, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.184 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83888.908447, idle connection 260896.000000, request 304999.950886 12/04/2025 02:27:45.184 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83888.432861, idle connection 260896.000000, request 304999.483824 12/04/2025 02:27:45.188 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83829.927979, idle connection 261436.000000, request 304397.094250 12/04/2025 02:27:45.189 7fa140971e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 12/04/2025 02:27:45.189 7fa140971e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.189 7fa140971e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 710 (603.3022403717041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1411295424, topics=[]) 12/04/2025 02:27:45.189 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1411295424 with 0 response partitions (1 implied) 12/04/2025 02:27:45.189 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83802.280518, idle connection 261809.000000, request 304397.116661 12/04/2025 02:27:45.189 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83335.160400, idle connection 260952.000000, request 304397.759914 12/04/2025 02:27:45.190 7fa13d3b0720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 12/04/2025 02:27:45.190 7fa13d3b0720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.190 7fa13d3b0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 694 (603.2800674438477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1034165134, topics=[]) 12/04/2025 02:27:45.190 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1034165134 with 0 response partitions (1 implied) 12/04/2025 02:27:45.190 7fa1409717c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 706 12/04/2025 02:27:45.190 7fa1409717c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.190 7fa1409717c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 706 (602.9977798461914 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2021726156, topics=[]) 12/04/2025 02:27:45.190 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2021726156 with 0 response partitions (1 implied) 12/04/2025 02:27:45.282 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83619.031738, idle connection 261462.000000, request 304398.959637 12/04/2025 02:27:45.283 7fa140971860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 12/04/2025 02:27:45.283 7fa140971860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.283 7fa140971860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 695 (601.5527248382568 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=622416178, topics=[]) 12/04/2025 02:27:45.283 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 622416178 with 0 response partitions (1 implied) 12/04/2025 02:27:45.285 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83328.602051, idle connection 261027.000000, request 304399.354219 12/04/2025 02:27:45.285 7fa13d490e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 12/04/2025 02:27:45.285 7fa13d490e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.285 7fa13d490e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.0017395019531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=21050150, topics=[]) 12/04/2025 02:27:45.285 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 21050150 with 0 response partitions (1 implied) 12/04/2025 02:27:45.285 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 359 12/04/2025 02:27:45.285 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/04/2025 02:27:45.285 7fa140971c20 [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)]) 12/04/2025 02:27:45.285 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.286 7fa140971c20 [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=1723932039, session_epoch=741, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.286 7fa140971c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 745 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1723932039, session_epoch=741, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.286 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84132.941406, idle connection 261414.000000, request 304999.948978 12/04/2025 02:27:45.286 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84132.576172, idle connection 261413.000000, request 304999.586821 12/04/2025 02:27:45.378 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 63 12/04/2025 02:27:45.378 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 12/04/2025 02:27:45.378 7fa13da7c2c0 [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)]) 12/04/2025 02:27:45.378 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.378 7fa13da7c2c0 [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=1394563909, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.378 7fa13da7c2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394563909, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.378 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83836.344971, idle connection 261035.000000, request 304999.948740 12/04/2025 02:27:45.379 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 19 12/04/2025 02:27:45.379 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 12/04/2025 02:27:45.379 7fa140971040 [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)]) 12/04/2025 02:27:45.379 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.379 7fa140971040 [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=1260842402, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.379 7fa140971040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1260842402, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.379 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82660.972900, idle connection 261305.000000, request 304999.964714 12/04/2025 02:27:45.379 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83835.310547, idle connection 261034.000000, request 304998.923779 12/04/2025 02:27:45.380 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 130 12/04/2025 02:27:45.380 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 12/04/2025 02:27:45.380 7fa13f45a720 [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)]) 12/04/2025 02:27:45.380 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.380 7fa13f45a720 [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=1013433983, session_epoch=703, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.380 7fa13f45a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 707 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1013433983, session_epoch=703, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.380 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83707.164795, idle connection 260913.000000, request 304999.966621 12/04/2025 02:27:45.380 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82659.707275, idle connection 261304.000000, request 304998.702049 12/04/2025 02:27:45.381 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83706.555176, idle connection 260912.000000, request 304999.359369 12/04/2025 02:27:45.382 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 26 12/04/2025 02:27:45.382 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/04/2025 02:27:45.382 7fa140971400 [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)]) 12/04/2025 02:27:45.382 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.382 7fa140971400 [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=1802323540, session_epoch=688, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.383 7fa140971400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1802323540, session_epoch=688, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.383 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82757.741455, idle connection 260604.000000, request 304999.968052 12/04/2025 02:27:45.383 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83491.190918, idle connection 261437.000000, request 304397.847891 12/04/2025 02:27:45.383 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82757.321289, idle connection 260603.000000, request 304999.550104 12/04/2025 02:27:45.383 7fa13d4907c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 12/04/2025 02:27:45.383 7fa13d4907c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.383 7fa13d4907c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (602.7233600616455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=636053439, topics=[]) 12/04/2025 02:27:45.384 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 636053439 with 0 response partitions (1 implied) 12/04/2025 02:27:45.389 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82633.612061, idle connection 260468.000000, request 304398.836136 12/04/2025 02:27:45.389 7fa13d632ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721 12/04/2025 02:27:45.389 7fa13d632ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.389 7fa13d632ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 721 (601.4838218688965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=731615446, topics=[]) 12/04/2025 02:27:45.389 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 731615446 with 0 response partitions (1 implied) 12/04/2025 02:27:45.391 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 12/04/2025 02:27:45.391 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 12/04/2025 02:27:45.391 7fa13d4909a0 [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)]) 12/04/2025 02:27:45.391 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.392 7fa13d4909a0 [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=1403412451, session_epoch=678, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.392 7fa13d4909a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1403412451, session_epoch=678, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.392 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82717.017822, idle connection 261377.000000, request 304999.966383 12/04/2025 02:27:45.392 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82716.709961, idle connection 261377.000000, request 304999.659538 12/04/2025 02:27:45.400 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82532.626465, idle connection 260849.000000, request 304399.082661 12/04/2025 02:27:45.400 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1027 12/04/2025 02:27:45.400 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.400 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1027 (601.2856960296631 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=265308676, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3749, last_stable_offset=3749, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xa4\x00\x00\x01\x04\x00\x00\x00\x00\x02\x14%\xc0]\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\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 12/04/2025 02:27:45.401 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 265308676 with 1 response partitions (0 implied) 12/04/2025 02:27:45.401 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3748 12/04/2025 02:27:45.401 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3748 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 12/04/2025 02:27:45.401 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3749 (leader epoch 0) 12/04/2025 02:27:45.489 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82892.605225, idle connection 260318.000000, request 304398.904562 12/04/2025 02:27:45.490 7fa13da5d2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 12/04/2025 02:27:45.490 7fa13da5d2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.490 7fa13da5d2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (601.5877723693848 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=410778758, topics=[]) 12/04/2025 02:27:45.490 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 410778758 with 0 response partitions (1 implied) 12/04/2025 02:27:45.502 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3749 12/04/2025 02:27:45.502 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/04/2025 02:27:45.502 7fa13d3dbae0 [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)]) 12/04/2025 02:27:45.502 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.502 7fa13d3dbae0 [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=265308676, session_epoch=1024, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3749, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/04/2025 02:27:45.502 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1028 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=265308676, session_epoch=1024, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3749, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/04/2025 02:27:45.502 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82430.469727, idle connection 260747.000000, request 304999.952555 12/04/2025 02:27:45.503 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82430.096680, idle connection 260747.000000, request 304999.585867 12/04/2025 02:27:45.543 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 47 12/04/2025 02:27:45.543 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/04/2025 02:27:45.544 7fa140971f40 [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)]) 12/04/2025 02:27:45.544 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.544 7fa140971f40 [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=1323793449, session_epoch=690, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.544 7fa140971f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1323793449, session_epoch=690, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.544 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83271.657959, idle connection 261006.000000, request 304999.893188 12/04/2025 02:27:45.544 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83271.277100, idle connection 261006.000000, request 304999.521017 12/04/2025 02:27:45.545 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 164 12/04/2025 02:27:45.545 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/04/2025 02:27:45.545 7fa13f45ac20 [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)]) 12/04/2025 02:27:45.545 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.545 7fa13f45ac20 [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=1207096404, session_epoch=715, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.545 7fa13f45ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 719 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1207096404, session_epoch=715, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.545 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83725.701904, idle connection 261465.000000, request 304999.950647 12/04/2025 02:27:45.546 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83725.379150, idle connection 261464.000000, request 304999.634981 12/04/2025 02:27:45.588 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 290 12/04/2025 02:27:45.588 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/04/2025 02:27:45.588 7fa13f45a540 [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)]) 12/04/2025 02:27:45.588 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.588 7fa13f45a540 [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=716602182, session_epoch=740, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.588 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 744 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=716602182, session_epoch=740, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.588 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83875.939697, idle connection 260581.000000, request 304999.952555 12/04/2025 02:27:45.589 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83875.563232, idle connection 260581.000000, request 304999.582291 12/04/2025 02:27:45.610 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83663.123779, idle connection 261388.000000, request 304399.019718 12/04/2025 02:27:45.610 7fa140971220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 703 12/04/2025 02:27:45.610 7fa140971220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.610 7fa140971220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 703 (601.40061378479 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=67958313, topics=[]) 12/04/2025 02:27:45.610 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 67958313 with 0 response partitions (1 implied) 12/04/2025 02:27:45.668 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83177.453125, idle connection 261508.000000, request 304398.906708 12/04/2025 02:27:45.669 7fa13f45a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 741 12/04/2025 02:27:45.669 7fa13f45a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.669 7fa13f45a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 741 (601.6030311584473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=310805383, topics=[]) 12/04/2025 02:27:45.669 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 310805383 with 0 response partitions (1 implied) 12/04/2025 02:27:45.688 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199 12/04/2025 02:27:45.688 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/04/2025 02:27:45.688 7fa13f45a0e0 [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)]) 12/04/2025 02:27:45.688 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.688 7fa13f45a0e0 [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=268076184, session_epoch=720, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.688 7fa13f45a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=268076184, session_epoch=720, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.688 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83238.602051, idle connection 260482.000000, request 304999.954224 12/04/2025 02:27:45.689 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83238.212646, idle connection 260482.000000, request 304999.571085 12/04/2025 02:27:45.690 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83200.472168, idle connection 260606.000000, request 304398.512602 12/04/2025 02:27:45.691 7fa13da7c720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 12/04/2025 02:27:45.691 7fa13da7c720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.691 7fa13da7c720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.8211841583252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1649154843, topics=[]) 12/04/2025 02:27:45.691 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1649154843 with 0 response partitions (1 implied) 12/04/2025 02:27:45.696 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83284.784912, idle connection 260682.000000, request 304397.581339 12/04/2025 02:27:45.696 7fa13d490400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 12/04/2025 02:27:45.696 7fa13d490400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.696 7fa13d490400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 692 (602.750301361084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1269968249, topics=[]) 12/04/2025 02:27:45.696 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1269968249 with 0 response partitions (1 implied) 12/04/2025 02:27:45.697 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83287.599365, idle connection 260689.000000, request 304397.669554 12/04/2025 02:27:45.697 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82089.860596, idle connection 260716.000000, request 304398.608685 12/04/2025 02:27:45.697 7fa13d632d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 12/04/2025 02:27:45.697 7fa13d632d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.697 7fa13d632d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (602.7266979217529 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=404048884, topics=[]) 12/04/2025 02:27:45.697 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 404048884 with 0 response partitions (1 implied) 12/04/2025 02:27:45.697 7fa13d632c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 12/04/2025 02:27:45.697 7fa13d632c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.697 7fa13d632c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (602.0739078521729 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=806440775, topics=[]) 12/04/2025 02:27:45.698 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 806440775 with 0 response partitions (1 implied) 12/04/2025 02:27:45.698 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 27 12/04/2025 02:27:45.698 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/04/2025 02:27:45.698 7fa140971360 [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)]) 12/04/2025 02:27:45.698 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.698 7fa140971360 [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=2097179136, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.698 7fa140971360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2097179136, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.698 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82912.904297, idle connection 260687.000000, request 304999.962807 12/04/2025 02:27:45.698 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 91 12/04/2025 02:27:45.698 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 12/04/2025 02:27:45.698 7fa1409719a0 [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)]) 12/04/2025 02:27:45.699 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.699 7fa1409719a0 [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=936803464, session_epoch=696, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.699 7fa1409719a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 700 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=936803464, session_epoch=696, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.699 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83283.962402, idle connection 260680.000000, request 304999.968052 12/04/2025 02:27:45.699 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82911.996094, idle connection 260686.000000, request 304999.056578 12/04/2025 02:27:45.699 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 109 12/04/2025 02:27:45.699 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 12/04/2025 02:27:45.699 7fa13f45acc0 [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)]) 12/04/2025 02:27:45.699 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.700 7fa13f45acc0 [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=1570595728, session_epoch=702, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.700 7fa13f45acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 706 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1570595728, session_epoch=702, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.700 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83256.685791, idle connection 260983.000000, request 304999.969244 12/04/2025 02:27:45.700 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83282.807129, idle connection 260679.000000, request 304998.814821 12/04/2025 02:27:45.700 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83256.086182, idle connection 260982.000000, request 304999.371052 12/04/2025 02:27:45.752 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83624.277832, idle connection 261235.000000, request 304399.023771 12/04/2025 02:27:45.752 7fa13f45a220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 755 12/04/2025 02:27:45.752 7fa13f45a220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.752 7fa13f45a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 755 (601.4804840087891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927942566, topics=[]) 12/04/2025 02:27:45.753 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927942566 with 0 response partitions (1 implied) 12/04/2025 02:27:45.785 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83288.038818, idle connection 260295.000000, request 304399.082661 12/04/2025 02:27:45.785 7fa140971b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 12/04/2025 02:27:45.785 7fa140971b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.785 7fa140971b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.3965606689453 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=274107694, topics=[]) 12/04/2025 02:27:45.785 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 274107694 with 0 response partitions (1 implied) 12/04/2025 02:27:45.789 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 150 12/04/2025 02:27:45.789 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/04/2025 02:27:45.789 7fa140971e00 [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)]) 12/04/2025 02:27:45.790 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.790 7fa140971e00 [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=1411295424, session_epoch=707, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.790 7fa140971e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 711 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1411295424, session_epoch=707, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.790 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83228.491211, idle connection 260834.000000, request 304999.953747 12/04/2025 02:27:45.790 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 42 12/04/2025 02:27:45.790 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 12/04/2025 02:27:45.790 7fa13d3b0720 [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)]) 12/04/2025 02:27:45.790 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.790 7fa13d3b0720 [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=1034165134, session_epoch=691, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.790 7fa13d3b0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1034165134, session_epoch=691, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.791 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83200.933105, idle connection 261208.000000, request 304999.964952 12/04/2025 02:27:45.791 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83227.414307, idle connection 260833.000000, request 304998.852015 12/04/2025 02:27:45.791 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 108 12/04/2025 02:27:45.791 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/04/2025 02:27:45.791 7fa1409717c0 [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)]) 12/04/2025 02:27:45.791 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.792 7fa1409717c0 [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=2021726156, session_epoch=703, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.792 7fa1409717c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 707 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2021726156, session_epoch=703, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.792 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82732.766846, idle connection 260349.000000, request 304999.963999 12/04/2025 02:27:45.792 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83199.267578, idle connection 261206.000000, request 304998.301744 12/04/2025 02:27:45.793 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82731.902588, idle connection 260348.000000, request 304999.102831 12/04/2025 02:27:45.884 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 12/04/2025 02:27:45.884 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 12/04/2025 02:27:45.884 7fa140971860 [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)]) 12/04/2025 02:27:45.884 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.884 7fa140971860 [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=622416178, session_epoch=692, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.884 7fa140971860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 696 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=622416178, session_epoch=692, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.885 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83016.854736, idle connection 260860.000000, request 304999.950409 12/04/2025 02:27:45.885 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83016.456055, idle connection 260859.000000, request 304999.559641 12/04/2025 02:27:45.885 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 25 12/04/2025 02:27:45.885 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 12/04/2025 02:27:45.885 7fa13d490e00 [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)]) 12/04/2025 02:27:45.886 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.886 7fa13d490e00 [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=21050150, session_epoch=686, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.886 7fa13d490e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=21050150, session_epoch=686, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.886 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82727.391602, idle connection 260426.000000, request 304999.964714 12/04/2025 02:27:45.886 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82727.045654, idle connection 260426.000000, request 304999.621153 12/04/2025 02:27:45.886 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83532.307373, idle connection 260813.000000, request 304399.318933 12/04/2025 02:27:45.887 7fa140971c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 745 12/04/2025 02:27:45.887 7fa140971c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.887 7fa140971c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 745 (600.9960174560547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1723932039, topics=[]) 12/04/2025 02:27:45.887 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1723932039 with 0 response partitions (1 implied) 12/04/2025 02:27:45.981 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83233.934326, idle connection 260432.000000, request 304397.537947 12/04/2025 02:27:45.981 7fa13da7c2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 12/04/2025 02:27:45.981 7fa13da7c2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.981 7fa13da7c2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (602.9455661773682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394563909, topics=[]) 12/04/2025 02:27:45.981 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394563909 with 0 response partitions (1 implied) 12/04/2025 02:27:45.982 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82058.416992, idle connection 260703.000000, request 304397.409916 12/04/2025 02:27:45.982 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83105.473145, idle connection 260311.000000, request 304398.275852 12/04/2025 02:27:45.982 7fa140971040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 12/04/2025 02:27:45.982 7fa140971040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.982 7fa140971040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (603.018045425415 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1260842402, topics=[]) 12/04/2025 02:27:45.982 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1260842402 with 0 response partitions (1 implied) 12/04/2025 02:27:45.982 7fa13f45a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 707 12/04/2025 02:27:45.982 7fa13f45a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.983 7fa13f45a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 707 (602.4796962738037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1013433983, topics=[]) 12/04/2025 02:27:45.983 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1013433983 with 0 response partitions (1 implied) 12/04/2025 02:27:45.984 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 6 12/04/2025 02:27:45.984 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 12/04/2025 02:27:45.984 7fa13d4907c0 [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)]) 12/04/2025 02:27:45.984 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.984 7fa13d4907c0 [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=636053439, session_epoch=680, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.984 7fa13d4907c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=636053439, session_epoch=680, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.984 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82889.782227, idle connection 260836.000000, request 304999.960661 12/04/2025 02:27:45.984 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82155.962402, idle connection 260002.000000, request 304398.189306 12/04/2025 02:27:45.985 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82889.289062, idle connection 260836.000000, request 304999.471188 12/04/2025 02:27:45.985 7fa140971400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 12/04/2025 02:27:45.985 7fa140971400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.985 7fa140971400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 692 (602.43821144104 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1802323540, topics=[]) 12/04/2025 02:27:45.985 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1802323540 with 0 response partitions (1 implied) 12/04/2025 02:27:45.990 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 12/04/2025 02:27:45.990 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/04/2025 02:27:45.990 7fa13d632ea0 [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)]) 12/04/2025 02:27:45.990 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:45.990 7fa13d632ea0 [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=731615446, session_epoch=718, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.990 7fa13d632ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=731615446, session_epoch=718, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:45.991 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82031.981201, idle connection 259866.000000, request 304999.962568 12/04/2025 02:27:45.991 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82031.673584, idle connection 259866.000000, request 304999.657393 12/04/2025 02:27:45.993 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82115.561768, idle connection 260775.000000, request 304398.511410 12/04/2025 02:27:45.993 7fa13d4909a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 12/04/2025 02:27:45.993 7fa13d4909a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:45.993 7fa13d4909a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (601.7868518829346 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1403412451, topics=[]) 12/04/2025 02:27:45.994 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1403412451 with 0 response partitions (1 implied) 12/04/2025 02:27:46.090 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 18 12/04/2025 02:27:46.090 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/04/2025 02:27:46.090 7fa13da5d2c0 [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)]) 12/04/2025 02:27:46.090 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.091 7fa13da5d2c0 [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=410778758, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.091 7fa13da5d2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=410778758, session_epoch=684, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.091 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82291.027832, idle connection 259717.000000, request 304999.940872 12/04/2025 02:27:46.091 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82290.645508, idle connection 259716.000000, request 304999.575615 12/04/2025 02:27:46.103 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81829.781982, idle connection 260146.000000, request 304399.269581 12/04/2025 02:27:46.103 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1028 12/04/2025 02:27:46.103 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.103 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1028 (601.121187210083 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=265308676, topics=[]) 12/04/2025 02:27:46.103 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 265308676 with 0 response partitions (1 implied) 12/04/2025 02:27:46.145 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82670.831299, idle connection 260405.000000, request 304399.066210 12/04/2025 02:27:46.145 7fa140971f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 12/04/2025 02:27:46.145 7fa140971f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.145 7fa140971f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 694 (601.4070510864258 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1323793449, topics=[]) 12/04/2025 02:27:46.145 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1323793449 with 0 response partitions (1 implied) 12/04/2025 02:27:46.146 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83125.118896, idle connection 260864.000000, request 304399.372101 12/04/2025 02:27:46.146 7fa13f45ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 719 12/04/2025 02:27:46.146 7fa13f45ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.146 7fa13f45ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 719 (600.9118556976318 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1207096404, topics=[]) 12/04/2025 02:27:46.146 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1207096404 with 0 response partitions (1 implied) 12/04/2025 02:27:46.189 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83275.180664, idle connection 259980.000000, request 304399.191618 12/04/2025 02:27:46.189 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 744 12/04/2025 02:27:46.190 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.190 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 744 (601.2318134307861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=716602182, topics=[]) 12/04/2025 02:27:46.190 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 716602182 with 0 response partitions (1 implied) 12/04/2025 02:27:46.211 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 90 12/04/2025 02:27:46.211 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/04/2025 02:27:46.211 7fa140971220 [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)]) 12/04/2025 02:27:46.211 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.211 7fa140971220 [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=67958313, session_epoch=700, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.211 7fa140971220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 704 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=67958313, session_epoch=700, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.211 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83061.622314, idle connection 260787.000000, request 304999.950886 12/04/2025 02:27:46.212 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83061.228516, idle connection 260786.000000, request 304999.564409 12/04/2025 02:27:46.269 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 309 12/04/2025 02:27:46.270 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 12/04/2025 02:27:46.270 7fa13f45a360 [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)]) 12/04/2025 02:27:46.270 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.270 7fa13f45a360 [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=310805383, session_epoch=738, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.270 7fa13f45a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 742 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=310805383, session_epoch=738, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.270 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82575.842773, idle connection 260906.000000, request 304999.952555 12/04/2025 02:27:46.270 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82575.454834, idle connection 260906.000000, request 304999.572515 12/04/2025 02:27:46.289 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82637.811279, idle connection 259881.000000, request 304399.166107 12/04/2025 02:27:46.289 7fa13f45a0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 724 12/04/2025 02:27:46.290 7fa13f45a0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.290 7fa13f45a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 724 (601.2425422668457 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=268076184, topics=[]) 12/04/2025 02:27:46.290 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 268076184 with 0 response partitions (1 implied) 12/04/2025 02:27:46.292 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 24 12/04/2025 02:27:46.292 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 12/04/2025 02:27:46.292 7fa13da7c720 [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)]) 12/04/2025 02:27:46.292 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.292 7fa13da7c720 [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=1649154843, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.292 7fa13da7c720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1649154843, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.293 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82598.416016, idle connection 260003.000000, request 304999.961853 12/04/2025 02:27:46.293 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82598.068848, idle connection 260003.000000, request 304999.617577 12/04/2025 02:27:46.297 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 12/04/2025 02:27:46.297 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 12/04/2025 02:27:46.297 7fa13d490400 [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)]) 12/04/2025 02:27:46.297 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.297 7fa13d490400 [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=1269968249, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.297 7fa13d490400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1269968249, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.297 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82683.624512, idle connection 260081.000000, request 304999.965191 12/04/2025 02:27:46.297 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82683.323242, idle connection 260081.000000, request 304999.666929 12/04/2025 02:27:46.298 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/04/2025 02:27:46.298 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 12/04/2025 02:27:46.298 7fa13d632d60 [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)]) 12/04/2025 02:27:46.298 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.298 7fa13d632d60 [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=404048884, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.298 7fa13d632d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=404048884, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.298 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82686.169434, idle connection 260087.000000, request 304999.967098 12/04/2025 02:27:46.298 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/04/2025 02:27:46.298 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 12/04/2025 02:27:46.298 7fa13d632c20 [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)]) 12/04/2025 02:27:46.299 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.299 7fa13d632c20 [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=806440775, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.299 7fa13d632c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=806440775, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.299 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81487.882568, idle connection 260114.000000, request 304999.957085 12/04/2025 02:27:46.299 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82685.220947, idle connection 260086.000000, request 304999.020100 12/04/2025 02:27:46.299 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81487.341309, idle connection 260113.000000, request 304999.430180 12/04/2025 02:27:46.300 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82310.888672, idle connection 260085.000000, request 304397.949457 12/04/2025 02:27:46.300 7fa140971360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 12/04/2025 02:27:46.300 7fa140971360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.301 7fa140971360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (602.3769378662109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2097179136, topics=[]) 12/04/2025 02:27:46.301 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2097179136 with 0 response partitions (1 implied) 12/04/2025 02:27:46.301 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82681.923828, idle connection 260078.000000, request 304397.930384 12/04/2025 02:27:46.301 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82655.396484, idle connection 260381.000000, request 304398.680449 12/04/2025 02:27:46.301 7fa1409719a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 700 12/04/2025 02:27:46.301 7fa1409719a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.301 7fa1409719a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 700 (602.4634838104248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=936803464, topics=[]) 12/04/2025 02:27:46.301 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 936803464 with 0 response partitions (1 implied) 12/04/2025 02:27:46.302 7fa13f45acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 706 12/04/2025 02:27:46.302 7fa13f45acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.302 7fa13f45acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 706 (602.1342277526855 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1570595728, topics=[]) 12/04/2025 02:27:46.302 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1570595728 with 0 response partitions (1 implied) 12/04/2025 02:27:46.353 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 456 12/04/2025 02:27:46.353 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 12/04/2025 02:27:46.353 7fa13f45a220 [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)]) 12/04/2025 02:27:46.353 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.353 7fa13f45a220 [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=1927942566, session_epoch=752, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.353 7fa13f45a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 756 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1927942566, session_epoch=752, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.354 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83022.623779, idle connection 260634.000000, request 304999.948978 12/04/2025 02:27:46.354 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83022.230225, idle connection 260633.000000, request 304999.562263 12/04/2025 02:27:46.386 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 28 12/04/2025 02:27:46.386 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 12/04/2025 02:27:46.386 7fa140971b80 [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)]) 12/04/2025 02:27:46.386 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.386 7fa140971b80 [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=274107694, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.387 7fa140971b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=274107694, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.387 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82685.881104, idle connection 259693.000000, request 304999.954462 12/04/2025 02:27:46.387 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82685.500000, idle connection 259693.000000, request 304999.579668 12/04/2025 02:27:46.393 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82625.842285, idle connection 260232.000000, request 304397.309065 12/04/2025 02:27:46.393 7fa140971e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 711 12/04/2025 02:27:46.393 7fa140971e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.393 7fa140971e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 711 (603.0855178833008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1411295424, topics=[]) 12/04/2025 02:27:46.393 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1411295424 with 0 response partitions (1 implied) 12/04/2025 02:27:46.393 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82598.201904, idle connection 260605.000000, request 304397.235394 12/04/2025 02:27:46.393 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82131.076416, idle connection 259748.000000, request 304398.276567 12/04/2025 02:27:46.394 7fa13d3b0720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 12/04/2025 02:27:46.394 7fa13d3b0720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.394 7fa13d3b0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 695 (603.2373905181885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1034165134, topics=[]) 12/04/2025 02:27:46.394 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1034165134 with 0 response partitions (1 implied) 12/04/2025 02:27:46.394 7fa1409717c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 707 12/04/2025 02:27:46.394 7fa1409717c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.394 7fa1409717c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 707 (602.5257110595703 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2021726156, topics=[]) 12/04/2025 02:27:46.394 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2021726156 with 0 response partitions (1 implied) 12/04/2025 02:27:46.486 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82415.881592, idle connection 260259.000000, request 304398.975849 12/04/2025 02:27:46.486 7fa140971860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696 12/04/2025 02:27:46.486 7fa140971860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.486 7fa140971860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 696 (601.5260219573975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=622416178, topics=[]) 12/04/2025 02:27:46.486 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 622416178 with 0 response partitions (1 implied) 12/04/2025 02:27:46.486 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82126.779541, idle connection 259825.000000, request 304399.352789 12/04/2025 02:27:46.487 7fa13d490e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 12/04/2025 02:27:46.487 7fa13d490e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.487 7fa13d490e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (600.9371280670166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=21050150, topics=[]) 12/04/2025 02:27:46.487 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 21050150 with 0 response partitions (1 implied) 12/04/2025 02:27:46.487 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 359 12/04/2025 02:27:46.487 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/04/2025 02:27:46.487 7fa140971c20 [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)]) 12/04/2025 02:27:46.487 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.487 7fa140971c20 [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=1723932039, session_epoch=742, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.487 7fa140971c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 746 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1723932039, session_epoch=742, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.488 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82931.183105, idle connection 260212.000000, request 304999.962330 12/04/2025 02:27:46.488 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82930.739014, idle connection 260212.000000, request 304999.519825 12/04/2025 02:27:46.582 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 63 12/04/2025 02:27:46.582 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 12/04/2025 02:27:46.582 7fa13da7c2c0 [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)]) 12/04/2025 02:27:46.582 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.582 7fa13da7c2c0 [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=1394563909, session_epoch=690, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.582 7fa13da7c2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394563909, session_epoch=690, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.582 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82632.300049, idle connection 259831.000000, request 304999.951601 12/04/2025 02:27:46.583 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 19 12/04/2025 02:27:46.583 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 12/04/2025 02:27:46.583 7fa140971040 [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)]) 12/04/2025 02:27:46.583 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.583 7fa140971040 [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=1260842402, session_epoch=686, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.583 7fa140971040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1260842402, session_epoch=686, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.583 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81456.935059, idle connection 260101.000000, request 304999.966383 12/04/2025 02:27:46.583 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82631.289307, idle connection 259830.000000, request 304998.949051 12/04/2025 02:27:46.584 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 130 12/04/2025 02:27:46.584 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 12/04/2025 02:27:46.584 7fa13f45a720 [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)]) 12/04/2025 02:27:46.584 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.584 7fa13f45a720 [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=1013433983, session_epoch=704, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.584 7fa13f45a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 708 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1013433983, session_epoch=704, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.584 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82503.125732, idle connection 259709.000000, request 304999.965906 12/04/2025 02:27:46.584 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81455.668213, idle connection 260100.000000, request 304998.701811 12/04/2025 02:27:46.585 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82502.518311, idle connection 259708.000000, request 304999.361515 12/04/2025 02:27:46.585 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 26 12/04/2025 02:27:46.586 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/04/2025 02:27:46.586 7fa140971400 [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)]) 12/04/2025 02:27:46.586 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.586 7fa140971400 [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=1802323540, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.586 7fa140971400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1802323540, session_epoch=689, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.586 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81554.397217, idle connection 259400.000000, request 304999.966383 12/04/2025 02:27:46.586 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82287.851562, idle connection 260234.000000, request 304398.033619 12/04/2025 02:27:46.586 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81553.988281, idle connection 259400.000000, request 304999.560356 12/04/2025 02:27:46.587 7fa13d4907c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 12/04/2025 02:27:46.587 7fa13d4907c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.587 7fa13d4907c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 684 (602.536678314209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=636053439, topics=[]) 12/04/2025 02:27:46.587 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 636053439 with 0 response partitions (1 implied) 12/04/2025 02:27:46.591 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81431.186279, idle connection 259265.000000, request 304399.168491 12/04/2025 02:27:46.592 7fa13d632ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 722 12/04/2025 02:27:46.592 7fa13d632ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.592 7fa13d632ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 722 (601.1664867401123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=731615446, topics=[]) 12/04/2025 02:27:46.592 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 731615446 with 0 response partitions (1 implied) 12/04/2025 02:27:46.594 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 12/04/2025 02:27:46.594 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 12/04/2025 02:27:46.594 7fa13d4909a0 [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)]) 12/04/2025 02:27:46.594 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.594 7fa13d4909a0 [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=1403412451, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.594 7fa13d4909a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1403412451, session_epoch=679, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.594 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81514.454590, idle connection 260174.000000, request 304999.965429 12/04/2025 02:27:46.595 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81514.168457, idle connection 260174.000000, request 304999.681950 12/04/2025 02:27:46.692 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81690.236328, idle connection 259116.000000, request 304399.160147 12/04/2025 02:27:46.692 7fa13da5d2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 12/04/2025 02:27:46.692 7fa13da5d2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.692 7fa13da5d2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.3214588165283 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=410778758, topics=[]) 12/04/2025 02:27:46.692 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 410778758 with 0 response partitions (1 implied) 12/04/2025 02:27:46.705 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3749 12/04/2025 02:27:46.705 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/04/2025 02:27:46.705 7fa13d3dbae0 [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)]) 12/04/2025 02:27:46.705 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.705 7fa13d3dbae0 [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=265308676, session_epoch=1025, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.705 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1029 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=265308676, session_epoch=1025, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.705 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81227.430908, idle connection 259544.000000, request 304999.955893 12/04/2025 02:27:46.706 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81227.051270, idle connection 259543.000000, request 304999.580860 12/04/2025 02:27:46.746 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 47 12/04/2025 02:27:46.746 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/04/2025 02:27:46.746 7fa140971f40 [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)]) 12/04/2025 02:27:46.746 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.746 7fa140971f40 [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=1323793449, session_epoch=691, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.746 7fa140971f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1323793449, session_epoch=691, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.746 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82069.291992, idle connection 259804.000000, request 304999.956846 12/04/2025 02:27:46.747 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82068.944336, idle connection 259803.000000, request 304999.614477 12/04/2025 02:27:46.747 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 164 12/04/2025 02:27:46.747 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/04/2025 02:27:46.747 7fa13f45ac20 [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)]) 12/04/2025 02:27:46.747 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.747 7fa13f45ac20 [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=1207096404, session_epoch=716, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.747 7fa13f45ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 720 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1207096404, session_epoch=716, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.747 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82523.766846, idle connection 260263.000000, request 304999.965668 12/04/2025 02:27:46.748 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82523.429688, idle connection 260262.000000, request 304999.631405 12/04/2025 02:27:46.790 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 290 12/04/2025 02:27:46.790 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/04/2025 02:27:46.790 7fa13f45a540 [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)]) 12/04/2025 02:27:46.790 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.791 7fa13f45a540 [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=716602182, session_epoch=741, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.791 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 745 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=716602182, session_epoch=741, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.791 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82673.565674, idle connection 259379.000000, request 304999.938488 12/04/2025 02:27:46.791 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82673.159912, idle connection 259378.000000, request 304999.541044 12/04/2025 02:27:46.812 7fa140971220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82460.813721, idle connection 260186.000000, request 304399.142027 12/04/2025 02:27:46.812 7fa140971220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 704 12/04/2025 02:27:46.813 7fa140971220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.813 7fa140971220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 704 (601.3689041137695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=67958313, topics=[]) 12/04/2025 02:27:46.813 7fa140971220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 67958313 with 0 response partitions (1 implied) 12/04/2025 02:27:46.871 7fa13f45a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81975.021484, idle connection 260305.000000, request 304399.128199 12/04/2025 02:27:46.871 7fa13f45a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742 12/04/2025 02:27:46.871 7fa13f45a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.871 7fa13f45a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 742 (601.4258861541748 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=310805383, topics=[]) 12/04/2025 02:27:46.872 7fa13f45a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 310805383 with 0 response partitions (1 implied) 12/04/2025 02:27:46.890 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199 12/04/2025 02:27:46.890 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/04/2025 02:27:46.890 7fa13f45a0e0 [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)]) 12/04/2025 02:27:46.890 7fa13f45a0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.890 7fa13f45a0e0 [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=268076184, session_epoch=721, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.891 7fa13f45a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 725 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=268076184, session_epoch=721, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.891 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82036.266357, idle connection 259280.000000, request 304999.949217 12/04/2025 02:27:46.891 7fa13f45a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82035.842773, idle connection 259279.000000, request 304999.533892 12/04/2025 02:27:46.894 7fa13da7c720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81997.289062, idle connection 259402.000000, request 304398.835897 12/04/2025 02:27:46.894 7fa13da7c720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 12/04/2025 02:27:46.894 7fa13da7c720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.894 7fa13da7c720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.538896560669 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1649154843, topics=[]) 12/04/2025 02:27:46.894 7fa13da7c720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1649154843 with 0 response partitions (1 implied) 12/04/2025 02:27:46.898 7fa13d490400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82082.400635, idle connection 259480.000000, request 304398.740768 12/04/2025 02:27:46.899 7fa13d490400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 12/04/2025 02:27:46.899 7fa13d490400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.899 7fa13d490400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (601.6411781311035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1269968249, topics=[]) 12/04/2025 02:27:46.899 7fa13d490400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1269968249 with 0 response partitions (1 implied) 12/04/2025 02:27:46.900 7fa13d632d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82084.713135, idle connection 259486.000000, request 304398.510218 12/04/2025 02:27:46.900 7fa13d632d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 12/04/2025 02:27:46.900 7fa13d632d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.900 7fa13d632d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (601.8519401550293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=404048884, topics=[]) 12/04/2025 02:27:46.900 7fa13d632d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 404048884 with 0 response partitions (1 implied) 12/04/2025 02:27:46.900 7fa13d632c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80886.398193, idle connection 259512.000000, request 304398.484945 12/04/2025 02:27:46.900 7fa13d632c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 12/04/2025 02:27:46.900 7fa13d632c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.901 7fa13d632c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (601.7954349517822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=806440775, topics=[]) 12/04/2025 02:27:46.901 7fa13d632c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 806440775 with 0 response partitions (1 implied) 12/04/2025 02:27:46.901 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 27 12/04/2025 02:27:46.901 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/04/2025 02:27:46.901 7fa140971360 [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)]) 12/04/2025 02:27:46.901 7fa140971360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.901 7fa140971360 [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=2097179136, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.901 7fa140971360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2097179136, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.901 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81709.738037, idle connection 259483.000000, request 304999.962091 12/04/2025 02:27:46.902 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 91 12/04/2025 02:27:46.902 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 12/04/2025 02:27:46.902 7fa1409719a0 [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)]) 12/04/2025 02:27:46.902 7fa1409719a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.902 7fa1409719a0 [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=936803464, session_epoch=697, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.902 7fa1409719a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 701 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=936803464, session_epoch=697, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.902 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82080.776367, idle connection 259477.000000, request 304999.966860 12/04/2025 02:27:46.902 7fa140971360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81708.791504, idle connection 259483.000000, request 304999.017954 12/04/2025 02:27:46.902 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 109 12/04/2025 02:27:46.903 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 12/04/2025 02:27:46.903 7fa13f45acc0 [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)]) 12/04/2025 02:27:46.903 7fa13f45acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.903 7fa13f45acc0 [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=1570595728, session_epoch=703, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.903 7fa13f45acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 707 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1570595728, session_epoch=703, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.903 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82053.417480, idle connection 259779.000000, request 304999.967813 12/04/2025 02:27:46.903 7fa1409719a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82079.536377, idle connection 259476.000000, request 304998.728275 12/04/2025 02:27:46.904 7fa13f45acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82052.792480, idle connection 259779.000000, request 304999.345064 12/04/2025 02:27:46.954 7fa13f45a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82421.800537, idle connection 260033.000000, request 304399.124384 12/04/2025 02:27:46.955 7fa13f45a220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 756 12/04/2025 02:27:46.955 7fa13f45a220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.955 7fa13f45a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 756 (601.4018058776855 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927942566, topics=[]) 12/04/2025 02:27:46.955 7fa13f45a220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927942566 with 0 response partitions (1 implied) 12/04/2025 02:27:46.988 7fa140971b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82084.718018, idle connection 259092.000000, request 304398.789406 12/04/2025 02:27:46.988 7fa140971b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 12/04/2025 02:27:46.988 7fa140971b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:46.988 7fa140971b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.696252822876 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=274107694, topics=[]) 12/04/2025 02:27:46.989 7fa140971b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 274107694 with 0 response partitions (1 implied) 12/04/2025 02:27:46.993 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 150 12/04/2025 02:27:46.993 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/04/2025 02:27:46.993 7fa140971e00 [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)]) 12/04/2025 02:27:46.994 7fa140971e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.994 7fa140971e00 [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=1411295424, session_epoch=708, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.994 7fa140971e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 712 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1411295424, session_epoch=708, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.994 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82024.508545, idle connection 259630.000000, request 304999.956131 12/04/2025 02:27:46.994 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 42 12/04/2025 02:27:46.994 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 12/04/2025 02:27:46.994 7fa13d3b0720 [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)]) 12/04/2025 02:27:46.994 7fa13d3b0720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.994 7fa13d3b0720 [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=1034165134, session_epoch=692, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.994 7fa13d3b0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 696 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1034165134, session_epoch=692, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.995 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81996.955811, idle connection 260004.000000, request 304999.965668 12/04/2025 02:27:46.995 7fa140971e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82023.531982, idle connection 259629.000000, request 304998.984575 12/04/2025 02:27:46.995 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 108 12/04/2025 02:27:46.995 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/04/2025 02:27:46.995 7fa1409717c0 [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)]) 12/04/2025 02:27:46.995 7fa1409717c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:46.995 7fa1409717c0 [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=2021726156, session_epoch=704, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.995 7fa1409717c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 708 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2021726156, session_epoch=704, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:46.996 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.964600, idle connection 259146.000000, request 304999.967575 12/04/2025 02:27:46.996 7fa13d3b0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81995.685059, idle connection 260003.000000, request 304998.697042 12/04/2025 02:27:46.996 7fa1409717c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.335449, idle connection 259145.000000, request 304999.340534 12/04/2025 02:27:47.087 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 12/04/2025 02:27:47.087 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 12/04/2025 02:27:47.087 7fa140971860 [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)]) 12/04/2025 02:27:47.088 7fa140971860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:47.088 7fa140971860 [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=622416178, session_epoch=693, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.088 7fa140971860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 697 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=622416178, session_epoch=693, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.088 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81813.479492, idle connection 259656.000000, request 304999.948502 12/04/2025 02:27:47.088 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 25 12/04/2025 02:27:47.088 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 12/04/2025 02:27:47.088 7fa13d490e00 [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)]) 12/04/2025 02:27:47.088 7fa13d490e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:47.088 7fa13d490e00 [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=21050150, session_epoch=687, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.089 7fa13d490e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=21050150, session_epoch=687, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.089 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81524.563232, idle connection 259223.000000, request 304999.963760 12/04/2025 02:27:47.089 7fa140971860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81812.383789, idle connection 259655.000000, request 304998.862505 12/04/2025 02:27:47.089 7fa140971c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82329.557861, idle connection 259610.000000, request 304398.339033 12/04/2025 02:27:47.089 7fa13d490e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81523.722168, idle connection 259222.000000, request 304999.125957 12/04/2025 02:27:47.090 7fa140971c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 746 12/04/2025 02:27:47.090 7fa140971c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.090 7fa140971c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 746 (602.4205684661865 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1723932039, topics=[]) 12/04/2025 02:27:47.090 7fa140971c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1723932039 with 0 response partitions (1 implied) 12/04/2025 02:27:47.185 7fa13da7c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82029.916504, idle connection 259228.000000, request 304397.566080 12/04/2025 02:27:47.185 7fa13da7c2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 12/04/2025 02:27:47.185 7fa13da7c2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.185 7fa13da7c2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 694 (602.9460430145264 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394563909, topics=[]) 12/04/2025 02:27:47.185 7fa13da7c2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394563909 with 0 response partitions (1 implied) 12/04/2025 02:27:47.186 7fa140971040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80854.351562, idle connection 259498.000000, request 304397.382736 12/04/2025 02:27:47.186 7fa13f45a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81901.391846, idle connection 259107.000000, request 304398.233891 12/04/2025 02:27:47.186 7fa140971040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 12/04/2025 02:27:47.186 7fa140971040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.186 7fa140971040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (603.0573844909668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1260842402, topics=[]) 12/04/2025 02:27:47.186 7fa140971040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1260842402 with 0 response partitions (1 implied) 12/04/2025 02:27:47.186 7fa13f45a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 708 12/04/2025 02:27:47.186 7fa13f45a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.187 7fa13f45a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 708 (602.5021076202393 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1013433983, topics=[]) 12/04/2025 02:27:47.187 7fa13f45a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1013433983 with 0 response partitions (1 implied) 12/04/2025 02:27:47.187 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 6 12/04/2025 02:27:47.187 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 12/04/2025 02:27:47.187 7fa13d4907c0 [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)]) 12/04/2025 02:27:47.187 7fa13d4907c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:47.187 7fa13d4907c0 [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=636053439, session_epoch=681, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.187 7fa13d4907c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=636053439, session_epoch=681, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.188 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81686.473877, idle connection 259633.000000, request 304999.961138 12/04/2025 02:27:47.188 7fa140971400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80952.651855, idle connection 258798.000000, request 304398.222208 12/04/2025 02:27:47.188 7fa13d4907c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81685.942871, idle connection 259632.000000, request 304999.433279 12/04/2025 02:27:47.188 7fa140971400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 12/04/2025 02:27:47.188 7fa140971400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.188 7fa140971400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (602.4901866912842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1802323540, topics=[]) 12/04/2025 02:27:47.189 7fa140971400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1802323540 with 0 response partitions (1 implied) 12/04/2025 02:27:47.192 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 12/04/2025 02:27:47.193 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/04/2025 02:27:47.193 7fa13d632ea0 [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)]) 12/04/2025 02:27:47.193 7fa13d632ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:47.193 7fa13d632ea0 [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=731615446, session_epoch=719, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.193 7fa13d632ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=731615446, session_epoch=719, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.193 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80829.606201, idle connection 258664.000000, request 304999.959230 12/04/2025 02:27:47.193 7fa13d632ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80829.136475, idle connection 258663.000000, request 304999.488354 12/04/2025 02:27:47.196 7fa13d4909a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80913.210205, idle connection 259573.000000, request 304398.722172 12/04/2025 02:27:47.196 7fa13d4909a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 12/04/2025 02:27:47.196 7fa13d4909a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.196 7fa13d4909a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (601.6244888305664 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1403412451, topics=[]) 12/04/2025 02:27:47.196 7fa13d4909a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1403412451 with 0 response partitions (1 implied) 12/04/2025 02:27:47.292 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 18 12/04/2025 02:27:47.293 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/04/2025 02:27:47.293 7fa13da5d2c0 [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)]) 12/04/2025 02:27:47.293 7fa13da5d2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/04/2025 02:27:47.293 7fa13da5d2c0 [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=410778758, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.293 7fa13da5d2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=410778758, session_epoch=685, topics=[], forgotten_topics_data=[]) 12/04/2025 02:27:47.293 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81088.697998, idle connection 258514.000000, request 304999.951839 12/04/2025 02:27:47.293 7fa13da5d2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81088.321777, idle connection 258514.000000, request 304999.582767 12/04/2025 02:27:47.306 7fa13d3dbae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80626.711914, idle connection 258943.000000, request 304399.238110 12/04/2025 02:27:47.306 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1029 12/04/2025 02:27:47.306 7fa13d3dbae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.306 7fa13d3dbae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1029 (601.2098789215088 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=265308676, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3750, last_stable_offset=3750, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x0e\xa5\x00\x00\x00\xf8\x00\x00\x00\x00\x02'\xf8\xe7\x9a\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\x8a\x03\x00\x00\x00\xcc\x02ObjectBgpRouter:cn-jenkins-deplo...")])]) 12/04/2025 02:27:47.307 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 265308676 with 1 response partitions (0 implied) 12/04/2025 02:27:47.307 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 260 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3749 12/04/2025 02:27:47.307 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3749 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 12/04/2025 02:27:47.307 7fa13d3dbae0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3750 (leader epoch 0) 12/04/2025 02:27:47.348 7fa140971f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81467.882812, idle connection 259202.000000, request 304398.545504 12/04/2025 02:27:47.348 7fa140971f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 12/04/2025 02:27:47.348 7fa140971f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.348 7fa140971f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 695 (601.9144058227539 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1323793449, topics=[]) 12/04/2025 02:27:47.348 7fa140971f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1323793449 with 0 response partitions (1 implied) 12/04/2025 02:27:47.349 7fa13f45ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81922.540771, idle connection 259661.000000, request 304398.739576 12/04/2025 02:27:47.349 7fa13f45ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 12/04/2025 02:27:47.349 7fa13f45ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.349 7fa13f45ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 720 (601.5670299530029 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1207096404, topics=[]) 12/04/2025 02:27:47.349 7fa13f45ac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1207096404 with 0 response partitions (1 implied) 12/04/2025 02:27:47.392 7fa13f45a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82072.753174, idle connection 258778.000000, request 304399.127007 12/04/2025 02:27:47.392 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 745 12/04/2025 02:27:47.392 7fa13f45a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/04/2025 02:27:47.392 7fa13f45a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 745 (601.3569831848145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=716602182, topics=[]) 12/04/2025 02:27:47.392 7fa13f45a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 716602182 with 0 response partitions (1 implied)