05/25/2026 02:14:15.802 7f8d2aebdae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1342488165, session_epoch=728, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.803 7f8d2aebdae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86896.389893, idle connection 263934.000000, request 304999.933243
05/25/2026 02:14:15.804 7f8d2aebdae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86895.901611, idle connection 263933.000000, request 304999.453545
05/25/2026 02:14:15.825 7f8d2b7b8360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85430.659424, idle connection 263585.000000, request 304399.035454
05/25/2026 02:14:15.826 7f8d2b7b8360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720
05/25/2026 02:14:15.826 7f8d2b7b8360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:15.826 7f8d2b7b8360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 720 (601.5076637268066 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=784650634, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=187, last_stable_offset=187, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xba\x00\x00\x00\xf7\x00\x00\x00\x00\x02\xfa\xf2\xb3K\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\x88\x03\x00\x00\x00\xca\x02ObjectVRouter:cn-jenkins-deploy-...')])])
05/25/2026 02:14:15.826 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 784650634 with 1 response partitions (0 implied)
05/25/2026 02:14:15.826 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 259 bytes of data for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 186
05/25/2026 02:14:15.826 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 186 for assigned partition TopicPartition(topic='-uve-topic-2', partition=0)
05/25/2026 02:14:15.827 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) to 187 (leader epoch 0)
05/25/2026 02:14:15.845 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 314
05/25/2026 02:14:15.846 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
05/25/2026 02:14:15.846 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293f3b80> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
05/25/2026 02:14:15.846 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.846 7f8d2aebd4a0 [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=991613665, session_epoch=732, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.846 7f8d2aebd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 736 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=991613665, session_epoch=732, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.846 7f8d2aebd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86723.802734, idle connection 263741.000000, request 304999.945164
05/25/2026 02:14:15.847 7f8d2aebd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86723.364746, idle connection 263741.000000, request 304999.514580
05/25/2026 02:14:15.863 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3769
05/25/2026 02:14:15.863 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
05/25/2026 02:14:15.863 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e4a00> 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)])
05/25/2026 02:14:15.863 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.863 7f8d29024680 [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=59175018, session_epoch=1008, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3769, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:15.863 7f8d29024680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 1012 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=59175018, session_epoch=1008, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3769, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:15.863 7f8d29024680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86454.644531, idle connection 263500.000000, request 304999.952316
05/25/2026 02:14:15.864 7f8d29024680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86454.260986, idle connection 263499.000000, request 304999.574184
05/25/2026 02:14:15.882 7f8d2a628400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87118.322021, idle connection 263472.000000, request 304399.059534
05/25/2026 02:14:15.882 7f8d2a628400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693
05/25/2026 02:14:15.882 7f8d2a628400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:15.882 7f8d2a628400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 693 (601.4361381530762 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1571174740, topics=[])
05/25/2026 02:14:15.882 7f8d2a628400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1571174740 with 0 response partitions (1 implied)
05/25/2026 02:14:15.884 7f8d290c4e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
05/25/2026 02:14:15.884 7f8d290c4e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
05/25/2026 02:14:15.884 7f8d290c4e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e6730> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
05/25/2026 02:14:15.884 7f8d290c4e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.884 7f8d290c4e00 [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=428815477, session_epoch=676, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.885 7f8d290c4e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=428815477, session_epoch=676, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.885 7f8d290c4e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85105.422363, idle connection 263746.000000, request 304999.955416
05/25/2026 02:14:15.885 7f8d290c4e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85105.021729, idle connection 263746.000000, request 304999.557972
05/25/2026 02:14:15.885 7f8d28e9fd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 33
05/25/2026 02:14:15.885 7f8d28e9fd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
05/25/2026 02:14:15.885 7f8d28e9fd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293f3dc0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
05/25/2026 02:14:15.885 7f8d28e9fd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.886 7f8d28e9fd60 [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=514561681, session_epoch=687, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.886 7f8d28e9fd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=514561681, session_epoch=687, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.886 7f8d28e9fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86334.603271, idle connection 263746.000000, request 304999.958992
05/25/2026 02:14:15.886 7f8d2aebd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 24
05/25/2026 02:14:15.886 7f8d2aebd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
05/25/2026 02:14:15.886 7f8d2aebd040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d2975e2e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
05/25/2026 02:14:15.886 7f8d2aebd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.886 7f8d2aebd040 [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=1045580783, session_epoch=680, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.886 7f8d2aebd040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1045580783, session_epoch=680, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.886 7f8d2aebd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85931.576904, idle connection 263367.000000, request 304999.966860
05/25/2026 02:14:15.887 7f8d2b7b8720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 37
05/25/2026 02:14:15.887 7f8d2b7b8720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
05/25/2026 02:14:15.887 7f8d2b7b8720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293ef280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
05/25/2026 02:14:15.887 7f8d2b7b8720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.887 7f8d2b7b8720 [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=1702416795, session_epoch=685, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.887 7f8d2b7b8720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1702416795, session_epoch=685, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.887 7f8d2b7b8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86394.869385, idle connection 264035.000000, request 304999.966383
05/25/2026 02:14:15.887 7f8d28e9fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86333.016113, idle connection 263745.000000, request 304998.373747
05/25/2026 02:14:15.888 7f8d2aebd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85930.439941, idle connection 263366.000000, request 304998.831749
05/25/2026 02:14:15.888 7f8d2b7b8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86394.080322, idle connection 264034.000000, request 304999.179602
05/25/2026 02:14:15.898 7f8d2aebd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85597.575684, idle connection 263519.000000, request 304399.170160
05/25/2026 02:14:15.898 7f8d2aebd9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 718
05/25/2026 02:14:15.898 7f8d2aebd9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:15.898 7f8d2aebd9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 718 (601.2837886810303 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1148682961, topics=[])
05/25/2026 02:14:15.899 7f8d2aebd9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1148682961 with 0 response partitions (1 implied)
05/25/2026 02:14:15.905 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 261
05/25/2026 02:14:15.905 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
05/25/2026 02:14:15.905 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe040> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
05/25/2026 02:14:15.905 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.906 7f8d2aebd860 [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=1748052302, session_epoch=735, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.906 7f8d2aebd860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 739 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1748052302, session_epoch=735, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.906 7f8d2aebd860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86176.560547, idle connection 263817.000000, request 304999.948978
05/25/2026 02:14:15.906 7f8d2b7b8d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 84
05/25/2026 02:14:15.906 7f8d2b7b8d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
05/25/2026 02:14:15.906 7f8d2b7b8d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293f3730> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
05/25/2026 02:14:15.906 7f8d2b7b8d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.906 7f8d2b7b8d60 [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=913316371, session_epoch=698, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.906 7f8d2b7b8d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 702 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=913316371, session_epoch=698, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.907 7f8d2b7b8d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86160.568115, idle connection 263634.000000, request 304999.962330
05/25/2026 02:14:15.907 7f8d2aebd860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86175.516846, idle connection 263816.000000, request 304998.912811
05/25/2026 02:14:15.907 7f8d2b7b8d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86159.962402, idle connection 263633.000000, request 304999.360323
05/25/2026 02:14:15.927 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 187
05/25/2026 02:14:15.927 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
05/25/2026 02:14:15.927 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe970> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-2', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
05/25/2026 02:14:15.928 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.928 7f8d2b7b8360 [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=784650634, session_epoch=717, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=187, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:15.928 7f8d2b7b8360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=784650634, session_epoch=717, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=187, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:15.928 7f8d2b7b8360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85328.103271, idle connection 263482.000000, request 304999.932766
05/25/2026 02:14:15.928 7f8d2b7b8360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85327.654541, idle connection 263482.000000, request 304999.493122
05/25/2026 02:14:15.946 7f8d2b7b8cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85775.211426, idle connection 263530.000000, request 304399.017096
05/25/2026 02:14:15.946 7f8d2b7b8cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688
05/25/2026 02:14:15.946 7f8d2b7b8cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:15.946 7f8d2b7b8cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 688 (601.4547348022461 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=790185305, topics=[])
05/25/2026 02:14:15.946 7f8d2b7b8cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 790185305 with 0 response partitions (1 implied)
05/25/2026 02:14:15.959 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 194
05/25/2026 02:14:15.959 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
05/25/2026 02:14:15.959 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e6b20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
05/25/2026 02:14:15.959 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:15.959 7f8d2aebd720 [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=38729996, session_epoch=702, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.959 7f8d2aebd720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 706 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=38729996, session_epoch=702, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:15.960 7f8d2aebd720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86607.856934, idle connection 263777.000000, request 304999.947786
05/25/2026 02:14:15.960 7f8d2b7b8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86444.639404, idle connection 264190.000000, request 304397.541523
05/25/2026 02:14:15.960 7f8d2aebd720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86607.273682, idle connection 263776.000000, request 304999.372721
05/25/2026 02:14:15.960 7f8d2b7b8900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692
05/25/2026 02:14:15.960 7f8d2b7b8900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:15.961 7f8d2b7b8900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 692 (603.1692028045654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2082826192, topics=[])
05/25/2026 02:14:15.961 7f8d2b7b8900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2082826192 with 0 response partitions (1 implied)
05/25/2026 02:14:15.961 7f8d2aebd720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 706
05/25/2026 02:14:15.961 7f8d2aebd720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:15.961 7f8d2aebd720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 706 (1.5871524810791016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=38729996, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=196, last_stable_offset=196, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xc2\x00\x00\x01\xd8\x00\x00\x00\x00\x02_e\x80\x7f\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\xa6\x03\x00\x00\x00\xe8\x02ObjectXmppPeerInfo:cn-jenkins-de...')])])
05/25/2026 02:14:15.961 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 38729996 with 1 response partitions (0 implied)
05/25/2026 02:14:15.961 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 484 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 194
05/25/2026 02:14:15.962 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 194 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0)
05/25/2026 02:14:15.962 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 196 (leader epoch 0)
05/25/2026 02:14:16.003 7f8d2aebd2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 200
05/25/2026 02:14:16.003 7f8d2aebd2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
05/25/2026 02:14:16.003 7f8d2aebd2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293f39d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
05/25/2026 02:14:16.003 7f8d2aebd2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.004 7f8d2aebd2c0 [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=1349939775, session_epoch=717, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.004 7f8d2aebd2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1349939775, session_epoch=717, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.004 7f8d2aebd2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86596.230469, idle connection 263205.000000, request 304999.943495
05/25/2026 02:14:16.004 7f8d2aebd2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86595.748291, idle connection 263205.000000, request 304999.468565
05/25/2026 02:14:16.017 7f8d2aebd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86827.218018, idle connection 264228.000000, request 304399.097443
05/25/2026 02:14:16.018 7f8d2aebd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 725
05/25/2026 02:14:16.018 7f8d2aebd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.018 7f8d2aebd220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 725 (601.5152931213379 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1269635716, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=237, last_stable_offset=237, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xeb\x00\x00\x02\x11\x00\x00\x00\x00\x024\xf8v\xd5\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xdc\x03\x00\x00\x00\x9e\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
05/25/2026 02:14:16.018 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1269635716 with 1 response partitions (0 implied)
05/25/2026 02:14:16.018 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 541 bytes of data for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 235
05/25/2026 02:14:16.018 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 235 for assigned partition TopicPartition(topic='-uve-topic-20', partition=0)
05/25/2026 02:14:16.019 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) to 237 (leader epoch 0)
05/25/2026 02:14:16.033 7f8d2b7b8f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 21
05/25/2026 02:14:16.033 7f8d2b7b8f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
05/25/2026 02:14:16.033 7f8d2b7b8f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e6670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
05/25/2026 02:14:16.033 7f8d2b7b8f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.033 7f8d2b7b8f40 [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=430489968, session_epoch=683, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.033 7f8d2b7b8f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=430489968, session_epoch=683, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.033 7f8d2b7b8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85224.306152, idle connection 263817.000000, request 304999.944687
05/25/2026 02:14:16.034 7f8d2b7b8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85223.879395, idle connection 263816.000000, request 304999.525070
05/25/2026 02:14:16.063 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 196
05/25/2026 02:14:16.063 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
05/25/2026 02:14:16.063 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293feb50> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
05/25/2026 02:14:16.063 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.063 7f8d2aebd720 [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=38729996, session_epoch=703, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=196, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.063 7f8d2aebd720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 707 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=38729996, session_epoch=703, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=196, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.063 7f8d2aebd720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86504.161865, idle connection 263673.000000, request 304999.944210
05/25/2026 02:14:16.064 7f8d2aebd720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86503.697998, idle connection 263673.000000, request 304999.487877
05/25/2026 02:14:16.119 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 237
05/25/2026 02:14:16.119 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
05/25/2026 02:14:16.120 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e6df0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-20', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
05/25/2026 02:14:16.120 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.120 7f8d2aebd220 [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=1269635716, session_epoch=722, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=237, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.120 7f8d2aebd220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1269635716, session_epoch=722, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=237, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.120 7f8d2aebd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86724.045166, idle connection 264125.000000, request 304999.923229
05/25/2026 02:14:16.121 7f8d2aebd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86723.435547, idle connection 264124.000000, request 304999.324322
05/25/2026 02:14:16.141 7f8d2c3ee180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86431.528076, idle connection 263491.000000, request 304398.964882
05/25/2026 02:14:16.141 7f8d2c3ee180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684
05/25/2026 02:14:16.141 7f8d2c3ee180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.141 7f8d2c3ee180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 684 (601.5989780426025 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=209320144, topics=[])
05/25/2026 02:14:16.141 7f8d2c3ee180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 209320144 with 0 response partitions (1 implied)
05/25/2026 02:14:16.144 7f8d28e9fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85537.630859, idle connection 263847.000000, request 304399.283886
05/25/2026 02:14:16.144 7f8d28e9fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683
05/25/2026 02:14:16.144 7f8d28e9fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.144 7f8d28e9fc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 683 (601.081132888794 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=548789102, topics=[])
05/25/2026 02:14:16.145 7f8d28e9fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 548789102 with 0 response partitions (1 implied)
05/25/2026 02:14:16.148 7f8d2b7b89a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 85
05/25/2026 02:14:16.148 7f8d2b7b89a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
05/25/2026 02:14:16.148 7f8d2b7b89a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d29853760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
05/25/2026 02:14:16.148 7f8d2b7b89a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.148 7f8d2b7b89a0 [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=1257883594, session_epoch=691, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.148 7f8d2b7b89a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1257883594, session_epoch=691, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.148 7f8d2b7b89a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85901.865234, idle connection 263345.000000, request 304999.954224
05/25/2026 02:14:16.149 7f8d2b7b89a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85901.456543, idle connection 263344.000000, request 304999.549150
05/25/2026 02:14:16.149 7f8d2c3ee400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85139.373779, idle connection 263748.000000, request 304399.168968
05/25/2026 02:14:16.149 7f8d2c3ee400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682
05/25/2026 02:14:16.149 7f8d2c3ee400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.149 7f8d2c3ee400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 682 (601.2451648712158 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1837599653, topics=[])
05/25/2026 02:14:16.149 7f8d2c3ee400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1837599653 with 0 response partitions (1 implied)
05/25/2026 02:14:16.154 7f8d2a628b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
05/25/2026 02:14:16.154 7f8d2a628b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
05/25/2026 02:14:16.154 7f8d2a628b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293efe20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
05/25/2026 02:14:16.154 7f8d2a628b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.154 7f8d2a628b80 [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=1307782535, session_epoch=676, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.154 7f8d2a628b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307782535, session_epoch=676, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.154 7f8d2a628b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85208.788818, idle connection 263743.000000, request 304999.954700
05/25/2026 02:14:16.155 7f8d2a628b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85208.412598, idle connection 263743.000000, request 304999.582291
05/25/2026 02:14:16.227 7f8d2b7b8220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
05/25/2026 02:14:16.227 7f8d2b7b8220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
05/25/2026 02:14:16.227 7f8d2b7b8220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe9a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
05/25/2026 02:14:16.227 7f8d2b7b8220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.227 7f8d2b7b8220 [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=923314008, session_epoch=676, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.227 7f8d2b7b8220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=923314008, session_epoch=676, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.228 7f8d2b7b8220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85138.884033, idle connection 263671.000000, request 304999.943733
05/25/2026 02:14:16.228 7f8d2b7b8220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85138.443359, idle connection 263670.000000, request 304999.512911
05/25/2026 02:14:16.243 7f8d2b7b85e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85726.157227, idle connection 262926.000000, request 304398.285389
05/25/2026 02:14:16.244 7f8d2b7b85e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692
05/25/2026 02:14:16.244 7f8d2b7b85e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.244 7f8d2b7b85e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 692 (602.2217273712158 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1552728841, topics=[])
05/25/2026 02:14:16.244 7f8d2b7b85e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1552728841 with 0 response partitions (1 implied)
05/25/2026 02:14:16.244 7f8d2aebd540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87098.910156, idle connection 263858.000000, request 304398.076534
05/25/2026 02:14:16.244 7f8d2aebd540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 712
05/25/2026 02:14:16.244 7f8d2aebd540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.245 7f8d2aebd540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 712 (602.2231578826904 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1901923957, topics=[])
05/25/2026 02:14:16.245 7f8d2aebd540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1901923957 with 0 response partitions (1 implied)
05/25/2026 02:14:16.248 7f8d2aebdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86405.571045, idle connection 263420.000000, request 304399.320841
05/25/2026 02:14:16.248 7f8d2aebdc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 712
05/25/2026 02:14:16.248 7f8d2aebdc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.248 7f8d2aebdc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 712 (601.0332107543945 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=737584920, topics=[])
05/25/2026 02:14:16.248 7f8d2aebdc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 737584920 with 0 response partitions (1 implied)
05/25/2026 02:14:16.327 7f8d2a628040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 14
05/25/2026 02:14:16.327 7f8d2a628040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
05/25/2026 02:14:16.327 7f8d2a628040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fef70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
05/25/2026 02:14:16.327 7f8d2a628040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.328 7f8d2a628040 [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=1934594746, session_epoch=681, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.328 7f8d2a628040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1934594746, session_epoch=681, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.328 7f8d2a628040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86250.169434, idle connection 262770.000000, request 304999.941111
05/25/2026 02:14:16.328 7f8d2b7b8ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85644.820068, idle connection 263449.000000, request 304396.014214
05/25/2026 02:14:16.328 7f8d2a628040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86249.550781, idle connection 262769.000000, request 304999.332428
05/25/2026 02:14:16.329 7f8d2b7b8ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696
05/25/2026 02:14:16.329 7f8d2b7b8ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.329 7f8d2b7b8ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 696 (604.7196388244629 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=91760380, topics=[])
05/25/2026 02:14:16.329 7f8d2b7b8ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 91760380 with 0 response partitions (1 implied)
05/25/2026 02:14:16.342 7f8d2aebd900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86150.236084, idle connection 263572.000000, request 304399.099350
05/25/2026 02:14:16.343 7f8d2aebd900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742
05/25/2026 02:14:16.343 7f8d2aebd900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.343 7f8d2aebd900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 742 (601.4881134033203 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=527807142, topics=[])
05/25/2026 02:14:16.343 7f8d2aebd900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 527807142 with 0 response partitions (1 implied)
05/25/2026 02:14:16.404 7f8d2aebdae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86295.427979, idle connection 263333.000000, request 304398.972273
05/25/2026 02:14:16.405 7f8d2aebdae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 732
05/25/2026 02:14:16.405 7f8d2aebdae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.405 7f8d2aebdae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 732 (601.6073226928711 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1342488165, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=231, last_stable_offset=231, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xe4\x00\x00\x01\xed\x00\x00\x00\x00\x02\xb7\x03wD\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\xb8\x03\x00\x00\x00\xfa\x02ObjectGeneratorInfo:cn-jenkins-d...')])])
05/25/2026 02:14:16.405 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1342488165 with 1 response partitions (0 implied)
05/25/2026 02:14:16.405 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 780 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 228
05/25/2026 02:14:16.405 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 228 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0)
05/25/2026 02:14:16.406 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 231 (leader epoch 0)
05/25/2026 02:14:16.447 7f8d2aebd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86122.926514, idle connection 263140.000000, request 304399.070024
05/25/2026 02:14:16.447 7f8d2aebd4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 736
05/25/2026 02:14:16.447 7f8d2aebd4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.448 7f8d2aebd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 736 (601.4580726623535 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=991613665, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=315, last_stable_offset=315, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01:\x00\x00\x00\xfe\x00\x00\x00\x00\x02M9\x02\xda\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\x96\x03\x00\x00\x00\xd8\x02ObjectVNTable:default-domain:def...')])])
05/25/2026 02:14:16.448 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 991613665 with 1 response partitions (0 implied)
05/25/2026 02:14:16.448 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 266 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 314
05/25/2026 02:14:16.448 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 314 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0)
05/25/2026 02:14:16.448 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 315 (leader epoch 0)
05/25/2026 02:14:16.464 7f8d29024680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85853.821533, idle connection 262899.000000, request 304399.122953
05/25/2026 02:14:16.465 7f8d29024680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1012
05/25/2026 02:14:16.465 7f8d29024680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.465 7f8d29024680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 1012 (601.4251708984375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=59175018, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3770, last_stable_offset=3770, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xb9\x00\x00\x01\x05\x00\x00\x00\x00\x02\xfe\xab\xd3y\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
05/25/2026 02:14:16.465 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 59175018 with 1 response partitions (0 implied)
05/25/2026 02:14:16.465 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3769
05/25/2026 02:14:16.465 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3769 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
05/25/2026 02:14:16.465 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3770 (leader epoch 0)
05/25/2026 02:14:16.483 7f8d2a628400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 37
05/25/2026 02:14:16.483 7f8d2a628400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
05/25/2026 02:14:16.483 7f8d2a628400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293f33a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
05/25/2026 02:14:16.483 7f8d2a628400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.483 7f8d2a628400 [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=1571174740, session_epoch=690, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.483 7f8d2a628400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1571174740, session_epoch=690, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.483 7f8d2a628400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86516.729248, idle connection 262871.000000, request 304999.948740
05/25/2026 02:14:16.484 7f8d2a628400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86516.278076, idle connection 262870.000000, request 304999.504089
05/25/2026 02:14:16.486 7f8d290c4e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84504.024902, idle connection 263145.000000, request 304398.560762
05/25/2026 02:14:16.486 7f8d290c4e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 680
05/25/2026 02:14:16.486 7f8d290c4e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.486 7f8d290c4e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 680 (601.8059253692627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=428815477, topics=[])
05/25/2026 02:14:16.487 7f8d290c4e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 428815477 with 0 response partitions (1 implied)
05/25/2026 02:14:16.488 7f8d28e9fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85732.238037, idle connection 263144.000000, request 304397.592545
05/25/2026 02:14:16.488 7f8d28e9fd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691
05/25/2026 02:14:16.488 7f8d28e9fd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.488 7f8d28e9fd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 691 (602.7228832244873 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=514561681, topics=[])
05/25/2026 02:14:16.489 7f8d28e9fd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 514561681 with 0 response partitions (1 implied)
05/25/2026 02:14:16.489 7f8d2aebd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85329.316406, idle connection 262765.000000, request 304397.706747
05/25/2026 02:14:16.489 7f8d2b7b8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85793.048584, idle connection 263433.000000, request 304398.145914
05/25/2026 02:14:16.489 7f8d2aebd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684
05/25/2026 02:14:16.489 7f8d2aebd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.489 7f8d2aebd040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 684 (602.7359962463379 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1045580783, topics=[])
05/25/2026 02:14:16.489 7f8d2aebd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1045580783 with 0 response partitions (1 implied)
05/25/2026 02:14:16.490 7f8d2b7b8720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689
05/25/2026 02:14:16.490 7f8d2b7b8720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.490 7f8d2b7b8720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 689 (602.625846862793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1702416795, topics=[])
05/25/2026 02:14:16.490 7f8d2b7b8720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1702416795 with 0 response partitions (1 implied)
05/25/2026 02:14:16.499 7f8d2aebd9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 194
05/25/2026 02:14:16.499 7f8d2aebd9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
05/25/2026 02:14:16.499 7f8d2aebd9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fc3a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
05/25/2026 02:14:16.499 7f8d2aebd9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.499 7f8d2aebd9a0 [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=1148682961, session_epoch=715, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.499 7f8d2aebd9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 719 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1148682961, session_epoch=715, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.499 7f8d2aebd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84996.079590, idle connection 262918.000000, request 304999.951839
05/25/2026 02:14:16.500 7f8d2aebd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84995.659424, idle connection 262917.000000, request 304999.536037
05/25/2026 02:14:16.506 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 231
05/25/2026 02:14:16.506 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
05/25/2026 02:14:16.506 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293ef8e0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
05/25/2026 02:14:16.506 7f8d2aebdae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.506 7f8d2aebdae0 [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=1342488165, session_epoch=729, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=231, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.507 7f8d2aebdae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1342488165, session_epoch=729, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=231, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.507 7f8d2aebdae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86192.861084, idle connection 263230.000000, request 304999.953270
05/25/2026 02:14:16.507 7f8d2aebdae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86192.509766, idle connection 263230.000000, request 304999.604702
05/25/2026 02:14:16.507 7f8d2aebd860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85574.925537, idle connection 263216.000000, request 304398.321152
05/25/2026 02:14:16.508 7f8d2aebd860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 739
05/25/2026 02:14:16.508 7f8d2aebd860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.508 7f8d2aebd860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 739 (602.0314693450928 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1748052302, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=263, last_stable_offset=263, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01\x05\x00\x00\x01\xc1\x00\x00\x00\x00\x02\x02\x0f(v\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\x8c\x03\x00\x00\x00\xce\x02ObjectVNTable:default-domain:def...')])])
05/25/2026 02:14:16.508 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1748052302 with 1 response partitions (0 implied)
05/25/2026 02:14:16.508 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 461 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 261
05/25/2026 02:14:16.508 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 261 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0)
05/25/2026 02:14:16.509 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 263 (leader epoch 0)
05/25/2026 02:14:16.509 7f8d2b7b8d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85558.450928, idle connection 263032.000000, request 304397.845984
05/25/2026 02:14:16.509 7f8d2b7b8d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 702
05/25/2026 02:14:16.509 7f8d2b7b8d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.509 7f8d2b7b8d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 702 (602.489709854126 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=913316371, topics=[])
05/25/2026 02:14:16.509 7f8d2b7b8d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 913316371 with 0 response partitions (1 implied)
05/25/2026 02:14:16.529 7f8d2b7b8360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84727.181641, idle connection 262881.000000, request 304399.010658
05/25/2026 02:14:16.529 7f8d2b7b8360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721
05/25/2026 02:14:16.529 7f8d2b7b8360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.529 7f8d2b7b8360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 721 (601.4485359191895 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=784650634, topics=[])
05/25/2026 02:14:16.530 7f8d2b7b8360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 784650634 with 0 response partitions (1 implied)
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 35
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d29783a30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [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=790185305, session_epoch=685, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=790185305, session_epoch=685, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.547 7f8d2b7b8cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85173.584473, idle connection 262928.000000, request 304999.947548
05/25/2026 02:14:16.548 7f8d2b7b8cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85173.157471, idle connection 262928.000000, request 304999.526978
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 315
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293edee0> 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)])
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.549 7f8d2aebd4a0 [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=991613665, session_epoch=733, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=315, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 737 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=991613665, session_epoch=733, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=315, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86020.713379, idle connection 263038.000000, request 304999.958754
05/25/2026 02:14:16.549 7f8d2aebd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86020.411621, idle connection 263038.000000, request 304999.660492
05/25/2026 02:14:16.561 7f8d2b7b8900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 66
05/25/2026 02:14:16.561 7f8d2b7b8900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
05/25/2026 02:14:16.561 7f8d2b7b8900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fc7c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
05/25/2026 02:14:16.561 7f8d2b7b8900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.561 7f8d2b7b8900 [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=2082826192, session_epoch=689, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.562 7f8d2b7b8900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=2082826192, session_epoch=689, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.562 7f8d2b7b8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85842.750977, idle connection 263588.000000, request 304999.955177
05/25/2026 02:14:16.562 7f8d2b7b8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85842.310303, idle connection 263587.000000, request 304999.515772
05/25/2026 02:14:16.566 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3770
05/25/2026 02:14:16.566 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
05/25/2026 02:14:16.566 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe220> 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)])
05/25/2026 02:14:16.566 7f8d29024680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.566 7f8d29024680 [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=59175018, session_epoch=1009, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3770, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.566 7f8d29024680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 1013 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=59175018, session_epoch=1009, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3770, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.566 7f8d29024680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85751.557617, idle connection 262797.000000, request 304999.958515
05/25/2026 02:14:16.567 7f8d29024680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85751.251709, idle connection 262796.000000, request 304999.655485
05/25/2026 02:14:16.605 7f8d2aebd2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85995.173096, idle connection 262604.000000, request 304398.885727
05/25/2026 02:14:16.605 7f8d2aebd2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721
05/25/2026 02:14:16.605 7f8d2aebd2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.605 7f8d2aebd2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 721 (601.6645431518555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349939775, topics=[])
05/25/2026 02:14:16.606 7f8d2aebd2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1349939775 with 0 response partitions (1 implied)
05/25/2026 02:14:16.611 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 263
05/25/2026 02:14:16.611 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
05/25/2026 02:14:16.612 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e6880> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
05/25/2026 02:14:16.612 7f8d2aebd860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.612 7f8d2aebd860 [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=1748052302, session_epoch=736, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=263, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.612 7f8d2aebd860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 740 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1748052302, session_epoch=736, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=263, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/25/2026 02:14:16.612 7f8d2aebd860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85470.337158, idle connection 263111.000000, request 304999.943256
05/25/2026 02:14:16.633 7f8d2aebd860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85449.817871, idle connection 263090.000000, request 304979.426861
05/25/2026 02:14:16.638 7f8d2b7b8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84619.575195, idle connection 263212.000000, request 304395.207882
05/25/2026 02:14:16.639 7f8d2b7b8f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687
05/25/2026 02:14:16.639 7f8d2b7b8f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.639 7f8d2b7b8f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 687 (605.595588684082 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=430489968, topics=[])
05/25/2026 02:14:16.639 7f8d2b7b8f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 430489968 with 0 response partitions (1 implied)
05/25/2026 02:14:16.664 7f8d2aebd720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85903.246338, idle connection 263072.000000, request 304399.027586
05/25/2026 02:14:16.665 7f8d2aebd720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 707
05/25/2026 02:14:16.665 7f8d2aebd720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.665 7f8d2aebd720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 707 (601.513147354126 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=38729996, topics=[])
05/25/2026 02:14:16.665 7f8d2aebd720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 38729996 with 0 response partitions (1 implied)
05/25/2026 02:14:16.721 7f8d2aebd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86122.876709, idle connection 263524.000000, request 304398.760557
05/25/2026 02:14:16.722 7f8d2aebd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 726
05/25/2026 02:14:16.722 7f8d2aebd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.722 7f8d2aebd220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 726 (601.7754077911377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1269635716, topics=[])
05/25/2026 02:14:16.722 7f8d2aebd220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1269635716 with 0 response partitions (1 implied)
05/25/2026 02:14:16.742 7f8d2c3ee180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 12
05/25/2026 02:14:16.742 7f8d2c3ee180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
05/25/2026 02:14:16.742 7f8d2c3ee180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293f3c40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
05/25/2026 02:14:16.742 7f8d2c3ee180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.742 7f8d2c3ee180 [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=209320144, session_epoch=681, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.742 7f8d2c3ee180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=209320144, session_epoch=681, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.742 7f8d2c3ee180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85829.763672, idle connection 262889.000000, request 304999.945402
05/25/2026 02:14:16.743 7f8d2c3ee180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85829.339111, idle connection 262889.000000, request 304999.529123
05/25/2026 02:14:16.745 7f8d28e9fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 8
05/25/2026 02:14:16.745 7f8d28e9fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
05/25/2026 02:14:16.745 7f8d28e9fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d29760b50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
05/25/2026 02:14:16.745 7f8d28e9fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.745 7f8d28e9fc20 [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=548789102, session_epoch=680, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.745 7f8d28e9fc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=548789102, session_epoch=680, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.746 7f8d28e9fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84936.140869, idle connection 263246.000000, request 304999.954224
05/25/2026 02:14:16.746 7f8d28e9fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84935.814941, idle connection 263246.000000, request 304999.631643
05/25/2026 02:14:16.749 7f8d2b7b89a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85300.961182, idle connection 262744.000000, request 304399.053574
05/25/2026 02:14:16.749 7f8d2b7b89a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695
05/25/2026 02:14:16.749 7f8d2b7b89a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.749 7f8d2b7b89a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 695 (601.3052463531494 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1257883594, topics=[])
05/25/2026 02:14:16.750 7f8d2b7b89a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1257883594 with 0 response partitions (1 implied)
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 14
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe5e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.750 7f8d2c3ee400 [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=1837599653, session_epoch=679, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1837599653, session_epoch=679, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84537.897705, idle connection 263146.000000, request 304999.960661
05/25/2026 02:14:16.750 7f8d2c3ee400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84537.603027, idle connection 263146.000000, request 304999.668837
05/25/2026 02:14:16.755 7f8d2a628b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84608.097900, idle connection 263142.000000, request 304399.265051
05/25/2026 02:14:16.755 7f8d2a628b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 680
05/25/2026 02:14:16.755 7f8d2a628b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.756 7f8d2a628b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 680 (601.1054515838623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307782535, topics=[])
05/25/2026 02:14:16.756 7f8d2a628b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307782535 with 0 response partitions (1 implied)
05/25/2026 02:14:16.829 7f8d2b7b8220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84537.100830, idle connection 263069.000000, request 304398.162127
05/25/2026 02:14:16.830 7f8d2b7b8220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 680
05/25/2026 02:14:16.830 7f8d2b7b8220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.830 7f8d2b7b8220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 680 (602.4055480957031 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=923314008, topics=[])
05/25/2026 02:14:16.830 7f8d2b7b8220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 923314008 with 0 response partitions (1 implied)
05/25/2026 02:14:16.844 7f8d2b7b85e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 63
05/25/2026 02:14:16.844 7f8d2b7b85e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
05/25/2026 02:14:16.845 7f8d2b7b85e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293e63d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
05/25/2026 02:14:16.845 7f8d2b7b85e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.845 7f8d2b7b85e0 [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=1552728841, session_epoch=689, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.845 7f8d2b7b85e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=1552728841, session_epoch=689, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.845 7f8d2b7b85e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85124.513428, idle connection 262324.000000, request 304999.939203
05/25/2026 02:14:16.845 7f8d2aebd540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 141
05/25/2026 02:14:16.845 7f8d2aebd540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
05/25/2026 02:14:16.845 7f8d2aebd540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe850> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
05/25/2026 02:14:16.845 7f8d2aebd540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.845 7f8d2aebd540 [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=1901923957, session_epoch=709, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.846 7f8d2aebd540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 713 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1901923957, session_epoch=709, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.846 7f8d2aebd540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86497.495361, idle connection 263257.000000, request 304999.963760
05/25/2026 02:14:16.846 7f8d2b7b85e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85123.469238, idle connection 262323.000000, request 304998.903275
05/25/2026 02:14:16.846 7f8d2aebd540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86496.785889, idle connection 263256.000000, request 304999.258518
05/25/2026 02:14:16.848 7f8d2aebdc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
05/25/2026 02:14:16.848 7f8d2aebdc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
05/25/2026 02:14:16.848 7f8d2aebdc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fe370> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
05/25/2026 02:14:16.848 7f8d2aebdc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.849 7f8d2aebdc20 [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=737584920, session_epoch=709, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.849 7f8d2aebdc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 713 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=737584920, session_epoch=709, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.849 7f8d2aebdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85804.386963, idle connection 262819.000000, request 304999.964476
05/25/2026 02:14:16.849 7f8d2aebdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85804.073975, idle connection 262819.000000, request 304999.653339
05/25/2026 02:14:16.929 7f8d2b7b8ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 49
05/25/2026 02:14:16.930 7f8d2b7b8ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
05/25/2026 02:14:16.930 7f8d2b7b8ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293fcd90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
05/25/2026 02:14:16.930 7f8d2b7b8ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.930 7f8d2b7b8ae0 [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=91760380, session_epoch=693, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.930 7f8d2b7b8ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=91760380, session_epoch=693, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.930 7f8d2b7b8ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85042.787354, idle connection 262847.000000, request 304999.945641
05/25/2026 02:14:16.930 7f8d2a628040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85647.625000, idle connection 262167.000000, request 304397.405624
05/25/2026 02:14:16.931 7f8d2b7b8ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85042.135986, idle connection 262846.000000, request 304999.303579
05/25/2026 02:14:16.931 7f8d2a628040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 685
05/25/2026 02:14:16.931 7f8d2a628040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/25/2026 02:14:16.931 7f8d2a628040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 685 (603.3928394317627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1934594746, topics=[])
05/25/2026 02:14:16.931 7f8d2a628040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1934594746 with 0 response partitions (1 implied)
05/25/2026 02:14:16.944 7f8d2aebd900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 323
05/25/2026 02:14:16.944 7f8d2aebd900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
05/25/2026 02:14:16.944 7f8d2aebd900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f8d293ef3d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
05/25/2026 02:14:16.944 7f8d2aebd900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/25/2026 02:14:16.944 7f8d2aebd900 [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=527807142, session_epoch=739, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.945 7f8d2aebd900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 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=527807142, session_epoch=739, topics=[], forgotten_topics_data=[])
05/25/2026 02:14:16.945 7f8d2aebd900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85547.584961, idle connection 262970.000000, request 304999.921560
05/25/2026 02:14:16.945 7f8d2aebd900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85547.134521, idle connection 262969.000000, request 304999.477625