01/05/2026 02:15:04.491 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85398.461426, idle connection 263011.000000, request 304999.952555 01/05/2026 02:15:04.492 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85397.083496, idle connection 263010.000000, request 304998.579264 01/05/2026 02:15:04.500 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85340.809570, idle connection 263004.000000, request 304399.224043 01/05/2026 02:15:04.500 7f45c8ac6360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 732 01/05/2026 02:15:04.500 7f45c8ac6360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.500 7f45c8ac6360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 732 (601.1509895324707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1654912196, topics=[]) 01/05/2026 02:15:04.500 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1654912196 with 0 response partitions (1 implied) 01/05/2026 02:15:04.544 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85663.325195, idle connection 263377.000000, request 304391.952038 01/05/2026 02:15:04.545 7f45c6b3c4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 01/05/2026 02:15:04.545 7f45c6b3c4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.545 7f45c6b3c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (608.5422039031982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=280741215, topics=[]) 01/05/2026 02:15:04.545 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 280741215 with 0 response partitions (1 implied) 01/05/2026 02:15:04.545 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84924.334961, idle connection 262366.000000, request 304392.210960 01/05/2026 02:15:04.545 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 263 01/05/2026 02:15:04.545 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 01/05/2026 02:15:04.545 7f45c8ac64a0 [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)]) 01/05/2026 02:15:04.545 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.546 7f45c8ac64a0 [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=985321860, session_epoch=726, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.546 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 730 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=985321860, session_epoch=726, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.546 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85496.556152, idle connection 263061.000000, request 304999.963284 01/05/2026 02:15:04.546 7f45c6b1d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 685 01/05/2026 02:15:04.546 7f45c6b1d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.546 7f45c6b1d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 685 (608.7393760681152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2034029383, topics=[]) 01/05/2026 02:15:04.546 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2034029383 with 0 response partitions (1 implied) 01/05/2026 02:15:04.546 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85747.635254, idle connection 263642.000000, request 304392.253399 01/05/2026 02:15:04.547 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86083.972656, idle connection 262896.000000, request 304393.100500 01/05/2026 02:15:04.547 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85498.397461, idle connection 263375.000000, request 304395.123720 01/05/2026 02:15:04.547 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85288.647217, idle connection 263031.000000, request 304396.069527 01/05/2026 02:15:04.547 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85495.244385, idle connection 263060.000000, request 304998.653889 01/05/2026 02:15:04.547 7f45c8ac6180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 01/05/2026 02:15:04.547 7f45c8ac6180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.547 7f45c8ac6180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 697 (608.6950302124023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1292325359, topics=[]) 01/05/2026 02:15:04.548 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1292325359 with 0 response partitions (1 implied) 01/05/2026 02:15:04.548 7f45c8060d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 714 01/05/2026 02:15:04.548 7f45c8060d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.548 7f45c8060d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 714 (608.154296875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1021366735, topics=[]) 01/05/2026 02:15:04.548 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1021366735 with 0 response partitions (1 implied) 01/05/2026 02:15:04.548 7f45c8ac6720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 724 01/05/2026 02:15:04.548 7f45c8ac6720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.548 7f45c8ac6720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 724 (606.543779373169 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=183967424, topics=[]) 01/05/2026 02:15:04.548 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 183967424 with 0 response partitions (1 implied) 01/05/2026 02:15:04.549 7f45c8060ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 01/05/2026 02:15:04.549 7f45c8060ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.549 7f45c8060ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 697 (605.9119701385498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=623893293, topics=[]) 01/05/2026 02:15:04.549 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 623893293 with 0 response partitions (1 implied) 01/05/2026 02:15:04.549 7f45c8ac64a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 730 01/05/2026 02:15:04.549 7f45c8ac64a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.549 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 730 (3.605365753173828 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=985321860, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=265, last_stable_offset=265, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01\x07\x00\x00\x02\x0f\x00\x00\x00\x00\x02\xcd\x1f\x9f\xb6\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\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/05/2026 02:15:04.550 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 985321860 with 1 response partitions (0 implied) 01/05/2026 02:15:04.550 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 539 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 263 01/05/2026 02:15:04.550 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 263 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) 01/05/2026 02:15:04.550 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 265 (leader epoch 0) 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85299.348633, idle connection 263203.000000, request 304399.115324 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1032 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1032 (601.3503074645996 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=166654786, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3722, last_stable_offset=3722, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\x89\x00\x00\x01\x04\x00\x00\x00\x00\x02H\xc6\xa6V\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...')])]) 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 166654786 with 1 response partitions (0 implied) 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3721 01/05/2026 02:15:04.597 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3721 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/05/2026 02:15:04.598 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3722 (leader epoch 0) 01/05/2026 02:15:04.599 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 89 01/05/2026 02:15:04.599 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 01/05/2026 02:15:04.599 7f45c8060ae0 [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)]) 01/05/2026 02:15:04.599 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.599 7f45c8060ae0 [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=1715580312, session_epoch=693, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.599 7f45c8060ae0 [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=1715580312, session_epoch=693, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.599 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85690.482178, idle connection 262981.000000, request 304999.957800 01/05/2026 02:15:04.600 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85690.132324, idle connection 262981.000000, request 304999.612331 01/05/2026 02:15:04.651 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 265 01/05/2026 02:15:04.651 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 01/05/2026 02:15:04.651 7f45c8ac64a0 [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)]) 01/05/2026 02:15:04.651 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.652 7f45c8ac64a0 [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=985321860, session_epoch=727, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=265, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:04.652 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 731 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=985321860, session_epoch=727, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=265, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:04.652 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85390.405518, idle connection 262955.000000, request 304999.947786 01/05/2026 02:15:04.652 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85389.999268, idle connection 262955.000000, request 304999.548197 01/05/2026 02:15:04.698 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3722 01/05/2026 02:15:04.698 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/05/2026 02:15:04.698 7f45c6a88900 [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)]) 01/05/2026 02:15:04.699 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.699 7f45c6a88900 [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=166654786, session_epoch=1029, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3722, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:04.699 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1033 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=166654786, session_epoch=1029, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3722, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:04.699 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85196.877441, idle connection 263101.000000, request 304999.945641 01/05/2026 02:15:04.700 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85196.388916, idle connection 263100.000000, request 304999.466181 01/05/2026 02:15:04.720 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 31 01/05/2026 02:15:04.720 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 01/05/2026 02:15:04.720 7f45c7129900 [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)]) 01/05/2026 02:15:04.721 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.721 7f45c7129900 [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=1070944470, session_epoch=688, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.721 7f45c7129900 [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=1070944470, session_epoch=688, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.721 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85032.827881, idle connection 262960.000000, request 304999.948263 01/05/2026 02:15:04.721 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85032.401367, idle connection 262959.000000, request 304999.530077 01/05/2026 02:15:04.783 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 78 01/05/2026 02:15:04.783 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 01/05/2026 02:15:04.783 7f45c8ac6ae0 [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)]) 01/05/2026 02:15:04.783 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.784 7f45c8ac6ae0 [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=1408973625, session_epoch=690, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.784 7f45c8ac6ae0 [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=1408973625, session_epoch=690, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.784 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85005.433838, idle connection 263593.000000, request 304999.948978 01/05/2026 02:15:04.784 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85004.878174, idle connection 263593.000000, request 304999.388695 01/05/2026 02:15:04.787 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 01/05/2026 02:15:04.787 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 01/05/2026 02:15:04.787 7f45c8060400 [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)]) 01/05/2026 02:15:04.787 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.787 7f45c8060400 [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=174895429, session_epoch=678, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.787 7f45c8060400 [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=174895429, session_epoch=678, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.788 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85049.586914, idle connection 262428.000000, request 304999.960184 01/05/2026 02:15:04.788 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 79 01/05/2026 02:15:04.788 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 01/05/2026 02:15:04.788 7f45c8060cc0 [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)]) 01/05/2026 02:15:04.788 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.788 7f45c8060cc0 [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=355757593, session_epoch=693, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.788 7f45c8060cc0 [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=355757593, session_epoch=693, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.788 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85238.196045, idle connection 262627.000000, request 304999.966383 01/05/2026 02:15:04.789 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85048.616211, idle connection 262427.000000, request 304998.994350 01/05/2026 02:15:04.789 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85237.614258, idle connection 262626.000000, request 304999.384403 01/05/2026 02:15:04.794 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 34 01/05/2026 02:15:04.794 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 01/05/2026 02:15:04.794 7f45c71295e0 [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)]) 01/05/2026 02:15:04.794 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.795 7f45c71295e0 [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=1111964764, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.795 7f45c71295e0 [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=1111964764, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.795 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85043.861572, idle connection 262431.000000, request 304999.964476 01/05/2026 02:15:04.795 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 01/05/2026 02:15:04.795 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 01/05/2026 02:15:04.795 7f45c8060220 [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)]) 01/05/2026 02:15:04.795 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.795 7f45c8060220 [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=474123149, session_epoch=683, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.795 7f45c8060220 [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=474123149, session_epoch=683, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.795 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85055.645020, idle connection 262987.000000, request 304999.966621 01/05/2026 02:15:04.796 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85447.629639, idle connection 262977.000000, request 304397.220850 01/05/2026 02:15:04.796 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85042.739258, idle connection 262430.000000, request 304998.845100 01/05/2026 02:15:04.796 7f45c80604a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 01/05/2026 02:15:04.796 7f45c80604a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.796 7f45c80604a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (603.5428047180176 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2058790469, topics=[]) 01/05/2026 02:15:04.797 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2058790469 with 0 response partitions (1 implied) 01/05/2026 02:15:04.797 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85054.153076, idle connection 262986.000000, request 304998.475552 01/05/2026 02:15:04.821 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 236 01/05/2026 02:15:04.822 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 01/05/2026 02:15:04.822 7f45c8ac67c0 [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)]) 01/05/2026 02:15:04.822 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.822 7f45c8ac67c0 [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=343967102, session_epoch=726, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.822 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 730 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=343967102, session_epoch=726, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.822 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85534.867920, idle connection 262850.000000, request 304999.952555 01/05/2026 02:15:04.822 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85611.534668, idle connection 262785.000000, request 304396.952391 01/05/2026 02:15:04.823 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85534.233887, idle connection 262850.000000, request 304999.324799 01/05/2026 02:15:04.823 7f45c8ac6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 727 01/05/2026 02:15:04.823 7f45c8ac6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.823 7f45c8ac6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 727 (603.7807464599609 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=696521521, topics=[]) 01/05/2026 02:15:04.823 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 696521521 with 0 response partitions (1 implied) 01/05/2026 02:15:04.824 7f45c8ac67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 730 01/05/2026 02:15:04.824 7f45c8ac67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.824 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 730 (1.5854835510253906 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=343967102, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=238, last_stable_offset=238, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xec\x00\x00\x02\x17\x00\x00\x00\x00\x02H\xf7E1\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...')])]) 01/05/2026 02:15:04.824 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 343967102 with 1 response partitions (0 implied) 01/05/2026 02:15:04.824 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 236 01/05/2026 02:15:04.824 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 236 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 01/05/2026 02:15:04.825 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 238 (leader epoch 0) 01/05/2026 02:15:04.846 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84472.103027, idle connection 263065.000000, request 304399.061680 01/05/2026 02:15:04.846 7f45c8034d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 680 01/05/2026 02:15:04.846 7f45c8034d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.846 7f45c8034d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 680 (601.564884185791 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1340736141, topics=[]) 01/05/2026 02:15:04.847 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1340736141 with 0 response partitions (1 implied) 01/05/2026 02:15:04.849 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84471.151367, idle connection 263063.000000, request 304399.381638 01/05/2026 02:15:04.849 7f45c8034f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 680 01/05/2026 02:15:04.849 7f45c8034f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.849 7f45c8034f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 680 (600.9969711303711 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=815321932, topics=[]) 01/05/2026 02:15:04.849 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 815321932 with 0 response partitions (1 implied) 01/05/2026 02:15:04.850 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85042.044922, idle connection 262267.000000, request 304398.795366 01/05/2026 02:15:04.850 7f45c716dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 01/05/2026 02:15:04.850 7f45c716dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.850 7f45c716dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.5334129333496 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1684080472, topics=[]) 01/05/2026 02:15:04.851 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1684080472 with 0 response partitions (1 implied) 01/05/2026 02:15:04.851 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85794.612549, idle connection 263191.000000, request 304398.418903 01/05/2026 02:15:04.852 7f45c6a5ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 01/05/2026 02:15:04.852 7f45c6a5ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.852 7f45c6a5ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 684 (601.8531322479248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=629736805, topics=[]) 01/05/2026 02:15:04.852 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 629736805 with 0 response partitions (1 implied) 01/05/2026 02:15:04.852 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84062.244385, idle connection 262694.000000, request 304398.563147 01/05/2026 02:15:04.852 7f45c80605e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 01/05/2026 02:15:04.852 7f45c80605e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:04.852 7f45c80605e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.7117500305176 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1460430259, topics=[]) 01/05/2026 02:15:04.852 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1460430259 with 0 response partitions (1 implied) 01/05/2026 02:15:04.925 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 238 01/05/2026 02:15:04.925 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 01/05/2026 02:15:04.925 7f45c8ac67c0 [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)]) 01/05/2026 02:15:04.925 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.926 7f45c8ac67c0 [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=343967102, session_epoch=727, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=238, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:04.926 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 731 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=343967102, session_epoch=727, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=238, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:04.926 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85430.839600, idle connection 262746.000000, request 304999.924183 01/05/2026 02:15:04.927 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85429.956299, idle connection 262746.000000, request 304999.053240 01/05/2026 02:15:04.950 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 01/05/2026 02:15:04.950 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 01/05/2026 02:15:04.950 7f45c7109ea0 [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)]) 01/05/2026 02:15:04.950 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:04.950 7f45c7109ea0 [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=1502574973, session_epoch=681, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.951 7f45c7109ea0 [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=1502574973, session_epoch=681, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:04.951 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85178.109375, idle connection 262628.000000, request 304999.948502 01/05/2026 02:15:04.951 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85177.685791, idle connection 262627.000000, request 304999.532223 01/05/2026 02:15:05.049 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 235 01/05/2026 02:15:05.049 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 01/05/2026 02:15:05.050 7f45c8ac65e0 [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)]) 01/05/2026 02:15:05.050 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.050 7f45c8ac65e0 [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=1920914818, session_epoch=724, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.050 7f45c8ac65e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 728 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1920914818, session_epoch=724, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.050 7f45c8ac65e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84974.752197, idle connection 263168.000000, request 304999.950409 01/05/2026 02:15:05.050 7f45c8ac65e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84974.262207, idle connection 263167.000000, request 304999.464750 01/05/2026 02:15:05.051 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 340 01/05/2026 02:15:05.051 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/05/2026 02:15:05.051 7f45c8ac6040 [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)]) 01/05/2026 02:15:05.051 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.051 7f45c8ac6040 [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=1462508730, session_epoch=739, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.052 7f45c8ac6040 [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=1462508730, session_epoch=739, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.052 7f45c8ac6040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84790.079590, idle connection 262768.000000, request 304999.954462 01/05/2026 02:15:05.052 7f45c8060c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85289.885498, idle connection 263167.000000, request 304397.086859 01/05/2026 02:15:05.052 7f45c80600e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85067.109375, idle connection 262368.000000, request 304397.566080 01/05/2026 02:15:05.052 7f45c8ac6040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84789.339844, idle connection 262768.000000, request 304999.214172 01/05/2026 02:15:05.053 7f45c8060c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 723 01/05/2026 02:15:05.053 7f45c8060c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.053 7f45c8060c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 723 (603.9371490478516 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1104920570, topics=[]) 01/05/2026 02:15:05.053 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1104920570 with 0 response partitions (1 implied) 01/05/2026 02:15:05.053 7f45c80600e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 719 01/05/2026 02:15:05.053 7f45c80600e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.054 7f45c80600e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 719 (603.8999557495117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=668211825, topics=[]) 01/05/2026 02:15:05.054 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 668211825 with 0 response partitions (1 implied) 01/05/2026 02:15:05.093 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84796.628418, idle connection 262410.000000, request 304398.055315 01/05/2026 02:15:05.093 7f45c6b3cb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 01/05/2026 02:15:05.093 7f45c6b3cb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.093 7f45c6b3cb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (602.5106906890869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=66696372, topics=[]) 01/05/2026 02:15:05.093 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 66696372 with 0 response partitions (1 implied) 01/05/2026 02:15:05.101 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 222 01/05/2026 02:15:05.101 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 01/05/2026 02:15:05.101 7f45c8ac6360 [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)]) 01/05/2026 02:15:05.101 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.102 7f45c8ac6360 [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=1654912196, session_epoch=729, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.102 7f45c8ac6360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 733 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1654912196, session_epoch=729, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.102 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84738.651367, idle connection 262401.000000, request 304999.954939 01/05/2026 02:15:05.102 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84738.285645, idle connection 262401.000000, request 304999.594212 01/05/2026 02:15:05.146 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 27 01/05/2026 02:15:05.146 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/05/2026 02:15:05.146 7f45c6b3c4a0 [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)]) 01/05/2026 02:15:05.146 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.146 7f45c6b3c4a0 [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=280741215, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.146 7f45c6b3c4a0 [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=280741215, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.146 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85061.169678, idle connection 262774.000000, request 304999.946356 01/05/2026 02:15:05.147 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85060.763428, idle connection 262774.000000, request 304999.549150 01/05/2026 02:15:05.147 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 20 01/05/2026 02:15:05.148 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 01/05/2026 02:15:05.148 7f45c6b1d0e0 [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)]) 01/05/2026 02:15:05.148 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.148 7f45c6b1d0e0 [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=2034029383, session_epoch=682, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.148 7f45c6b1d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034029383, session_epoch=682, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.148 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84321.368164, idle connection 261763.000000, request 304999.959707 01/05/2026 02:15:05.149 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84320.979248, idle connection 261762.000000, request 304999.573946 01/05/2026 02:15:05.149 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 118 01/05/2026 02:15:05.149 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 01/05/2026 02:15:05.149 7f45c8ac6180 [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)]) 01/05/2026 02:15:05.149 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.149 7f45c8ac6180 [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=1292325359, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.149 7f45c8ac6180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 698 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292325359, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.149 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85144.857422, idle connection 263039.000000, request 304999.963284 01/05/2026 02:15:05.149 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 142 01/05/2026 02:15:05.149 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 01/05/2026 02:15:05.150 7f45c8060d60 [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)]) 01/05/2026 02:15:05.150 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.150 7f45c8060d60 [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=1021366735, session_epoch=711, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.150 7f45c8060d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 715 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1021366735, session_epoch=711, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.150 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85480.681396, idle connection 262293.000000, request 304999.964714 01/05/2026 02:15:05.150 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 241 01/05/2026 02:15:05.150 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 01/05/2026 02:15:05.150 7f45c8ac6720 [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)]) 01/05/2026 02:15:05.150 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.151 7f45c8ac6720 [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=183967424, session_epoch=721, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.151 7f45c8ac6720 [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=183967424, session_epoch=721, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.151 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84894.380615, idle connection 262771.000000, request 304999.965668 01/05/2026 02:15:05.151 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 64 01/05/2026 02:15:05.151 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/05/2026 02:15:05.151 7f45c8060ea0 [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)]) 01/05/2026 02:15:05.151 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.151 7f45c8060ea0 [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=623893293, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.151 7f45c8060ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 698 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=623893293, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.151 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84684.156250, idle connection 262426.000000, request 304999.968290 01/05/2026 02:15:05.152 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85142.462891, idle connection 263037.000000, request 304997.571468 01/05/2026 02:15:05.152 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85478.666504, idle connection 262291.000000, request 304997.954369 01/05/2026 02:15:05.152 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84892.861328, idle connection 262769.000000, request 304998.446465 01/05/2026 02:15:05.153 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84682.876221, idle connection 262425.000000, request 304998.690844 01/05/2026 02:15:05.200 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85089.769043, idle connection 262381.000000, request 304399.240255 01/05/2026 02:15:05.200 7f45c8060ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 01/05/2026 02:15:05.201 7f45c8060ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.201 7f45c8060ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 697 (601.2635231018066 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1715580312, topics=[]) 01/05/2026 02:15:05.201 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1715580312 with 0 response partitions (1 implied) 01/05/2026 02:15:05.253 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84789.485840, idle connection 262354.000000, request 304399.028301 01/05/2026 02:15:05.253 7f45c8ac64a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 731 01/05/2026 02:15:05.253 7f45c8ac64a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.253 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 731 (601.581335067749 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=985321860, topics=[]) 01/05/2026 02:15:05.254 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 985321860 with 0 response partitions (1 implied) 01/05/2026 02:15:05.300 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84595.952881, idle connection 262500.000000, request 304399.021149 01/05/2026 02:15:05.300 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1033 01/05/2026 02:15:05.300 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.301 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1033 (601.5470027923584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=166654786, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3723, last_stable_offset=3723, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\x8a\x00\x00\x00\xf8\x00\x00\x00\x00\x02\xcc\xb5\xd2\x9c\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...')])]) 01/05/2026 02:15:05.301 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 166654786 with 1 response partitions (0 implied) 01/05/2026 02:15:05.301 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 260 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3722 01/05/2026 02:15:05.301 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3722 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/05/2026 02:15:05.301 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3723 (leader epoch 0) 01/05/2026 02:15:05.323 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84431.138428, idle connection 262358.000000, request 304398.258686 01/05/2026 02:15:05.323 7f45c7129900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 01/05/2026 02:15:05.323 7f45c7129900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.323 7f45c7129900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 692 (602.2355556488037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1070944470, topics=[]) 01/05/2026 02:15:05.323 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1070944470 with 0 response partitions (1 implied) 01/05/2026 02:15:05.385 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84404.349365, idle connection 262992.000000, request 304398.863554 01/05/2026 02:15:05.385 7f45c8ac6ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 01/05/2026 02:15:05.385 7f45c8ac6ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.385 7f45c8ac6ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 694 (601.6526222229004 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1408973625, topics=[]) 01/05/2026 02:15:05.386 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1408973625 with 0 response partitions (1 implied) 01/05/2026 02:15:05.389 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84447.974609, idle connection 261826.000000, request 304398.347616 01/05/2026 02:15:05.389 7f45c8060400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 01/05/2026 02:15:05.390 7f45c8060400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.390 7f45c8060400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (602.0541191101074 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=174895429, topics=[]) 01/05/2026 02:15:05.390 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 174895429 with 0 response partitions (1 implied) 01/05/2026 02:15:05.390 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84636.529785, idle connection 262025.000000, request 304398.300171 01/05/2026 02:15:05.390 7f45c8060cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 01/05/2026 02:15:05.390 7f45c8060cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.390 7f45c8060cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 697 (602.0674705505371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=355757593, topics=[]) 01/05/2026 02:15:05.390 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 355757593 with 0 response partitions (1 implied) 01/05/2026 02:15:05.397 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 44 01/05/2026 02:15:05.397 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 01/05/2026 02:15:05.397 7f45c80604a0 [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)]) 01/05/2026 02:15:05.397 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.397 7f45c80604a0 [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=2058790469, session_epoch=684, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.397 7f45c80604a0 [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=2058790469, session_epoch=684, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.397 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84845.771240, idle connection 262375.000000, request 304999.953985 01/05/2026 02:15:05.398 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84440.931152, idle connection 261828.000000, request 304397.034168 01/05/2026 02:15:05.398 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84453.252197, idle connection 262385.000000, request 304397.574902 01/05/2026 02:15:05.398 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84845.099854, idle connection 262374.000000, request 304999.289274 01/05/2026 02:15:05.398 7f45c71295e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 01/05/2026 02:15:05.398 7f45c71295e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.399 7f45c71295e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (603.7836074829102 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1111964764, topics=[]) 01/05/2026 02:15:05.399 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1111964764 with 0 response partitions (1 implied) 01/05/2026 02:15:05.399 7f45c8060220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 01/05/2026 02:15:05.399 7f45c8060220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.399 7f45c8060220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (603.5397052764893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=474123149, topics=[]) 01/05/2026 02:15:05.399 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 474123149 with 0 response partitions (1 implied) 01/05/2026 02:15:05.402 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3723 01/05/2026 02:15:05.402 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/05/2026 02:15:05.402 7f45c6a88900 [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)]) 01/05/2026 02:15:05.402 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.402 7f45c6a88900 [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=166654786, session_epoch=1030, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3723, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:05.403 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1034 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=166654786, session_epoch=1030, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3723, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:05.403 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84492.957275, idle connection 262397.000000, request 304999.955654 01/05/2026 02:15:05.403 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84492.641846, idle connection 262397.000000, request 304999.644756 01/05/2026 02:15:05.425 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 241 01/05/2026 02:15:05.425 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/05/2026 02:15:05.425 7f45c8ac6860 [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)]) 01/05/2026 02:15:05.425 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.425 7f45c8ac6860 [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=696521521, session_epoch=724, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.426 7f45c8ac6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 728 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=696521521, session_epoch=724, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.426 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85008.294922, idle connection 262182.000000, request 304999.954700 01/05/2026 02:15:05.428 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85005.544678, idle connection 262179.000000, request 304997.209787 01/05/2026 02:15:05.447 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 01/05/2026 02:15:05.447 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 01/05/2026 02:15:05.447 7f45c8034d60 [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)]) 01/05/2026 02:15:05.447 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.447 7f45c8034d60 [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=1340736141, session_epoch=677, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.447 7f45c8034d60 [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=1340736141, session_epoch=677, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.448 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83870.312744, idle connection 262463.000000, request 304999.954462 01/05/2026 02:15:05.448 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83869.833252, idle connection 262462.000000, request 304999.480009 01/05/2026 02:15:05.449 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/05/2026 02:15:05.450 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 01/05/2026 02:15:05.450 7f45c8034f40 [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)]) 01/05/2026 02:15:05.450 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.450 7f45c8034f40 [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=815321932, session_epoch=677, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.450 7f45c8034f40 [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=815321932, session_epoch=677, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.450 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83869.656494, idle connection 262461.000000, request 304999.962091 01/05/2026 02:15:05.450 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83869.349609, idle connection 262461.000000, request 304999.657869 01/05/2026 02:15:05.451 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 01/05/2026 02:15:05.451 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 01/05/2026 02:15:05.451 7f45c716dea0 [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)]) 01/05/2026 02:15:05.451 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.451 7f45c716dea0 [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=1684080472, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.451 7f45c716dea0 [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=1684080472, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.451 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84440.646729, idle connection 261665.000000, request 304999.966621 01/05/2026 02:15:05.452 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84440.375732, idle connection 261665.000000, request 304999.697924 01/05/2026 02:15:05.452 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 01/05/2026 02:15:05.452 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 01/05/2026 02:15:05.452 7f45c6a5ba40 [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)]) 01/05/2026 02:15:05.452 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.452 7f45c6a5ba40 [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=629736805, session_epoch=681, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.452 7f45c6a5ba40 [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=629736805, session_epoch=681, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.453 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85193.404053, idle connection 262590.000000, request 304999.967098 01/05/2026 02:15:05.453 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 20 01/05/2026 02:15:05.453 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 01/05/2026 02:15:05.453 7f45c80605e0 [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)]) 01/05/2026 02:15:05.453 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.453 7f45c80605e0 [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=1460430259, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.453 7f45c80605e0 [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=1460430259, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.453 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83461.003174, idle connection 262093.000000, request 304999.969244 01/05/2026 02:15:05.453 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85192.563721, idle connection 262589.000000, request 304999.128819 01/05/2026 02:15:05.454 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83460.484863, idle connection 262092.000000, request 304999.453545 01/05/2026 02:15:05.528 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84829.392334, idle connection 262145.000000, request 304398.477793 01/05/2026 02:15:05.528 7f45c8ac67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 731 01/05/2026 02:15:05.528 7f45c8ac67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.528 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 731 (602.158784866333 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=343967102, topics=[]) 01/05/2026 02:15:05.528 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 343967102 with 0 response partitions (1 implied) 01/05/2026 02:15:05.552 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84576.501953, idle connection 262026.000000, request 304398.334503 01/05/2026 02:15:05.553 7f45c7109ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 685 01/05/2026 02:15:05.553 7f45c7109ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.553 7f45c7109ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 685 (602.3807525634766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1502574973, topics=[]) 01/05/2026 02:15:05.553 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1502574973 with 0 response partitions (1 implied) 01/05/2026 02:15:05.652 7f45c8ac65e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84372.448242, idle connection 262566.000000, request 304397.645712 01/05/2026 02:15:05.653 7f45c8ac65e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 728 01/05/2026 02:15:05.653 7f45c8ac65e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.653 7f45c8ac65e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 728 (602.9889583587646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1920914818, topics=[]) 01/05/2026 02:15:05.653 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1920914818 with 0 response partitions (1 implied) 01/05/2026 02:15:05.653 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 206 01/05/2026 02:15:05.653 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 01/05/2026 02:15:05.653 7f45c8060c20 [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)]) 01/05/2026 02:15:05.654 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.654 7f45c8060c20 [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=1104920570, session_epoch=720, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.654 7f45c8060c20 [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=1104920570, session_epoch=720, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.654 7f45c8060c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84687.928711, idle connection 262565.000000, request 304999.959707 01/05/2026 02:15:05.654 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 189 01/05/2026 02:15:05.654 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 01/05/2026 02:15:05.654 7f45c80600e0 [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)]) 01/05/2026 02:15:05.654 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.654 7f45c80600e0 [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=668211825, session_epoch=716, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.654 7f45c80600e0 [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=668211825, session_epoch=716, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.655 7f45c80600e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84464.559326, idle connection 261765.000000, request 304999.965906 01/05/2026 02:15:05.655 7f45c8ac6040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84187.033936, idle connection 262165.000000, request 304396.911383 01/05/2026 02:15:05.655 7f45c8060c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84686.763184, idle connection 262564.000000, request 304998.798847 01/05/2026 02:15:05.655 7f45c8ac6040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743 01/05/2026 02:15:05.655 7f45c8ac6040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.655 7f45c8ac6040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 743 (603.7993431091309 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462508730, topics=[]) 01/05/2026 02:15:05.656 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462508730 with 0 response partitions (1 implied) 01/05/2026 02:15:05.656 7f45c80600e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84463.196777, idle connection 261764.000000, request 304998.604774 01/05/2026 02:15:05.694 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 20 01/05/2026 02:15:05.694 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 01/05/2026 02:15:05.694 7f45c6b3cb80 [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)]) 01/05/2026 02:15:05.695 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.695 7f45c6b3cb80 [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=66696372, session_epoch=684, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.695 7f45c6b3cb80 [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=66696372, session_epoch=684, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.695 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84194.154785, idle connection 261807.000000, request 304999.932528 01/05/2026 02:15:05.696 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84193.632080, idle connection 261807.000000, request 304999.418020 01/05/2026 02:15:05.703 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84137.865967, idle connection 261801.000000, request 304399.167061 01/05/2026 02:15:05.703 7f45c8ac6360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 733 01/05/2026 02:15:05.703 7f45c8ac6360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.703 7f45c8ac6360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 733 (601.2649536132812 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1654912196, topics=[]) 01/05/2026 02:15:05.703 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1654912196 with 0 response partitions (1 implied) 01/05/2026 02:15:05.747 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84460.196045, idle connection 262173.000000, request 304398.974657 01/05/2026 02:15:05.748 7f45c6b3c4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 01/05/2026 02:15:05.748 7f45c6b3c4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.748 7f45c6b3c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.4947891235352 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=280741215, topics=[]) 01/05/2026 02:15:05.748 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 280741215 with 0 response partitions (1 implied) 01/05/2026 02:15:05.750 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83719.211182, idle connection 261160.000000, request 304397.796869 01/05/2026 02:15:05.751 7f45c6b1d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 01/05/2026 02:15:05.751 7f45c6b1d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.751 7f45c6b1d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 686 (602.7085781097412 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2034029383, topics=[]) 01/05/2026 02:15:05.751 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2034029383 with 0 response partitions (1 implied) 01/05/2026 02:15:05.754 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84540.044922, idle connection 262434.000000, request 304395.149708 01/05/2026 02:15:05.754 7f45c8ac6180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 698 01/05/2026 02:15:05.754 7f45c8ac6180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.754 7f45c8ac6180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 698 (605.241060256958 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1292325359, topics=[]) 01/05/2026 02:15:05.755 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1292325359 with 0 response partitions (1 implied) 01/05/2026 02:15:05.755 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84875.794189, idle connection 261688.000000, request 304395.080328 01/05/2026 02:15:05.755 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84290.207764, idle connection 262167.000000, request 304395.795584 01/05/2026 02:15:05.755 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84080.453857, idle connection 261822.000000, request 304396.267653 01/05/2026 02:15:05.755 7f45c8060d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 715 01/05/2026 02:15:05.755 7f45c8060d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.755 7f45c8060d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 715 (605.4322719573975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1021366735, topics=[]) 01/05/2026 02:15:05.755 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1021366735 with 0 response partitions (1 implied) 01/05/2026 02:15:05.756 7f45c8ac6720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 725 01/05/2026 02:15:05.756 7f45c8ac6720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.756 7f45c8ac6720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 725 (605.0724983215332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=183967424, topics=[]) 01/05/2026 02:15:05.756 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 183967424 with 0 response partitions (1 implied) 01/05/2026 02:15:05.756 7f45c8060ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 698 01/05/2026 02:15:05.756 7f45c8060ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:05.756 7f45c8060ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 698 (604.9556732177734 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=623893293, topics=[]) 01/05/2026 02:15:05.756 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 623893293 with 0 response partitions (1 implied) 01/05/2026 02:15:05.802 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 89 01/05/2026 02:15:05.802 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 01/05/2026 02:15:05.802 7f45c8060ae0 [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)]) 01/05/2026 02:15:05.802 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.802 7f45c8060ae0 [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=1715580312, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.802 7f45c8060ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 698 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1715580312, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.802 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84487.559570, idle connection 261778.000000, request 304999.936581 01/05/2026 02:15:05.803 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84487.131836, idle connection 261778.000000, request 304999.529123 01/05/2026 02:15:05.854 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 265 01/05/2026 02:15:05.854 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 01/05/2026 02:15:05.854 7f45c8ac64a0 [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)]) 01/05/2026 02:15:05.854 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.855 7f45c8ac64a0 [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=985321860, session_epoch=728, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.855 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 732 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=985321860, session_epoch=728, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.855 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84187.498291, idle connection 261752.000000, request 304999.951124 01/05/2026 02:15:05.855 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84187.013428, idle connection 261752.000000, request 304999.472618 01/05/2026 02:15:05.926 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 31 01/05/2026 02:15:05.926 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 01/05/2026 02:15:05.926 7f45c7129900 [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)]) 01/05/2026 02:15:05.926 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.926 7f45c7129900 [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=1070944470, session_epoch=689, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.927 7f45c7129900 [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=1070944470, session_epoch=689, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.927 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83827.172607, idle connection 261754.000000, request 304999.949217 01/05/2026 02:15:05.927 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83826.768311, idle connection 261753.000000, request 304999.552011 01/05/2026 02:15:05.986 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 78 01/05/2026 02:15:05.986 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 01/05/2026 02:15:05.986 7f45c8ac6ae0 [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)]) 01/05/2026 02:15:05.986 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.986 7f45c8ac6ae0 [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=1408973625, session_epoch=691, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.987 7f45c8ac6ae0 [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=1408973625, session_epoch=691, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.987 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83802.484131, idle connection 262390.000000, request 304999.945402 01/05/2026 02:15:05.987 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83802.069092, idle connection 262390.000000, request 304999.539137 01/05/2026 02:15:05.990 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 01/05/2026 02:15:05.990 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 01/05/2026 02:15:05.990 7f45c8060400 [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)]) 01/05/2026 02:15:05.990 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.990 7f45c8060400 [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=174895429, session_epoch=679, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.990 7f45c8060400 [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=174895429, session_epoch=679, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.991 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83846.615234, idle connection 261225.000000, request 304999.961615 01/05/2026 02:15:05.991 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 79 01/05/2026 02:15:05.991 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 01/05/2026 02:15:05.991 7f45c8060cc0 [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)]) 01/05/2026 02:15:05.991 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.991 7f45c8060cc0 [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=355757593, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.991 7f45c8060cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 698 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=355757593, session_epoch=694, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.991 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84035.257080, idle connection 261424.000000, request 304999.967575 01/05/2026 02:15:05.992 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83845.667725, idle connection 261224.000000, request 304999.018431 01/05/2026 02:15:05.992 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84034.682129, idle connection 261423.000000, request 304999.396563 01/05/2026 02:15:05.999 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 34 01/05/2026 02:15:05.999 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 01/05/2026 02:15:05.999 7f45c71295e0 [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)]) 01/05/2026 02:15:05.999 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:05.999 7f45c71295e0 [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=1111964764, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:05.999 7f45c71295e0 [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=1111964764, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.000 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83839.088379, idle connection 261226.000000, request 304999.959946 01/05/2026 02:15:06.000 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 01/05/2026 02:15:06.000 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 01/05/2026 02:15:06.000 7f45c8060220 [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)]) 01/05/2026 02:15:06.000 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.000 7f45c8060220 [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=474123149, session_epoch=684, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.000 7f45c8060220 [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=474123149, session_epoch=684, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.000 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83850.954834, idle connection 261782.000000, request 304999.967813 01/05/2026 02:15:06.000 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84242.933350, idle connection 261772.000000, request 304397.121906 01/05/2026 02:15:06.001 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83837.979004, idle connection 261225.000000, request 304998.855114 01/05/2026 02:15:06.001 7f45c80604a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 01/05/2026 02:15:06.001 7f45c80604a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.001 7f45c80604a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (603.5399436950684 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2058790469, topics=[]) 01/05/2026 02:15:06.001 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2058790469 with 0 response partitions (1 implied) 01/05/2026 02:15:06.002 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83849.539062, idle connection 261781.000000, request 304998.551369 01/05/2026 02:15:06.004 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83892.310547, idle connection 261796.000000, request 304399.309158 01/05/2026 02:15:06.004 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1034 01/05/2026 02:15:06.004 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.004 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1034 (601.1347770690918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=166654786, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3724, last_stable_offset=3724, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\x8b\x00\x00\x01\x04\x00\x00\x00\x00\x02k\xd7y\xc7\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...')])]) 01/05/2026 02:15:06.004 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 166654786 with 1 response partitions (0 implied) 01/05/2026 02:15:06.004 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3723 01/05/2026 02:15:06.005 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3723 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/05/2026 02:15:06.005 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3724 (leader epoch 0) 01/05/2026 02:15:06.029 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84404.761963, idle connection 261579.000000, request 304396.420479 01/05/2026 02:15:06.030 7f45c8ac6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 728 01/05/2026 02:15:06.030 7f45c8ac6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.030 7f45c8ac6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 728 (604.0847301483154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=696521521, topics=[]) 01/05/2026 02:15:06.030 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 696521521 with 0 response partitions (1 implied) 01/05/2026 02:15:06.049 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83269.332031, idle connection 261862.000000, request 304398.972511 01/05/2026 02:15:06.049 7f45c8034d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 01/05/2026 02:15:06.049 7f45c8034d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.049 7f45c8034d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 681 (601.4902591705322 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1340736141, topics=[]) 01/05/2026 02:15:06.049 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1340736141 with 0 response partitions (1 implied) 01/05/2026 02:15:06.051 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83268.969971, idle connection 261860.000000, request 304399.273157 01/05/2026 02:15:06.051 7f45c8034f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 01/05/2026 02:15:06.051 7f45c8034f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.051 7f45c8034f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 681 (601.0940074920654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=815321932, topics=[]) 01/05/2026 02:15:06.051 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 815321932 with 0 response partitions (1 implied) 01/05/2026 02:15:06.052 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83840.062988, idle connection 261065.000000, request 304399.382114 01/05/2026 02:15:06.052 7f45c716dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 01/05/2026 02:15:06.052 7f45c716dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.052 7f45c716dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (600.9528636932373 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1684080472, topics=[]) 01/05/2026 02:15:06.053 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1684080472 with 0 response partitions (1 implied) 01/05/2026 02:15:06.054 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84592.028320, idle connection 261989.000000, request 304398.588181 01/05/2026 02:15:06.054 7f45c6a5ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 685 01/05/2026 02:15:06.054 7f45c6a5ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.054 7f45c6a5ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 685 (601.7780303955078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=629736805, topics=[]) 01/05/2026 02:15:06.054 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 629736805 with 0 response partitions (1 implied) 01/05/2026 02:15:06.055 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82859.531250, idle connection 261491.000000, request 304398.496151 01/05/2026 02:15:06.055 7f45c80605e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 01/05/2026 02:15:06.055 7f45c80605e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.055 7f45c80605e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.787805557251 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1460430259, topics=[]) 01/05/2026 02:15:06.055 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1460430259 with 0 response partitions (1 implied) 01/05/2026 02:15:06.109 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3724 01/05/2026 02:15:06.109 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/05/2026 02:15:06.109 7f45c6a88900 [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)]) 01/05/2026 02:15:06.109 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.109 7f45c6a88900 [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=166654786, session_epoch=1031, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3724, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:06.109 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1035 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=166654786, session_epoch=1031, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3724, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 02:15:06.109 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83786.618652, idle connection 261691.000000, request 304999.947309 01/05/2026 02:15:06.110 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83786.103516, idle connection 261690.000000, request 304999.439716 01/05/2026 02:15:06.129 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 238 01/05/2026 02:15:06.129 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 01/05/2026 02:15:06.130 7f45c8ac67c0 [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)]) 01/05/2026 02:15:06.130 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.130 7f45c8ac67c0 [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=343967102, session_epoch=728, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.130 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 732 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=343967102, session_epoch=728, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.130 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84227.017578, idle connection 261543.000000, request 304999.950171 01/05/2026 02:15:06.131 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84226.432373, idle connection 261542.000000, request 304999.371529 01/05/2026 02:15:06.155 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 01/05/2026 02:15:06.155 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 01/05/2026 02:15:06.155 7f45c7109ea0 [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)]) 01/05/2026 02:15:06.155 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.155 7f45c7109ea0 [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=1502574973, session_epoch=682, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.155 7f45c7109ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1502574973, session_epoch=682, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.155 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83973.579590, idle connection 261423.000000, request 304999.951839 01/05/2026 02:15:06.156 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83973.084961, idle connection 261422.000000, request 304999.463081 01/05/2026 02:15:06.253 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 235 01/05/2026 02:15:06.254 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 01/05/2026 02:15:06.254 7f45c8ac65e0 [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)]) 01/05/2026 02:15:06.254 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.254 7f45c8ac65e0 [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=1920914818, session_epoch=725, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.254 7f45c8ac65e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 729 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1920914818, session_epoch=725, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.254 7f45c8ac65e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83770.516846, idle connection 261964.000000, request 304999.948740 01/05/2026 02:15:06.255 7f45c8ac65e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83770.065186, idle connection 261963.000000, request 304999.504328 01/05/2026 02:15:06.257 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 340 01/05/2026 02:15:06.257 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/05/2026 02:15:06.257 7f45c8ac6040 [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)]) 01/05/2026 02:15:06.257 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.257 7f45c8ac6040 [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=1462508730, session_epoch=740, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.257 7f45c8ac6040 [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=1462508730, session_epoch=740, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.257 7f45c8ac6040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83584.627686, idle connection 261563.000000, request 304999.961853 01/05/2026 02:15:06.257 7f45c8060c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84084.454590, idle connection 261962.000000, request 304396.489859 01/05/2026 02:15:06.258 7f45c8060c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 724 01/05/2026 02:15:06.258 7f45c8060c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.258 7f45c8060c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 724 (603.9094924926758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1104920570, topics=[]) 01/05/2026 02:15:06.258 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1104920570 with 0 response partitions (1 implied) 01/05/2026 02:15:06.258 7f45c80600e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83861.104004, idle connection 261162.000000, request 304396.511316 01/05/2026 02:15:06.258 7f45c8ac6040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83583.339600, idle connection 261562.000000, request 304998.673677 01/05/2026 02:15:06.259 7f45c80600e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 01/05/2026 02:15:06.259 7f45c80600e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.259 7f45c80600e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 720 (604.2826175689697 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=668211825, topics=[]) 01/05/2026 02:15:06.259 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 668211825 with 0 response partitions (1 implied) 01/05/2026 02:15:06.296 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83593.102539, idle connection 261206.000000, request 304398.884773 01/05/2026 02:15:06.296 7f45c6b3cb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 01/05/2026 02:15:06.296 7f45c6b3cb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.297 7f45c6b3cb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.6206741333008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=66696372, topics=[]) 01/05/2026 02:15:06.297 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 66696372 with 0 response partitions (1 implied) 01/05/2026 02:15:06.304 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 222 01/05/2026 02:15:06.304 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 01/05/2026 02:15:06.304 7f45c8ac6360 [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)]) 01/05/2026 02:15:06.304 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.304 7f45c8ac6360 [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=1654912196, session_epoch=730, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.304 7f45c8ac6360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 734 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1654912196, session_epoch=730, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.304 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83536.155518, idle connection 261199.000000, request 304999.953508 01/05/2026 02:15:06.305 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83535.739502, idle connection 261198.000000, request 304999.543667 01/05/2026 02:15:06.348 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 27 01/05/2026 02:15:06.349 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/05/2026 02:15:06.349 7f45c6b3c4a0 [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)]) 01/05/2026 02:15:06.349 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.349 7f45c6b3c4a0 [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=280741215, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.349 7f45c6b3c4a0 [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=280741215, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.349 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83858.496826, idle connection 261572.000000, request 304999.952078 01/05/2026 02:15:06.350 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83858.075928, idle connection 261571.000000, request 304999.538660 01/05/2026 02:15:06.351 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 20 01/05/2026 02:15:06.351 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 01/05/2026 02:15:06.351 7f45c6b1d0e0 [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)]) 01/05/2026 02:15:06.351 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.352 7f45c6b1d0e0 [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=2034029383, session_epoch=683, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.352 7f45c6b1d0e0 [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=2034029383, session_epoch=683, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.352 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83117.729736, idle connection 260559.000000, request 304999.962330 01/05/2026 02:15:06.352 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83117.408936, idle connection 260559.000000, request 304999.644518 01/05/2026 02:15:06.355 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 118 01/05/2026 02:15:06.355 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 01/05/2026 02:15:06.355 7f45c8ac6180 [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)]) 01/05/2026 02:15:06.355 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.355 7f45c8ac6180 [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=1292325359, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.355 7f45c8ac6180 [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=1292325359, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.356 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83938.491455, idle connection 261833.000000, request 304999.963999 01/05/2026 02:15:06.356 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 142 01/05/2026 02:15:06.356 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 01/05/2026 02:15:06.356 7f45c8060d60 [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)]) 01/05/2026 02:15:06.356 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.356 7f45c8060d60 [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=1021366735, session_epoch=712, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.356 7f45c8060d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 716 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1021366735, session_epoch=712, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.356 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84274.316162, idle connection 261086.000000, request 304999.965906 01/05/2026 02:15:06.357 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83937.568604, idle connection 261832.000000, request 304999.040365 01/05/2026 02:15:06.357 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 241 01/05/2026 02:15:06.357 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 01/05/2026 02:15:06.357 7f45c8ac6720 [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)]) 01/05/2026 02:15:06.357 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.357 7f45c8ac6720 [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=183967424, session_epoch=722, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.357 7f45c8ac6720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 726 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=183967424, session_epoch=722, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.357 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83687.931885, idle connection 261564.000000, request 304999.965429 01/05/2026 02:15:06.357 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 64 01/05/2026 02:15:06.357 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/05/2026 02:15:06.357 7f45c8060ea0 [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)]) 01/05/2026 02:15:06.357 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.358 7f45c8060ea0 [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=623893293, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.358 7f45c8060ea0 [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=623893293, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.358 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83477.714600, idle connection 261220.000000, request 304999.969006 01/05/2026 02:15:06.358 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84272.554443, idle connection 261085.000000, request 304998.203278 01/05/2026 02:15:06.358 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83686.635010, idle connection 261563.000000, request 304998.670816 01/05/2026 02:15:06.359 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83476.743164, idle connection 261219.000000, request 304998.999834 01/05/2026 02:15:06.403 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83886.687500, idle connection 261178.000000, request 304399.078846 01/05/2026 02:15:06.403 7f45c8060ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 698 01/05/2026 02:15:06.404 7f45c8060ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.404 7f45c8060ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 698 (601.3431549072266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1715580312, topics=[]) 01/05/2026 02:15:06.404 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1715580312 with 0 response partitions (1 implied) 01/05/2026 02:15:06.456 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83586.506592, idle connection 261151.000000, request 304398.959637 01/05/2026 02:15:06.456 7f45c8ac64a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 732 01/05/2026 02:15:06.456 7f45c8ac64a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.456 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 732 (601.54128074646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=985321860, topics=[]) 01/05/2026 02:15:06.456 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 985321860 with 0 response partitions (1 implied) 01/05/2026 02:15:06.528 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83226.286377, idle connection 261153.000000, request 304399.063349 01/05/2026 02:15:06.528 7f45c7129900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 01/05/2026 02:15:06.528 7f45c7129900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.528 7f45c7129900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (601.5586853027344 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1070944470, topics=[]) 01/05/2026 02:15:06.528 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1070944470 with 0 response partitions (1 implied) 01/05/2026 02:15:06.589 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83200.711426, idle connection 261788.000000, request 304398.173094 01/05/2026 02:15:06.589 7f45c8ac6ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 01/05/2026 02:15:06.589 7f45c8ac6ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.589 7f45c8ac6ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 695 (602.3080348968506 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1408973625, topics=[]) 01/05/2026 02:15:06.589 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1408973625 with 0 response partitions (1 implied) 01/05/2026 02:15:06.593 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83244.567871, idle connection 260623.000000, request 304397.915125 01/05/2026 02:15:06.593 7f45c8060400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 01/05/2026 02:15:06.593 7f45c8060400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.593 7f45c8060400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (602.3943424224854 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=174895429, topics=[]) 01/05/2026 02:15:06.593 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 174895429 with 0 response partitions (1 implied) 01/05/2026 02:15:06.593 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83433.240723, idle connection 260822.000000, request 304397.952795 01/05/2026 02:15:06.593 7f45c8060cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 698 01/05/2026 02:15:06.593 7f45c8060cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.594 7f45c8060cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 698 (602.3309230804443 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=355757593, topics=[]) 01/05/2026 02:15:06.594 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 355757593 with 0 response partitions (1 implied) 01/05/2026 02:15:06.602 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 44 01/05/2026 02:15:06.602 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 01/05/2026 02:15:06.602 7f45c80604a0 [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)]) 01/05/2026 02:15:06.602 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.602 7f45c80604a0 [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=2058790469, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.602 7f45c80604a0 [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=2058790469, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.603 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83640.690918, idle connection 261170.000000, request 304999.957323 01/05/2026 02:15:06.603 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83235.856445, idle connection 260623.000000, request 304396.730900 01/05/2026 02:15:06.603 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83248.223633, idle connection 261180.000000, request 304397.238731 01/05/2026 02:15:06.603 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83640.095215, idle connection 261169.000000, request 304999.366760 01/05/2026 02:15:06.603 7f45c71295e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 01/05/2026 02:15:06.603 7f45c71295e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.603 7f45c71295e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (603.9881706237793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1111964764, topics=[]) 01/05/2026 02:15:06.604 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1111964764 with 0 response partitions (1 implied) 01/05/2026 02:15:06.604 7f45c8060220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 01/05/2026 02:15:06.604 7f45c8060220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.604 7f45c8060220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (603.787899017334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=474123149, topics=[]) 01/05/2026 02:15:06.604 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 474123149 with 0 response partitions (1 implied) 01/05/2026 02:15:06.630 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 241 01/05/2026 02:15:06.630 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/05/2026 02:15:06.631 7f45c8ac6860 [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)]) 01/05/2026 02:15:06.631 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.631 7f45c8ac6860 [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=696521521, session_epoch=725, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.631 7f45c8ac6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 729 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=696521521, session_epoch=725, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.631 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83802.979492, idle connection 260977.000000, request 304999.951124 01/05/2026 02:15:06.631 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83802.589111, idle connection 260976.000000, request 304999.557734 01/05/2026 02:15:06.650 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 01/05/2026 02:15:06.650 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 01/05/2026 02:15:06.650 7f45c8034d60 [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)]) 01/05/2026 02:15:06.650 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.651 7f45c8034d60 [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=1340736141, session_epoch=678, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.651 7f45c8034d60 [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=1340736141, session_epoch=678, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.651 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82667.106934, idle connection 261260.000000, request 304999.954462 01/05/2026 02:15:06.651 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82666.738037, idle connection 261259.000000, request 304999.591827 01/05/2026 02:15:06.652 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/05/2026 02:15:06.652 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 01/05/2026 02:15:06.652 7f45c8034f40 [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)]) 01/05/2026 02:15:06.652 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.653 7f45c8034f40 [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=815321932, session_epoch=678, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.653 7f45c8034f40 [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=815321932, session_epoch=678, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.653 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82666.863525, idle connection 261258.000000, request 304999.965191 01/05/2026 02:15:06.653 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82666.583740, idle connection 261258.000000, request 304999.688148 01/05/2026 02:15:06.653 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 01/05/2026 02:15:06.653 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 01/05/2026 02:15:06.654 7f45c716dea0 [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)]) 01/05/2026 02:15:06.654 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.654 7f45c716dea0 [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=1684080472, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.654 7f45c716dea0 [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=1684080472, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.654 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83238.307617, idle connection 260463.000000, request 304999.969006 01/05/2026 02:15:06.654 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83238.050049, idle connection 260463.000000, request 304999.713182 01/05/2026 02:15:06.656 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 01/05/2026 02:15:06.656 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 01/05/2026 02:15:06.656 7f45c6a5ba40 [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)]) 01/05/2026 02:15:06.656 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.656 7f45c6a5ba40 [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=629736805, session_epoch=682, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.656 7f45c6a5ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=629736805, session_epoch=682, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.656 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83989.940674, idle connection 261387.000000, request 304999.966621 01/05/2026 02:15:06.656 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 20 01/05/2026 02:15:06.656 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 01/05/2026 02:15:06.656 7f45c80605e0 [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)]) 01/05/2026 02:15:06.656 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.656 7f45c80605e0 [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=1460430259, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.657 7f45c80605e0 [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=1460430259, session_epoch=686, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.657 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82257.538330, idle connection 260889.000000, request 304999.969006 01/05/2026 02:15:06.657 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83989.100830, idle connection 261386.000000, request 304999.129295 01/05/2026 02:15:06.657 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82257.022949, idle connection 260889.000000, request 304999.456167 01/05/2026 02:15:06.710 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83185.685059, idle connection 261090.000000, request 304399.004459 01/05/2026 02:15:06.711 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1035 01/05/2026 02:15:06.711 7f45c6a88900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.711 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1035 (601.489782333374 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=166654786, topics=[]) 01/05/2026 02:15:06.711 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 166654786 with 0 response partitions (1 implied) 01/05/2026 02:15:06.731 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83625.970459, idle connection 260942.000000, request 304398.903131 01/05/2026 02:15:06.731 7f45c8ac67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 732 01/05/2026 02:15:06.731 7f45c8ac67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.732 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 732 (601.5851497650146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=343967102, topics=[]) 01/05/2026 02:15:06.732 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 343967102 with 0 response partitions (1 implied) 01/05/2026 02:15:06.756 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83372.623535, idle connection 260822.000000, request 304398.991823 01/05/2026 02:15:06.757 7f45c7109ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 01/05/2026 02:15:06.757 7f45c7109ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.757 7f45c7109ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 686 (601.6201972961426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1502574973, topics=[]) 01/05/2026 02:15:06.757 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1502574973 with 0 response partitions (1 implied) 01/05/2026 02:15:06.855 7f45c8ac65e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83169.609131, idle connection 261363.000000, request 304399.039745 01/05/2026 02:15:06.856 7f45c8ac65e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 729 01/05/2026 02:15:06.856 7f45c8ac65e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.856 7f45c8ac65e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 729 (601.5596389770508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1920914818, topics=[]) 01/05/2026 02:15:06.856 7f45c8ac65e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1920914818 with 0 response partitions (1 implied) 01/05/2026 02:15:06.858 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 206 01/05/2026 02:15:06.859 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 01/05/2026 02:15:06.859 7f45c8060c20 [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)]) 01/05/2026 02:15:06.859 7f45c8060c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.859 7f45c8060c20 [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=1104920570, session_epoch=721, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.859 7f45c8060c20 [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=1104920570, session_epoch=721, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.859 7f45c8060c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83482.743896, idle connection 261360.000000, request 304999.956369 01/05/2026 02:15:06.859 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 189 01/05/2026 02:15:06.859 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 01/05/2026 02:15:06.859 7f45c80600e0 [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)]) 01/05/2026 02:15:06.859 7f45c80600e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.859 7f45c80600e0 [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=668211825, session_epoch=717, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.860 7f45c80600e0 [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=668211825, session_epoch=717, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.860 7f45c80600e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83259.455566, idle connection 260560.000000, request 304999.965429 01/05/2026 02:15:06.860 7f45c8060c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83481.704590, idle connection 261359.000000, request 304998.921633 01/05/2026 02:15:06.860 7f45c8ac6040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82981.507812, idle connection 260960.000000, request 304396.843910 01/05/2026 02:15:06.861 7f45c80600e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83258.621826, idle connection 260559.000000, request 304999.135494 01/05/2026 02:15:06.861 7f45c8ac6040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 744 01/05/2026 02:15:06.861 7f45c8ac6040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.861 7f45c8ac6040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 744 (603.7933826446533 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462508730, topics=[]) 01/05/2026 02:15:06.861 7f45c8ac6040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462508730 with 0 response partitions (1 implied) 01/05/2026 02:15:06.897 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 20 01/05/2026 02:15:06.897 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 01/05/2026 02:15:06.897 7f45c6b3cb80 [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)]) 01/05/2026 02:15:06.897 7f45c6b3cb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:06.898 7f45c6b3cb80 [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=66696372, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.898 7f45c6b3cb80 [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=66696372, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:06.898 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82991.356445, idle connection 260604.000000, request 304999.950171 01/05/2026 02:15:06.898 7f45c6b3cb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82990.960205, idle connection 260604.000000, request 304999.560595 01/05/2026 02:15:06.905 7f45c8ac6360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82935.367676, idle connection 260598.000000, request 304399.169207 01/05/2026 02:15:06.905 7f45c8ac6360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 734 01/05/2026 02:15:06.905 7f45c8ac6360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.906 7f45c8ac6360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 734 (601.2976169586182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1654912196, topics=[]) 01/05/2026 02:15:06.906 7f45c8ac6360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1654912196 with 0 response partitions (1 implied) 01/05/2026 02:15:06.950 7f45c6b3c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83257.603516, idle connection 260971.000000, request 304399.058580 01/05/2026 02:15:06.950 7f45c6b3c4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 01/05/2026 02:15:06.951 7f45c6b3c4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.951 7f45c6b3c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (601.5350818634033 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=280741215, topics=[]) 01/05/2026 02:15:06.951 7f45c6b3c4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 280741215 with 0 response partitions (1 implied) 01/05/2026 02:15:06.952 7f45c6b1d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82517.020996, idle connection 259958.000000, request 304399.250269 01/05/2026 02:15:06.953 7f45c6b1d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 01/05/2026 02:15:06.953 7f45c6b1d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.953 7f45c6b1d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (601.1686325073242 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2034029383, topics=[]) 01/05/2026 02:15:06.953 7f45c6b1d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2034029383 with 0 response partitions (1 implied) 01/05/2026 02:15:06.958 7f45c8ac6180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83335.736816, idle connection 261230.000000, request 304397.207737 01/05/2026 02:15:06.959 7f45c8ac6180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 699 01/05/2026 02:15:06.959 7f45c8ac6180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.959 7f45c8ac6180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 699 (603.1332015991211 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1292325359, topics=[]) 01/05/2026 02:15:06.959 7f45c8ac6180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1292325359 with 0 response partitions (1 implied) 01/05/2026 02:15:06.959 7f45c8060d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83671.552490, idle connection 260484.000000, request 304397.203445 01/05/2026 02:15:06.959 7f45c8ac6720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83085.970947, idle connection 260963.000000, request 304398.006439 01/05/2026 02:15:06.959 7f45c8060d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 716 01/05/2026 02:15:06.959 7f45c8060d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.960 7f45c8060d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 716 (603.2898426055908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1021366735, topics=[]) 01/05/2026 02:15:06.960 7f45c8060d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1021366735 with 0 response partitions (1 implied) 01/05/2026 02:15:06.960 7f45c8ac6720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 726 01/05/2026 02:15:06.960 7f45c8ac6720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.960 7f45c8ac6720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 726 (602.8034687042236 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=183967424, topics=[]) 01/05/2026 02:15:06.960 7f45c8ac6720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 183967424 with 0 response partitions (1 implied) 01/05/2026 02:15:06.960 7f45c8060ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82875.245361, idle connection 260617.000000, request 304397.499800 01/05/2026 02:15:06.960 7f45c8060ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 699 01/05/2026 02:15:06.960 7f45c8060ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:06.960 7f45c8060ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 699 (602.7753353118896 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=623893293, topics=[]) 01/05/2026 02:15:06.961 7f45c8060ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 623893293 with 0 response partitions (1 implied) 01/05/2026 02:15:07.004 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 89 01/05/2026 02:15:07.005 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 01/05/2026 02:15:07.005 7f45c8060ae0 [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)]) 01/05/2026 02:15:07.005 7f45c8060ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.005 7f45c8060ae0 [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=1715580312, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.005 7f45c8060ae0 [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=1715580312, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.005 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83284.683105, idle connection 260576.000000, request 304999.943495 01/05/2026 02:15:07.006 7f45c8060ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83284.239746, idle connection 260575.000000, request 304999.507904 01/05/2026 02:15:07.058 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 265 01/05/2026 02:15:07.058 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 01/05/2026 02:15:07.058 7f45c8ac64a0 [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)]) 01/05/2026 02:15:07.058 7f45c8ac64a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.058 7f45c8ac64a0 [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=985321860, session_epoch=729, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.058 7f45c8ac64a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 733 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=985321860, session_epoch=729, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.058 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82983.923828, idle connection 260549.000000, request 304999.936819 01/05/2026 02:15:07.059 7f45c8ac64a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82983.516846, idle connection 260548.000000, request 304999.536753 01/05/2026 02:15:07.129 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 31 01/05/2026 02:15:07.129 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 01/05/2026 02:15:07.129 7f45c7129900 [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)]) 01/05/2026 02:15:07.129 7f45c7129900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.129 7f45c7129900 [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=1070944470, session_epoch=690, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.129 7f45c7129900 [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=1070944470, session_epoch=690, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.130 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82624.227051, idle connection 260551.000000, request 304999.947786 01/05/2026 02:15:07.130 7f45c7129900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82623.820068, idle connection 260550.000000, request 304999.549150 01/05/2026 02:15:07.190 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 78 01/05/2026 02:15:07.190 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 01/05/2026 02:15:07.190 7f45c8ac6ae0 [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)]) 01/05/2026 02:15:07.190 7f45c8ac6ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.190 7f45c8ac6ae0 [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=1408973625, session_epoch=692, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.190 7f45c8ac6ae0 [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=1408973625, session_epoch=692, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.190 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82598.988525, idle connection 261187.000000, request 304999.914169 01/05/2026 02:15:07.191 7f45c8ac6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82598.496582, idle connection 261186.000000, request 304999.466658 01/05/2026 02:15:07.193 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 01/05/2026 02:15:07.193 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 01/05/2026 02:15:07.193 7f45c8060400 [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)]) 01/05/2026 02:15:07.194 7f45c8060400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.194 7f45c8060400 [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=174895429, session_epoch=680, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.194 7f45c8060400 [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=174895429, session_epoch=680, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.194 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82643.312744, idle connection 260022.000000, request 304999.963522 01/05/2026 02:15:07.194 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 79 01/05/2026 02:15:07.194 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 01/05/2026 02:15:07.194 7f45c8060cc0 [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)]) 01/05/2026 02:15:07.194 7f45c8060cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.194 7f45c8060cc0 [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=355757593, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.194 7f45c8060cc0 [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=355757593, session_epoch=695, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.195 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82831.900391, idle connection 260220.000000, request 304999.962091 01/05/2026 02:15:07.195 7f45c8060400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82642.296631, idle connection 260021.000000, request 304998.950005 01/05/2026 02:15:07.195 7f45c8060cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82831.081299, idle connection 260219.000000, request 304999.146461 01/05/2026 02:15:07.204 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 34 01/05/2026 02:15:07.204 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 01/05/2026 02:15:07.204 7f45c71295e0 [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)]) 01/05/2026 02:15:07.204 7f45c71295e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.204 7f45c71295e0 [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=1111964764, session_epoch=687, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.204 7f45c71295e0 [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=1111964764, session_epoch=687, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.204 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82634.183350, idle connection 260021.000000, request 304999.960184 01/05/2026 02:15:07.205 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 01/05/2026 02:15:07.205 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 01/05/2026 02:15:07.205 7f45c8060220 [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)]) 01/05/2026 02:15:07.205 7f45c8060220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.205 7f45c8060220 [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=474123149, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.205 7f45c8060220 [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=474123149, session_epoch=685, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.205 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82646.049561, idle connection 260578.000000, request 304999.967337 01/05/2026 02:15:07.205 7f45c80604a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83038.026855, idle connection 260567.000000, request 304397.297144 01/05/2026 02:15:07.206 7f45c71295e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82633.111084, idle connection 260020.000000, request 304998.891830 01/05/2026 02:15:07.206 7f45c80604a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 01/05/2026 02:15:07.206 7f45c80604a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.206 7f45c80604a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (603.3451557159424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2058790469, topics=[]) 01/05/2026 02:15:07.206 7f45c80604a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2058790469 with 0 response partitions (1 implied) 01/05/2026 02:15:07.206 7f45c8060220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82644.804199, idle connection 260576.000000, request 304998.724222 01/05/2026 02:15:07.232 7f45c8ac6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83201.919678, idle connection 260376.000000, request 304398.891926 01/05/2026 02:15:07.232 7f45c8ac6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 729 01/05/2026 02:15:07.233 7f45c8ac6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.233 7f45c8ac6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 729 (601.707935333252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=696521521, topics=[]) 01/05/2026 02:15:07.233 7f45c8ac6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 696521521 with 0 response partitions (1 implied) 01/05/2026 02:15:07.252 7f45c8034d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82066.313965, idle connection 260659.000000, request 304399.159908 01/05/2026 02:15:07.252 7f45c8034d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 01/05/2026 02:15:07.252 7f45c8034d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.252 7f45c8034d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (601.3796329498291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1340736141, topics=[]) 01/05/2026 02:15:07.252 7f45c8034d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1340736141 with 0 response partitions (1 implied) 01/05/2026 02:15:07.253 7f45c8034f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82066.330322, idle connection 260658.000000, request 304399.431705 01/05/2026 02:15:07.254 7f45c8034f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 01/05/2026 02:15:07.254 7f45c8034f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.254 7f45c8034f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (601.041316986084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=815321932, topics=[]) 01/05/2026 02:15:07.254 7f45c8034f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 815321932 with 0 response partitions (1 implied) 01/05/2026 02:15:07.254 7f45c716dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82637.801514, idle connection 259863.000000, request 304399.451971 01/05/2026 02:15:07.255 7f45c716dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 01/05/2026 02:15:07.255 7f45c716dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.255 7f45c716dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (600.8305549621582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1684080472, topics=[]) 01/05/2026 02:15:07.255 7f45c716dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1684080472 with 0 response partitions (1 implied) 01/05/2026 02:15:07.257 7f45c6a5ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83388.589355, idle connection 260785.000000, request 304398.615599 01/05/2026 02:15:07.258 7f45c6a5ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 01/05/2026 02:15:07.258 7f45c6a5ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.258 7f45c6a5ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 686 (601.6638278961182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=629736805, topics=[]) 01/05/2026 02:15:07.258 7f45c6a5ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 629736805 with 0 response partitions (1 implied) 01/05/2026 02:15:07.258 7f45c80605e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81656.214355, idle connection 260288.000000, request 304398.645639 01/05/2026 02:15:07.258 7f45c80605e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 01/05/2026 02:15:07.258 7f45c80605e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 02:15:07.258 7f45c80605e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (601.6268730163574 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1460430259, topics=[]) 01/05/2026 02:15:07.258 7f45c80605e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1460430259 with 0 response partitions (1 implied) 01/05/2026 02:15:07.311 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3724 01/05/2026 02:15:07.311 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/05/2026 02:15:07.312 7f45c6a88900 [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)]) 01/05/2026 02:15:07.312 7f45c6a88900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.312 7f45c6a88900 [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=166654786, session_epoch=1032, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.312 7f45c6a88900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1036 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=166654786, session_epoch=1032, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.312 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82583.836182, idle connection 260488.000000, request 304999.926805 01/05/2026 02:15:07.313 7f45c6a88900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82583.284668, idle connection 260487.000000, request 304999.388695 01/05/2026 02:15:07.332 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 238 01/05/2026 02:15:07.332 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 01/05/2026 02:15:07.332 7f45c8ac67c0 [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)]) 01/05/2026 02:15:07.332 7f45c8ac67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.333 7f45c8ac67c0 [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=343967102, session_epoch=729, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.333 7f45c8ac67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 733 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=343967102, session_epoch=729, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.333 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83024.126709, idle connection 260340.000000, request 304999.943972 01/05/2026 02:15:07.333 7f45c8ac67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83023.600342, idle connection 260339.000000, request 304999.421358 01/05/2026 02:15:07.357 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 01/05/2026 02:15:07.358 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 01/05/2026 02:15:07.358 7f45c7109ea0 [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)]) 01/05/2026 02:15:07.358 7f45c7109ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 02:15:07.358 7f45c7109ea0 [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=1502574973, session_epoch=683, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.358 7f45c7109ea0 [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=1502574973, session_epoch=683, topics=[], forgotten_topics_data=[]) 01/05/2026 02:15:07.358 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82770.828857, idle connection 260220.000000, request 304999.952078 01/05/2026 02:15:07.359 7f45c7109ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82770.346680, idle connection 260220.000000, request 304999.477148