05/07/2026 02:30:52.235 7f782abb40e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 856 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1287725455, session_epoch=851, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.237 7f782abb40e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242415.262695, idle connection 118725.000000, request 304999.916077 05/07/2026 02:30:52.237 7f782abb40e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242414.698730, idle connection 118725.000000, request 304999.367476 05/07/2026 02:30:52.259 7f782bb09f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242165.656250, idle connection 118772.000000, request 304397.897482 05/07/2026 02:30:52.259 7f782bb09f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808 05/07/2026 02:30:52.259 7f782bb09f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.259 7f782bb09f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 808 (602.7121543884277 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=781471984, topics=[]) 05/07/2026 02:30:52.260 7f782bb09f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 781471984 with 0 response partitions (1 implied) 05/07/2026 02:30:52.308 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 201 05/07/2026 02:30:52.308 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 05/07/2026 02:30:52.308 7f7828cc4d60 [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)]) 05/07/2026 02:30:52.309 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.309 7f7828cc4d60 [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=774194858, session_epoch=838, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.309 7f7828cc4d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 843 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=774194858, session_epoch=838, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.309 7f7828cc4d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240641.346924, idle connection 117304.000000, request 304999.928713 05/07/2026 02:30:52.310 7f7828cc4d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240640.574707, idle connection 117303.000000, request 304999.169350 05/07/2026 02:30:52.310 7f7828cc4d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 843 05/07/2026 02:30:52.311 7f7828cc4d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.311 7f7828cc4d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 843 (1.6872882843017578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=774194858, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=203, last_stable_offset=203, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xc9\x00\x00\x01\xc7\x00\x00\x00\x00\x02V\xb30_\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\x90\x03\x00\x00\x00\xd2\x02ObjectVRouter:cn-jenkins-deploy-...')])]) 05/07/2026 02:30:52.311 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 774194858 with 1 response partitions (0 implied) 05/07/2026 02:30:52.311 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 467 bytes of data for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 201 05/07/2026 02:30:52.311 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 201 for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) 05/07/2026 02:30:52.312 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) to 203 (leader epoch 0) 05/07/2026 02:30:52.412 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 203 05/07/2026 02:30:52.413 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 05/07/2026 02:30:52.413 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-2', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 05/07/2026 02:30:52.413 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.413 7f7828cc4d60 [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=774194858, session_epoch=839, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=203, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.413 7f7828cc4d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 844 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=774194858, session_epoch=839, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=203, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.413 7f7828cc4d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240537.106201, idle connection 117200.000000, request 304999.929190 05/07/2026 02:30:52.414 7f7828cc4d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240536.548340, idle connection 117199.000000, request 304999.383450 05/07/2026 02:30:52.469 7f782bb094a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242090.445068, idle connection 118122.000000, request 304398.633242 05/07/2026 02:30:52.469 7f782bb094a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 817 05/07/2026 02:30:52.469 7f782bb094a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.469 7f782bb094a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 817 (601.996660232544 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2064585841, topics=[]) 05/07/2026 02:30:52.470 7f782bb094a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2064585841 with 0 response partitions (1 implied) 05/07/2026 02:30:52.473 7f782b3a9680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242574.162598, idle connection 118047.000000, request 304395.799398 05/07/2026 02:30:52.474 7f782b3a9680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 848 05/07/2026 02:30:52.474 7f782b3a9680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.474 7f782b3a9680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 848 (604.8634052276611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=209420302, topics=[]) 05/07/2026 02:30:52.474 7f782b3a9680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 209420302 with 0 response partitions (1 implied) 05/07/2026 02:30:52.475 7f782c86f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240878.781006, idle connection 118120.000000, request 304395.614147 05/07/2026 02:30:52.475 7f782bb095e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242088.314209, idle connection 118362.000000, request 304396.175861 05/07/2026 02:30:52.475 7f782b3a9180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241848.848389, idle connection 118363.000000, request 304396.713018 05/07/2026 02:30:52.475 7f782c86f540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808 05/07/2026 02:30:52.475 7f782c86f540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.475 7f782c86f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 808 (605.0164699554443 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2077578244, topics=[]) 05/07/2026 02:30:52.475 7f782c86f540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2077578244 with 0 response partitions (1 implied) 05/07/2026 02:30:52.476 7f782bb095e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808 05/07/2026 02:30:52.476 7f782bb095e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.476 7f782bb095e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 808 (604.8393249511719 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1485332719, topics=[]) 05/07/2026 02:30:52.476 7f782bb095e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1485332719 with 0 response partitions (1 implied) 05/07/2026 02:30:52.476 7f782b3a9180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 847 05/07/2026 02:30:52.476 7f782b3a9180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.476 7f782b3a9180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 847 (604.6617031097412 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2118933616, topics=[]) 05/07/2026 02:30:52.476 7f782b3a9180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2118933616 with 0 response partitions (1 implied) 05/07/2026 02:30:52.551 7f782b3a9040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242099.080322, idle connection 118230.000000, request 304396.445513 05/07/2026 02:30:52.552 7f782b3a9040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810 05/07/2026 02:30:52.552 7f782b3a9040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.552 7f782b3a9040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 810 (604.2044162750244 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=986013345, topics=[]) 05/07/2026 02:30:52.552 7f782b3a9040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 986013345 with 0 response partitions (1 implied) 05/07/2026 02:30:52.553 7f782c86f860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 24 05/07/2026 02:30:52.553 7f782c86f860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 05/07/2026 02:30:52.553 7f782c86f860 [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)]) 05/07/2026 02:30:52.553 7f782c86f860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.553 7f782c86f860 [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=1500418796, session_epoch=803, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.553 7f782c86f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 808 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1500418796, session_epoch=803, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.553 7f782c86f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241492.781738, idle connection 118234.000000, request 304999.943733 05/07/2026 02:30:52.553 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 74 05/07/2026 02:30:52.554 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 05/07/2026 02:30:52.554 7f782bb09e00 [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)]) 05/07/2026 02:30:52.554 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.554 7f782bb09e00 [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=400985060, session_epoch=816, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.554 7f782bb09e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 821 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=400985060, session_epoch=816, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.554 7f782bb09e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242610.229004, idle connection 117708.000000, request 304999.958277 05/07/2026 02:30:52.554 7f782bb09040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242127.275391, idle connection 117772.000000, request 304394.566774 05/07/2026 02:30:52.554 7f782bb09d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240987.155029, idle connection 117551.000000, request 304395.656347 05/07/2026 02:30:52.555 7f782c86f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241491.211914, idle connection 118233.000000, request 304998.380184 05/07/2026 02:30:52.555 7f782bb09e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242609.130371, idle connection 117706.000000, request 304998.863220 05/07/2026 02:30:52.555 7f782bb09040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 801 05/07/2026 02:30:52.555 7f782bb09040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.556 7f782bb09040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 801 (606.6982746124268 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=18141299, topics=[]) 05/07/2026 02:30:52.556 7f782bb09040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 18141299 with 0 response partitions (1 implied) 05/07/2026 02:30:52.556 7f782bb09d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 814 05/07/2026 02:30:52.556 7f782bb09d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.556 7f782bb09d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 814 (606.020450592041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1613898577, topics=[]) 05/07/2026 02:30:52.556 7f782bb09d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1613898577 with 0 response partitions (1 implied) 05/07/2026 02:30:52.557 7f782bb09e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 821 05/07/2026 02:30:52.557 7f782bb09e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.557 7f782bb09e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 821 (2.8040409088134766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=400985060, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00J\x00\x00\x01\x17\x00\x00\x00\x00\x02\x1fk\xe2\xc8\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\xc8\x03\x00\x00\x00\x8a\x03ObjectVMITable:default-global-sy...')])]) 05/07/2026 02:30:52.557 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 400985060 with 1 response partitions (0 implied) 05/07/2026 02:30:52.557 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-16', partition=0) with offset 74 05/07/2026 02:30:52.557 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 74 for assigned partition TopicPartition(topic='-uve-topic-16', partition=0) 05/07/2026 02:30:52.558 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-16', partition=0) to 75 (leader epoch 0) 05/07/2026 02:30:52.571 7f782b3a97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241549.704102, idle connection 118138.000000, request 304398.869276 05/07/2026 02:30:52.571 7f782b3a97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 831 05/07/2026 02:30:52.571 7f782b3a97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.571 7f782b3a97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 831 (601.8004417419434 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1350203192, topics=[]) 05/07/2026 02:30:52.571 7f782b3a97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1350203192 with 0 response partitions (1 implied) 05/07/2026 02:30:52.577 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 555 05/07/2026 02:30:52.577 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 05/07/2026 02:30:52.577 7f782b3a95e0 [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)]) 05/07/2026 02:30:52.578 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.578 7f782b3a95e0 [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=1611234378, session_epoch=890, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.578 7f782b3a95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 895 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1611234378, session_epoch=890, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.578 7f782b3a95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241773.237305, idle connection 118616.000000, request 304999.944448 05/07/2026 02:30:52.578 7f782bb092c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240966.229980, idle connection 118512.000000, request 304397.493601 05/07/2026 02:30:52.579 7f782b3a95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241772.561523, idle connection 118616.000000, request 304999.274254 05/07/2026 02:30:52.579 7f782bb092c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810 05/07/2026 02:30:52.579 7f782bb092c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.579 7f782bb092c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 810 (603.297233581543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=962563412, topics=[]) 05/07/2026 02:30:52.579 7f782bb092c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 962563412 with 0 response partitions (1 implied) 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 895 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 895 (1.7571449279785156 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1611234378, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=556, last_stable_offset=556, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x02+\x00\x00\x00\xfc\x00\x00\x00\x00\x02\xd1\x1b\xa2\xf1\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\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...')])]) 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1611234378 with 1 response partitions (0 implied) 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 264 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 555 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 555 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 05/07/2026 02:30:52.580 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 556 (leader epoch 0) 05/07/2026 02:30:52.624 7f782bb09c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 20 05/07/2026 02:30:52.624 7f782bb09c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 05/07/2026 02:30:52.624 7f782bb09c20 [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)]) 05/07/2026 02:30:52.625 7f782bb09c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.625 7f782bb09c20 [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=245404017, session_epoch=801, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.625 7f782bb09c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 806 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=245404017, session_epoch=801, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.625 7f782bb09c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241529.952148, idle connection 117637.000000, request 304999.940395 05/07/2026 02:30:52.625 7f7828cb6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240920.952881, idle connection 117362.000000, request 304398.786545 05/07/2026 02:30:52.626 7f782bb09c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241529.197998, idle connection 117637.000000, request 304999.197245 05/07/2026 02:30:52.626 7f7828cb6180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 805 05/07/2026 02:30:52.626 7f7828cb6180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.626 7f7828cb6180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 805 (602.0638942718506 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285458202, topics=[]) 05/07/2026 02:30:52.626 7f7828cb6180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1285458202 with 0 response partitions (1 implied) 05/07/2026 02:30:52.628 7f7828cb6540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240919.575684, idle connection 118081.000000, request 304398.386717 05/07/2026 02:30:52.629 7f7828cb6540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 804 05/07/2026 02:30:52.629 7f7828cb6540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.629 7f7828cb6540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 804 (602.1139621734619 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=742784301, topics=[]) 05/07/2026 02:30:52.629 7f7828cb6540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 742784301 with 0 response partitions (1 implied) 05/07/2026 02:30:52.630 7f782b3a9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241732.652100, idle connection 117804.000000, request 304397.725344 05/07/2026 02:30:52.630 7f782b3a9400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 853 05/07/2026 02:30:52.631 7f782b3a9400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.631 7f782b3a9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 853 (602.686882019043 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1315013804, topics=[]) 05/07/2026 02:30:52.631 7f782b3a9400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1315013804 with 0 response partitions (1 implied) 05/07/2026 02:30:52.631 7f782b3a9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241722.503906, idle connection 117890.000000, request 304397.785664 05/07/2026 02:30:52.631 7f782b3a9e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 849 05/07/2026 02:30:52.631 7f782b3a9e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.631 7f782b3a9e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 849 (602.5817394256592 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=883673562, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=216, last_stable_offset=216, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xd6\x00\x00\x02\x13\x00\x00\x00\x00\x02e\xad\x1c\xd5\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\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 05/07/2026 02:30:52.632 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 883673562 with 1 response partitions (0 implied) 05/07/2026 02:30:52.632 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 543 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 214 05/07/2026 02:30:52.632 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 214 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 05/07/2026 02:30:52.632 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 216 (leader epoch 0) 05/07/2026 02:30:52.657 7f782b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 206 05/07/2026 02:30:52.657 7f782b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 05/07/2026 02:30:52.658 7f782b3a9cc0 [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)]) 05/07/2026 02:30:52.658 7f782b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.658 7f782b3a9cc0 [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=282069246, session_epoch=837, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.658 7f782b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 842 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=282069246, session_epoch=837, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.658 7f782b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241768.723389, idle connection 117930.000000, request 304999.942541 05/07/2026 02:30:52.659 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 75 05/07/2026 02:30:52.659 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 05/07/2026 02:30:52.659 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-16', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 05/07/2026 02:30:52.659 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.659 7f782bb09e00 [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=400985060, session_epoch=817, topics=[(topic='-uve-topic-16', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=75, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.659 7f782bb09e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=400985060, session_epoch=817, topics=[(topic='-uve-topic-16', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=75, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.659 7f782bb09e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242505.038086, idle connection 117602.000000, request 304999.942064 05/07/2026 02:30:52.660 7f782b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241767.068359, idle connection 117928.000000, request 304998.295784 05/07/2026 02:30:52.660 7f782bb09e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242504.251465, idle connection 117602.000000, request 304999.165297 05/07/2026 02:30:52.681 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 556 05/07/2026 02:30:52.681 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 05/07/2026 02:30:52.681 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 05/07/2026 02:30:52.681 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.681 7f782b3a95e0 [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=1611234378, session_epoch=891, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=556, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.682 7f782b3a95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 896 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1611234378, session_epoch=891, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=556, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.682 7f782b3a95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241669.505859, idle connection 118513.000000, request 304999.944210 05/07/2026 02:30:52.682 7f782b3a95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241669.066650, idle connection 118512.000000, request 304999.510527 05/07/2026 02:30:52.722 7f782bb09180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240928.832764, idle connection 117264.000000, request 304398.496389 05/07/2026 02:30:52.722 7f782bb09180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 807 05/07/2026 02:30:52.722 7f782bb09180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.722 7f782bb09180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 807 (602.1475791931152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458142065, topics=[]) 05/07/2026 02:30:52.722 7f782bb09180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458142065 with 0 response partitions (1 implied) 05/07/2026 02:30:52.725 7f782abb4220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 202 05/07/2026 02:30:52.725 7f782abb4220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 05/07/2026 02:30:52.725 7f782abb4220 [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)]) 05/07/2026 02:30:52.725 7f782abb4220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.725 7f782abb4220 [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=1445879433, session_epoch=834, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.726 7f782abb4220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 839 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1445879433, session_epoch=834, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.726 7f782abb4220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241352.043213, idle connection 118586.000000, request 304999.939680 05/07/2026 02:30:52.726 7f782bb09a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240945.077148, idle connection 118112.000000, request 304397.475481 05/07/2026 02:30:52.726 7f782abb4220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241351.391602, idle connection 118586.000000, request 304999.294758 05/07/2026 02:30:52.727 7f782bb09a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 812 05/07/2026 02:30:52.727 7f782bb09a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.727 7f782bb09a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 812 (603.3768653869629 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1335061678, topics=[]) 05/07/2026 02:30:52.727 7f782bb09a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1335061678 with 0 response partitions (1 implied) 05/07/2026 02:30:52.730 7f7828cc4ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240979.130127, idle connection 117152.000000, request 304399.148703 05/07/2026 02:30:52.731 7f7828cc4ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 800 05/07/2026 02:30:52.731 7f7828cc4ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.731 7f7828cc4ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 800 (601.2909412384033 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=519389482, topics=[]) 05/07/2026 02:30:52.731 7f7828cc4ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 519389482 with 0 response partitions (1 implied) 05/07/2026 02:30:52.733 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 216 05/07/2026 02:30:52.733 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 05/07/2026 02:30:52.733 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 05/07/2026 02:30:52.733 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.733 7f782b3a9e00 [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=883673562, session_epoch=845, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=216, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.733 7f782b3a9e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 850 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883673562, session_epoch=845, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=216, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/07/2026 02:30:52.733 7f782b3a9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241620.134766, idle connection 117788.000000, request 304999.953747 05/07/2026 02:30:52.734 7f782b3a9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241619.679199, idle connection 117788.000000, request 304999.497652 05/07/2026 02:30:52.755 7f782b3a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241496.277832, idle connection 118174.000000, request 304398.857117 05/07/2026 02:30:52.756 7f782b3a9ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 819 05/07/2026 02:30:52.756 7f782b3a9ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.756 7f782b3a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 819 (601.811408996582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=749095824, topics=[]) 05/07/2026 02:30:52.756 7f782b3a9ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 749095824 with 0 response partitions (1 implied) 05/07/2026 02:30:52.787 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3890 05/07/2026 02:30:52.787 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 05/07/2026 02:30:52.787 7f782c904b80 [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)]) 05/07/2026 02:30:52.788 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.788 7f782c904b80 [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=260092402, session_epoch=1182, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.788 7f782c904b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 1187 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=260092402, session_epoch=1182, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.788 7f782c904b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240578.606934, idle connection 117253.000000, request 304999.938726 05/07/2026 02:30:52.788 7f782c904b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240578.124268, idle connection 117252.000000, request 304999.464750 05/07/2026 02:30:52.794 7f782bb917c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240965.417969, idle connection 117124.000000, request 304399.065018 05/07/2026 02:30:52.794 7f782bb917c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 800 05/07/2026 02:30:52.794 7f782bb917c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.794 7f782bb917c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 800 (601.3824939727783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=965323366, topics=[]) 05/07/2026 02:30:52.795 7f782bb917c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 965323366 with 0 response partitions (1 implied) 05/07/2026 02:30:52.809 7f782c86f180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 30 05/07/2026 02:30:52.810 7f782c86f180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 05/07/2026 02:30:52.810 7f782c86f180 [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)]) 05/07/2026 02:30:52.810 7f782c86f180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.810 7f782c86f180 [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=1807114200, session_epoch=805, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.810 7f782c86f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 810 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807114200, session_epoch=805, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.810 7f782c86f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241577.433105, idle connection 117635.000000, request 304999.940395 05/07/2026 02:30:52.811 7f782c86f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241576.947510, idle connection 117634.000000, request 304999.463081 05/07/2026 02:30:52.838 7f782abb40e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241814.162842, idle connection 118124.000000, request 304398.818970 05/07/2026 02:30:52.839 7f782abb40e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 856 05/07/2026 02:30:52.839 7f782abb40e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:52.839 7f782abb40e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 856 (601.9375324249268 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1287725455, topics=[]) 05/07/2026 02:30:52.839 7f782abb40e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1287725455 with 0 response partitions (1 implied) 05/07/2026 02:30:52.860 7f782bb09f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 50 05/07/2026 02:30:52.860 7f782bb09f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 05/07/2026 02:30:52.860 7f782bb09f40 [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)]) 05/07/2026 02:30:52.861 7f782bb09f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:52.861 7f782bb09f40 [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=781471984, session_epoch=804, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.861 7f782bb09f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=781471984, session_epoch=804, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:52.861 7f782bb09f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241563.254883, idle connection 118169.000000, request 304999.910831 05/07/2026 02:30:52.862 7f782bb09f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241562.490234, idle connection 118168.000000, request 304999.159575 05/07/2026 02:30:53.014 7f7828cc4d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239935.966064, idle connection 116598.000000, request 304398.791552 05/07/2026 02:30:53.015 7f7828cc4d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 844 05/07/2026 02:30:53.015 7f7828cc4d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.015 7f7828cc4d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 844 (601.9301414489746 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=774194858, topics=[]) 05/07/2026 02:30:53.015 7f7828cc4d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 774194858 with 0 response partitions (1 implied) 05/07/2026 02:30:53.070 7f782bb094a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 75 05/07/2026 02:30:53.070 7f782bb094a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 05/07/2026 02:30:53.070 7f782bb094a0 [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)]) 05/07/2026 02:30:53.070 7f782bb094a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.071 7f782bb094a0 [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=2064585841, session_epoch=813, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.071 7f782bb094a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 818 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2064585841, session_epoch=813, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.071 7f782bb094a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241488.270020, idle connection 117520.000000, request 304999.939203 05/07/2026 02:30:53.071 7f782bb094a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241487.774902, idle connection 117519.000000, request 304999.452829 05/07/2026 02:30:53.075 7f782b3a9680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 209 05/07/2026 02:30:53.075 7f782b3a9680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 05/07/2026 02:30:53.075 7f782b3a9680 [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)]) 05/07/2026 02:30:53.075 7f782b3a9680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.075 7f782b3a9680 [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=209420302, session_epoch=844, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.075 7f782b3a9680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 849 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209420302, session_epoch=844, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.075 7f782b3a9680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241972.381348, idle connection 117446.000000, request 304999.957323 05/07/2026 02:30:53.076 7f782b3a9680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241971.803223, idle connection 117445.000000, request 304999.381781 05/07/2026 02:30:53.076 7f782c86f540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 26 05/07/2026 02:30:53.076 7f782c86f540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 05/07/2026 02:30:53.076 7f782c86f540 [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)]) 05/07/2026 02:30:53.076 7f782c86f540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.076 7f782c86f540 [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=2077578244, session_epoch=804, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.076 7f782c86f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2077578244, session_epoch=804, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.077 7f782c86f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240276.668945, idle connection 117518.000000, request 304999.955893 05/07/2026 02:30:53.077 7f782bb095e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 43 05/07/2026 02:30:53.077 7f782bb095e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 05/07/2026 02:30:53.077 7f782bb095e0 [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)]) 05/07/2026 02:30:53.077 7f782bb095e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.077 7f782bb095e0 [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=1485332719, session_epoch=804, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.077 7f782bb095e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1485332719, session_epoch=804, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.078 7f782bb095e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241485.540283, idle connection 117759.000000, request 304999.961615 05/07/2026 02:30:53.078 7f782b3a9180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 241 05/07/2026 02:30:53.078 7f782b3a9180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 05/07/2026 02:30:53.078 7f782b3a9180 [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)]) 05/07/2026 02:30:53.078 7f782b3a9180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.078 7f782b3a9180 [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=2118933616, session_epoch=843, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.078 7f782b3a9180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 848 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2118933616, session_epoch=843, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.078 7f782b3a9180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241245.578369, idle connection 117760.000000, request 304999.965668 05/07/2026 02:30:53.079 7f782c86f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240274.815430, idle connection 117516.000000, request 304998.105526 05/07/2026 02:30:53.079 7f782bb095e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241484.102051, idle connection 117758.000000, request 304998.525143 05/07/2026 02:30:53.079 7f782b3a9180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241244.420654, idle connection 117759.000000, request 304998.806477 05/07/2026 02:30:53.153 7f782b3a9040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 51 05/07/2026 02:30:53.153 7f782b3a9040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 05/07/2026 02:30:53.153 7f782b3a9040 [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)]) 05/07/2026 02:30:53.153 7f782b3a9040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.153 7f782b3a9040 [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=986013345, session_epoch=806, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.154 7f782b3a9040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 811 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=986013345, session_epoch=806, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.154 7f782b3a9040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241496.823486, idle connection 117628.000000, request 304999.937534 05/07/2026 02:30:53.154 7f782b3a9040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241496.081055, idle connection 117627.000000, request 304999.194384 05/07/2026 02:30:53.156 7f782bb09040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 5 05/07/2026 02:30:53.156 7f782bb09040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 05/07/2026 02:30:53.156 7f782bb09040 [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)]) 05/07/2026 02:30:53.156 7f782bb09040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.156 7f782bb09040 [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=18141299, session_epoch=797, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.156 7f782bb09040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 802 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=18141299, session_epoch=797, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.157 7f782bb09040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241524.895508, idle connection 117170.000000, request 304999.937057 05/07/2026 02:30:53.157 7f782bb09d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 60 05/07/2026 02:30:53.157 7f782bb09d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 05/07/2026 02:30:53.157 7f782bb09d60 [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)]) 05/07/2026 02:30:53.157 7f782bb09d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.157 7f782bb09d60 [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=1613898577, session_epoch=810, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.157 7f782bb09d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 815 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1613898577, session_epoch=810, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.157 7f782bb09d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240384.147949, idle connection 116948.000000, request 304999.949932 05/07/2026 02:30:53.158 7f782c86f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240888.391602, idle connection 117630.000000, request 304395.559549 05/07/2026 02:30:53.158 7f782bb09040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241523.436768, idle connection 117168.000000, request 304998.482943 05/07/2026 02:30:53.158 7f782c86f860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808 05/07/2026 02:30:53.158 7f782c86f860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.159 7f782c86f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 808 (605.3874492645264 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1500418796, topics=[]) 05/07/2026 02:30:53.159 7f782c86f860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1500418796 with 0 response partitions (1 implied) 05/07/2026 02:30:53.159 7f782bb09d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240382.482666, idle connection 116946.000000, request 304998.287678 05/07/2026 02:30:53.172 7f782b3a97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 148 05/07/2026 02:30:53.172 7f782b3a97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 05/07/2026 02:30:53.172 7f782b3a97c0 [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)]) 05/07/2026 02:30:53.172 7f782b3a97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.172 7f782b3a97c0 [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=1350203192, session_epoch=827, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.172 7f782b3a97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 832 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1350203192, session_epoch=827, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.173 7f782b3a97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240947.723633, idle connection 117536.000000, request 304999.948025 05/07/2026 02:30:53.173 7f782b3a97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240947.116455, idle connection 117535.000000, request 304999.344826 05/07/2026 02:30:53.180 7f782bb092c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 36 05/07/2026 02:30:53.180 7f782bb092c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 05/07/2026 02:30:53.180 7f782bb092c0 [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)]) 05/07/2026 02:30:53.180 7f782bb092c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.180 7f782bb092c0 [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=962563412, session_epoch=806, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.180 7f782bb092c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 811 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=962563412, session_epoch=806, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.180 7f782bb092c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240364.307373, idle connection 117910.000000, request 304999.953270 05/07/2026 02:30:53.181 7f782bb092c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240363.773926, idle connection 117910.000000, request 304999.423027 05/07/2026 02:30:53.227 7f7828cb6180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 14 05/07/2026 02:30:53.228 7f7828cb6180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 05/07/2026 02:30:53.228 7f7828cb6180 [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)]) 05/07/2026 02:30:53.228 7f7828cb6180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.228 7f7828cb6180 [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=1285458202, session_epoch=801, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.228 7f7828cb6180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 806 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285458202, session_epoch=801, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.229 7f7828cb6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240317.643555, idle connection 116758.000000, request 304999.922514 05/07/2026 02:30:53.229 7f782bb09c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240925.923096, idle connection 117033.000000, request 304395.915747 05/07/2026 02:30:53.229 7f7828cb6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240316.733643, idle connection 116757.000000, request 304999.026775 05/07/2026 02:30:53.230 7f782bb09c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 806 05/07/2026 02:30:53.230 7f782bb09c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.230 7f782bb09c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 806 (605.013370513916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=245404017, topics=[]) 05/07/2026 02:30:53.230 7f782bb09c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 245404017 with 0 response partitions (1 implied) 05/07/2026 02:30:53.230 7f7828cb6540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 12 05/07/2026 02:30:53.230 7f7828cb6540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 05/07/2026 02:30:53.230 7f7828cb6540 [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)]) 05/07/2026 02:30:53.231 7f7828cb6540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.231 7f7828cb6540 [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=742784301, session_epoch=800, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.231 7f7828cb6540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 805 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742784301, session_epoch=800, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.231 7f7828cb6540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240317.012451, idle connection 117478.000000, request 304999.960661 05/07/2026 02:30:53.231 7f7828cb6540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240316.407471, idle connection 117478.000000, request 304999.358177 05/07/2026 02:30:53.232 7f782b3a9400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 339 05/07/2026 02:30:53.232 7f782b3a9400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 05/07/2026 02:30:53.232 7f782b3a9400 [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)]) 05/07/2026 02:30:53.232 7f782b3a9400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.232 7f782b3a9400 [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=1315013804, session_epoch=849, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.232 7f782b3a9400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 854 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1315013804, session_epoch=849, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.232 7f782b3a9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241130.668213, idle connection 117202.000000, request 304999.962330 05/07/2026 02:30:53.233 7f782b3a9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241130.130127, idle connection 117201.000000, request 304999.425888 05/07/2026 02:30:53.260 7f782b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241166.288330, idle connection 117327.000000, request 304397.507191 05/07/2026 02:30:53.261 7f782b3a9cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 842 05/07/2026 02:30:53.261 7f782b3a9cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.261 7f782b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 842 (603.1148433685303 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=282069246, topics=[]) 05/07/2026 02:30:53.261 7f782b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 282069246 with 0 response partitions (1 implied) 05/07/2026 02:30:53.262 7f782bb09e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241902.728516, idle connection 117000.000000, request 304397.639275 05/07/2026 02:30:53.262 7f782bb09e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 822 05/07/2026 02:30:53.262 7f782bb09e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.262 7f782bb09e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 822 (602.7131080627441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=400985060, topics=[]) 05/07/2026 02:30:53.262 7f782bb09e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 400985060 with 0 response partitions (1 implied) 05/07/2026 02:30:53.283 7f782b3a95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241068.582764, idle connection 117912.000000, request 304399.013996 05/07/2026 02:30:53.283 7f782b3a95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 896 05/07/2026 02:30:53.283 7f782b3a95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.283 7f782b3a95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 896 (601.5152931213379 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1611234378, topics=[]) 05/07/2026 02:30:53.283 7f782b3a95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1611234378 with 0 response partitions (1 implied) 05/07/2026 02:30:53.323 7f782bb09180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 22 05/07/2026 02:30:53.323 7f782bb09180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 05/07/2026 02:30:53.323 7f782bb09180 [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)]) 05/07/2026 02:30:53.323 7f782bb09180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.323 7f782bb09180 [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=458142065, session_epoch=803, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.324 7f782bb09180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 808 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458142065, session_epoch=803, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.324 7f782bb09180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240326.575439, idle connection 116661.000000, request 304999.939680 05/07/2026 02:30:53.324 7f782bb09180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240326.086670, idle connection 116661.000000, request 304999.459743 05/07/2026 02:30:53.327 7f782bb09a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 50 05/07/2026 02:30:53.327 7f782bb09a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 05/07/2026 02:30:53.327 7f782bb09a40 [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)]) 05/07/2026 02:30:53.328 7f782bb09a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.328 7f782bb09a40 [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=1335061678, session_epoch=808, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.328 7f782bb09a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 813 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1335061678, session_epoch=808, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.328 7f782bb09a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240343.143799, idle connection 117510.000000, request 304999.952078 05/07/2026 02:30:53.328 7f782abb4220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240749.618408, idle connection 117984.000000, request 304397.520781 05/07/2026 02:30:53.328 7f782bb09a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240342.604248, idle connection 117510.000000, request 304999.416351 05/07/2026 02:30:53.329 7f782abb4220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 839 05/07/2026 02:30:53.329 7f782abb4220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.329 7f782abb4220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 839 (603.2240390777588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1445879433, topics=[]) 05/07/2026 02:30:53.329 7f782abb4220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1445879433 with 0 response partitions (1 implied) 05/07/2026 02:30:53.331 7f7828cc4ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 05/07/2026 02:30:53.331 7f7828cc4ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 05/07/2026 02:30:53.331 7f7828cc4ea0 [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)]) 05/07/2026 02:30:53.332 7f7828cc4ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.332 7f7828cc4ea0 [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=519389482, session_epoch=796, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.332 7f7828cc4ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 801 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=519389482, session_epoch=796, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.332 7f7828cc4ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240377.638672, idle connection 116550.000000, request 304999.941826 05/07/2026 02:30:53.332 7f7828cc4ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240377.281982, idle connection 116550.000000, request 304999.592304 05/07/2026 02:30:53.334 7f782b3a9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241019.278809, idle connection 117187.000000, request 304399.099827 05/07/2026 02:30:53.334 7f782b3a9e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 850 05/07/2026 02:30:53.335 7f782b3a9e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.335 7f782b3a9e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 850 (601.33957862854 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=883673562, topics=[]) 05/07/2026 02:30:53.335 7f782b3a9e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 883673562 with 0 response partitions (1 implied) 05/07/2026 02:30:53.368 7f782b3a9ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 75 05/07/2026 02:30:53.368 7f782b3a9ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 05/07/2026 02:30:53.369 7f782b3a9ae0 [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)]) 05/07/2026 02:30:53.369 7f782b3a9ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.369 7f782b3a9ae0 [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=749095824, session_epoch=815, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.369 7f782b3a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 820 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=749095824, session_epoch=815, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.369 7f782b3a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240882.320068, idle connection 117560.000000, request 304999.942541 05/07/2026 02:30:53.372 7f782b3a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240879.329590, idle connection 117557.000000, request 304996.959925 05/07/2026 02:30:53.389 7f782c904b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239977.546875, idle connection 116652.000000, request 304398.881197 05/07/2026 02:30:53.389 7f782c904b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1187 05/07/2026 02:30:53.390 7f782c904b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.390 7f782c904b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 1187 (601.7544269561768 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=260092402, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3891, last_stable_offset=3891, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f2\x00\x00\x01\x04\x00\x00\x00\x00\x02\xd0R\rQ\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...')])]) 05/07/2026 02:30:53.390 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 260092402 with 1 response partitions (0 implied) 05/07/2026 02:30:53.390 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3890 05/07/2026 02:30:53.390 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3890 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 05/07/2026 02:30:53.390 7f782c904b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3891 (leader epoch 0) 05/07/2026 02:30:53.395 7f782bb917c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 05/07/2026 02:30:53.395 7f782bb917c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 05/07/2026 02:30:53.395 7f782bb917c0 [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)]) 05/07/2026 02:30:53.395 7f782bb917c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.395 7f782bb917c0 [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=965323366, session_epoch=796, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.395 7f782bb917c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 801 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=965323366, session_epoch=796, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.396 7f782bb917c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240363.537598, idle connection 116522.000000, request 304999.930382 05/07/2026 02:30:53.396 7f782bb917c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240362.960205, idle connection 116522.000000, request 304999.358892 05/07/2026 02:30:53.411 7f782c86f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240976.436523, idle connection 117034.000000, request 304398.945093 05/07/2026 02:30:53.412 7f782c86f180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810 05/07/2026 02:30:53.412 7f782c86f180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/07/2026 02:30:53.412 7f782c86f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 810 (601.6833782196045 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1807114200, topics=[]) 05/07/2026 02:30:53.412 7f782c86f180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1807114200 with 0 response partitions (1 implied) 05/07/2026 02:30:53.439 7f782abb40e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 223 05/07/2026 02:30:53.440 7f782abb40e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 05/07/2026 02:30:53.440 7f782abb40e0 [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)]) 05/07/2026 02:30:53.440 7f782abb40e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/07/2026 02:30:53.440 7f782abb40e0 [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=1287725455, session_epoch=852, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.440 7f782abb40e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 857 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1287725455, session_epoch=852, topics=[], forgotten_topics_data=[]) 05/07/2026 02:30:53.440 7f782abb40e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241211.967529, idle connection 117522.000000, request 304999.941111 05/07/2026 02:30:53.441 7f782abb40e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241211.412109, idle connection 117522.000000, request 304999.391079