10/23/2025 02:08:29.612 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
10/23/2025 02:08:29.613 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
10/23/2025 02:08:29.613 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5ff040> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
10/23/2025 02:08:29.613 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.613 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=506759906, session_epoch=737, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.613 7f9d6d3eec20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 741 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=506759906, session_epoch=737, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.613 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11454.751465, idle connection 188795.000000, request 304999.956608
10/23/2025 02:08:29.614 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11161.967773, idle connection 189699.000000, request 304396.209002
10/23/2025 02:08:29.614 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11453.800781, idle connection 188795.000000, request 304999.010563
10/23/2025 02:08:29.615 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 747
10/23/2025 02:08:29.615 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:29.615 7f9d6c1417c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 747 (604.7215461730957 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2132864108, topics=[])
10/23/2025 02:08:29.615 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2132864108 with 0 response partitions (1 implied)
10/23/2025 02:08:29.619 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
10/23/2025 02:08:29.619 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
10/23/2025 02:08:29.619 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46dd60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
10/23/2025 02:08:29.620 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.620 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029254678, session_epoch=737, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.620 7f9d6c141040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 741 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029254678, session_epoch=737, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.620 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11450.200928, idle connection 188790.000000, request 304999.956608
10/23/2025 02:08:29.620 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11449.830811, idle connection 188789.000000, request 304999.591589
10/23/2025 02:08:29.634 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 190
10/23/2025 02:08:29.634 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
10/23/2025 02:08:29.634 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5ff280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
10/23/2025 02:08:29.634 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.634 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776426665, session_epoch=780, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.634 7f9d6d3eef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 784 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776426665, session_epoch=780, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.635 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11548.889404, idle connection 188716.000000, request 304999.940395
10/23/2025 02:08:29.635 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11548.508545, idle connection 188715.000000, request 304999.565363
10/23/2025 02:08:29.671 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 12407.215332, idle connection 189537.000000, request 304398.820400
10/23/2025 02:08:29.672 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 782
10/23/2025 02:08:29.672 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:29.672 7f9d6b650c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 782 (601.717472076416 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459735899, topics=[])
10/23/2025 02:08:29.672 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1459735899 with 0 response partitions (1 implied)
10/23/2025 02:08:29.777 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 49
10/23/2025 02:08:29.777 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
10/23/2025 02:08:29.778 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5a4070> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
10/23/2025 02:08:29.778 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.778 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123674361, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.778 7f9d6c141ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123674361, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.778 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11373.373535, idle connection 188724.000000, request 304999.944925
10/23/2025 02:08:29.778 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11372.916016, idle connection 188724.000000, request 304999.494791
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 46
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a81bac0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=693831948, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=693831948, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.779 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11477.078125, idle connection 189837.000000, request 304999.962568
10/23/2025 02:08:29.779 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 23
10/23/2025 02:08:29.779 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
10/23/2025 02:08:29.780 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5976d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
10/23/2025 02:08:29.780 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.780 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1592531477, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.780 7f9d6c141540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 749 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1592531477, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.780 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11596.378174, idle connection 188954.000000, request 304999.966383
10/23/2025 02:08:29.780 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11476.094238, idle connection 189836.000000, request 304998.981476
10/23/2025 02:08:29.780 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11595.826904, idle connection 188953.000000, request 304999.418020
10/23/2025 02:08:29.840 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 381
10/23/2025 02:08:29.840 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/23/2025 02:08:29.840 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479f10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
10/23/2025 02:08:29.840 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.841 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=802, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.841 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 806 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=802, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.841 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11046.203857, idle connection 188995.000000, request 304999.947548
10/23/2025 02:08:29.841 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11045.782715, idle connection 188994.000000, request 304999.536514
10/23/2025 02:08:29.843 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10833.829834, idle connection 188484.000000, request 304398.346901
10/23/2025 02:08:29.844 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 746
10/23/2025 02:08:29.844 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:29.844 7f9d6c141220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 746 (602.0944118499756 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1766330240, topics=[])
10/23/2025 02:08:29.844 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1766330240 with 0 response partitions (1 implied)
10/23/2025 02:08:29.844 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 12247.446533, idle connection 189607.000000, request 304398.239613
10/23/2025 02:08:29.844 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 758
10/23/2025 02:08:29.844 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:29.844 7f9d6c141b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 758 (602.0557880401611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=847983267, topics=[])
10/23/2025 02:08:29.844 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 847983267 with 0 response partitions (1 implied)
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 43
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47c670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1992472767, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1992472767, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.901 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11479.426270, idle connection 188857.000000, request 304999.942541
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 31
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47c3d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=198852300, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=198852300, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.902 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10776.407471, idle connection 189307.000000, request 304999.964476
10/23/2025 02:08:29.902 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11478.355225, idle connection 188856.000000, request 304998.883009
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 26
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479340> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277230090, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277230090, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.903 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11210.697510, idle connection 188574.000000, request 304999.967098
10/23/2025 02:08:29.903 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10775.100342, idle connection 189305.000000, request 304998.660088
10/23/2025 02:08:29.904 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11210.061279, idle connection 188574.000000, request 304999.333382
10/23/2025 02:08:29.905 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 12075.189941, idle connection 189200.000000, request 304399.276972
10/23/2025 02:08:29.905 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 749
10/23/2025 02:08:29.905 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:29.906 7f9d6c141cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 749 (601.0682582855225 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=406878178, topics=[])
10/23/2025 02:08:29.906 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 406878178 with 0 response partitions (1 implied)
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 139
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479790> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416108689, session_epoch=768, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 772 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416108689, session_epoch=768, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10761.249512, idle connection 188623.000000, request 304999.956846
10/23/2025 02:08:29.914 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10760.891357, idle connection 188623.000000, request 304999.603748
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 18
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47cf40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=465380140, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 748 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=465380140, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.001 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10379.932129, idle connection 188929.000000, request 304999.942541
10/23/2025 02:08:30.002 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10883.697754, idle connection 188572.000000, request 304397.352934
10/23/2025 02:08:30.002 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10379.276855, idle connection 188928.000000, request 304999.297142
10/23/2025 02:08:30.002 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 746
10/23/2025 02:08:30.002 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.003 7f9d6b134400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 746 (603.4257411956787 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=734312328, topics=[])
10/23/2025 02:08:30.003 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 734312328 with 0 response partitions (1 implied)
10/23/2025 02:08:30.011 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 214
10/23/2025 02:08:30.012 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/23/2025 02:08:30.012 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46d0a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/23/2025 02:08:30.012 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.012 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=619652300, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.012 7f9d6b650a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=619652300, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.012 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11775.302490, idle connection 189155.000000, request 304999.947071
10/23/2025 02:08:30.013 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11774.921631, idle connection 189155.000000, request 304999.573231
10/23/2025 02:08:30.042 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 277
10/23/2025 02:08:30.043 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
10/23/2025 02:08:30.043 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47c040> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
10/23/2025 02:08:30.043 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.043 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=960564100, session_epoch=805, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.043 7f9d6b6509a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=960564100, session_epoch=805, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.043 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11543.395508, idle connection 188935.000000, request 304999.945641
10/23/2025 02:08:30.044 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11542.922363, idle connection 188934.000000, request 304999.482155
10/23/2025 02:08:30.072 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10706.119873, idle connection 188551.000000, request 304398.038626
10/23/2025 02:08:30.072 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 783
10/23/2025 02:08:30.072 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.072 7f9d6b650540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 783 (602.4966239929199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=57599649, topics=[])
10/23/2025 02:08:30.072 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 57599649 with 0 response partitions (1 implied)
10/23/2025 02:08:30.073 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11259.072754, idle connection 188403.000000, request 304397.698402
10/23/2025 02:08:30.074 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 752
10/23/2025 02:08:30.074 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.074 7f9d6b0c6860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 752 (602.6289463043213 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=844134647, topics=[])
10/23/2025 02:08:30.074 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 844134647 with 0 response partitions (1 implied)
10/23/2025 02:08:30.075 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11300.132568, idle connection 189133.000000, request 304397.867680
10/23/2025 02:08:30.075 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 763
10/23/2025 02:08:30.075 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.075 7f9d6b6502c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 763 (602.4315357208252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1126391604, topics=[])
10/23/2025 02:08:30.075 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1126391604 with 0 response partitions (1 implied)
10/23/2025 02:08:30.115 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10963.418457, idle connection 188322.000000, request 304396.892071
10/23/2025 02:08:30.116 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 747
10/23/2025 02:08:30.116 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.116 7f9d6b1bcea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 747 (603.6429405212402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1484190749, topics=[])
10/23/2025 02:08:30.116 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1484190749 with 0 response partitions (1 implied)
10/23/2025 02:08:30.116 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11472.528320, idle connection 188896.000000, request 304396.667004
10/23/2025 02:08:30.117 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 749
10/23/2025 02:08:30.117 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.117 7f9d6b0e7400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 749 (603.8827896118164 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277879316, topics=[])
10/23/2025 02:08:30.117 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277879316 with 0 response partitions (1 implied)
10/23/2025 02:08:30.143 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 12117.191895, idle connection 188969.000000, request 304398.581505
10/23/2025 02:08:30.144 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 765
10/23/2025 02:08:30.144 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.144 7f9d6b19f360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 765 (602.1273136138916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1707088916, topics=[])
10/23/2025 02:08:30.144 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1707088916 with 0 response partitions (1 implied)
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 185
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46ae50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014790684, session_epoch=783, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 787 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014790684, session_epoch=783, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.176 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 12210.467041, idle connection 188482.000000, request 304999.944925
10/23/2025 02:08:30.177 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11005.297119, idle connection 188977.000000, request 304395.944118
10/23/2025 02:08:30.177 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 12209.772461, idle connection 188482.000000, request 304999.257088
10/23/2025 02:08:30.177 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 797
10/23/2025 02:08:30.177 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.178 7f9d6b6507c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 797 (605.0198078155518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=368197022, topics=[])
10/23/2025 02:08:30.178 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 368197022 with 0 response partitions (1 implied)
10/23/2025 02:08:30.184 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11792.317871, idle connection 188562.000000, request 304398.501873
10/23/2025 02:08:30.184 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 778
10/23/2025 02:08:30.184 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.184 7f9d6b650400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 778 (601.8795967102051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1251811946, topics=[])
10/23/2025 02:08:30.184 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1251811946 with 0 response partitions (1 implied)
10/23/2025 02:08:30.210 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9827.366943, idle connection 188380.000000, request 304398.688078
10/23/2025 02:08:30.211 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1094
10/23/2025 02:08:30.211 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.211 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 1094 (601.9086837768555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=208911105, topics=[])
10/23/2025 02:08:30.211 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 208911105 with 0 response partitions (1 implied)
10/23/2025 02:08:30.216 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
10/23/2025 02:08:30.216 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
10/23/2025 02:08:30.216 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a460910> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
10/23/2025 02:08:30.217 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.217 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2132864108, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.217 7f9d6c1417c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 748 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2132864108, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.217 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10558.927490, idle connection 189096.000000, request 304999.949455
10/23/2025 02:08:30.217 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10850.965820, idle connection 188192.000000, request 304396.173477
10/23/2025 02:08:30.218 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10558.164062, idle connection 189095.000000, request 304999.191761
10/23/2025 02:08:30.218 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 741
10/23/2025 02:08:30.218 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.218 7f9d6d3eec20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 741 (604.7384738922119 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=506759906, topics=[])
10/23/2025 02:08:30.218 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 506759906 with 0 response partitions (1 implied)
10/23/2025 02:08:30.221 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10848.696777, idle connection 188188.000000, request 304398.455143
10/23/2025 02:08:30.222 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 741
10/23/2025 02:08:30.222 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.222 7f9d6c141040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 741 (601.9089221954346 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1029254678, topics=[])
10/23/2025 02:08:30.222 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1029254678 with 0 response partitions (1 implied)
10/23/2025 02:08:30.236 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10947.846680, idle connection 188115.000000, request 304398.896456
10/23/2025 02:08:30.236 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 784
10/23/2025 02:08:30.236 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.236 7f9d6d3eef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 784 (601.5501022338867 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=776426665, topics=[])
10/23/2025 02:08:30.236 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 776426665 with 0 response partitions (1 implied)
10/23/2025 02:08:30.273 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 174
10/23/2025 02:08:30.273 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
10/23/2025 02:08:30.273 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a460f70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
10/23/2025 02:08:30.273 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.274 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459735899, session_epoch=779, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.274 7f9d6b650c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 783 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459735899, session_epoch=779, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.274 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11804.642578, idle connection 188934.000000, request 304999.938726
10/23/2025 02:08:30.274 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11804.111084, idle connection 188934.000000, request 304999.416590
10/23/2025 02:08:30.380 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10771.796875, idle connection 188122.000000, request 304398.366690
10/23/2025 02:08:30.380 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 752
10/23/2025 02:08:30.380 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.380 7f9d6c141ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 752 (602.2534370422363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=123674361, topics=[])
10/23/2025 02:08:30.380 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 123674361 with 0 response partitions (1 implied)
10/23/2025 02:08:30.381 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10875.547119, idle connection 189236.000000, request 304398.430824
10/23/2025 02:08:30.381 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 752
10/23/2025 02:08:30.381 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.381 7f9d6c141860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 752 (601.8688678741455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=693831948, topics=[])
10/23/2025 02:08:30.381 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 693831948 with 0 response partitions (1 implied)
10/23/2025 02:08:30.381 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10994.954102, idle connection 188352.000000, request 304398.543835
10/23/2025 02:08:30.381 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 749
10/23/2025 02:08:30.382 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.382 7f9d6c141540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 749 (601.7460823059082 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1592531477, topics=[])
10/23/2025 02:08:30.382 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1592531477 with 0 response partitions (1 implied)
10/23/2025 02:08:30.442 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10445.146484, idle connection 188394.000000, request 304398.890257
10/23/2025 02:08:30.442 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 806
10/23/2025 02:08:30.442 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.442 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 806 (601.654052734375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1767298541, topics=[])
10/23/2025 02:08:30.443 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1767298541 with 0 response partitions (1 implied)
10/23/2025 02:08:30.444 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 12
10/23/2025 02:08:30.444 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
10/23/2025 02:08:30.444 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479a00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
10/23/2025 02:08:30.444 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.444 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1766330240, session_epoch=743, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.444 7f9d6c141220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 747 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1766330240, session_epoch=743, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.445 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10232.456787, idle connection 187883.000000, request 304999.938250
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 91
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4b4df0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=847983267, session_epoch=755, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 759 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=847983267, session_epoch=755, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.445 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11646.191406, idle connection 189005.000000, request 304999.964952
10/23/2025 02:08:30.446 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10231.439697, idle connection 187882.000000, request 304998.924494
10/23/2025 02:08:30.446 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11645.541260, idle connection 189005.000000, request 304999.317408
10/23/2025 02:08:30.504 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10876.982666, idle connection 188255.000000, request 304397.497892
10/23/2025 02:08:30.504 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 751
10/23/2025 02:08:30.504 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.504 7f9d6b1bc4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 751 (603.0528545379639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1992472767, topics=[])
10/23/2025 02:08:30.505 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1992472767 with 0 response partitions (1 implied)
10/23/2025 02:08:30.505 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10173.701904, idle connection 188704.000000, request 304397.259951
10/23/2025 02:08:30.505 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10608.859131, idle connection 187972.000000, request 304398.129702
10/23/2025 02:08:30.505 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 751
10/23/2025 02:08:30.505 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.505 7f9d6b1622c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 751 (603.2259464263916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=198852300, topics=[])
10/23/2025 02:08:30.505 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 198852300 with 0 response partitions (1 implied)
10/23/2025 02:08:30.506 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 751
10/23/2025 02:08:30.506 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.506 7f9d6c141360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 751 (602.8549671173096 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277230090, topics=[])
10/23/2025 02:08:30.506 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277230090 with 0 response partitions (1 implied)
10/23/2025 02:08:30.506 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 33
10/23/2025 02:08:30.506 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
10/23/2025 02:08:30.506 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5dc6d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
10/23/2025 02:08:30.507 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.507 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406878178, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.507 7f9d6c141cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 750 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406878178, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.507 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11473.487549, idle connection 188598.000000, request 304999.956369
10/23/2025 02:08:30.507 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11473.099121, idle connection 188597.000000, request 304999.571323
10/23/2025 02:08:30.515 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10160.535889, idle connection 188023.000000, request 304399.245501
10/23/2025 02:08:30.515 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 772
10/23/2025 02:08:30.515 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.515 7f9d6b650180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 772 (601.2129783630371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416108689, topics=[])
10/23/2025 02:08:30.515 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416108689 with 0 response partitions (1 implied)
10/23/2025 02:08:30.603 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15
10/23/2025 02:08:30.603 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
10/23/2025 02:08:30.603 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a546ac0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
10/23/2025 02:08:30.603 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.604 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=734312328, session_epoch=743, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.604 7f9d6b134400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 747 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=734312328, session_epoch=743, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.604 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10281.619629, idle connection 187970.000000, request 304999.944925
10/23/2025 02:08:30.604 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9777.314453, idle connection 188326.000000, request 304397.332191
10/23/2025 02:08:30.605 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10280.863770, idle connection 187969.000000, request 304999.198437
10/23/2025 02:08:30.605 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 748
10/23/2025 02:08:30.605 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.605 7f9d6b0c6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 748 (603.5969257354736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=465380140, topics=[])
10/23/2025 02:08:30.605 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 465380140 with 0 response partitions (1 implied)
10/23/2025 02:08:30.613 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11174.426514, idle connection 188554.000000, request 304399.073124
10/23/2025 02:08:30.613 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 785
10/23/2025 02:08:30.613 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.613 7f9d6b650a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 785 (601.3460159301758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=619652300, topics=[])
10/23/2025 02:08:30.614 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 619652300 with 0 response partitions (1 implied)
10/23/2025 02:08:30.645 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10942.086182, idle connection 188333.000000, request 304398.637056
10/23/2025 02:08:30.645 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 809
10/23/2025 02:08:30.645 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.645 7f9d6b6509a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 809 (601.9666194915771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=960564100, topics=[])
10/23/2025 02:08:30.645 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 960564100 with 0 response partitions (1 implied)
10/23/2025 02:08:30.674 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 234
10/23/2025 02:08:30.674 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
10/23/2025 02:08:30.674 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47ca90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
10/23/2025 02:08:30.674 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.674 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=57599649, session_epoch=780, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.674 7f9d6b650540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 784 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=57599649, session_epoch=780, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.675 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10103.333008, idle connection 187948.000000, request 304999.940634
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 32
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46d670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=844134647, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=844134647, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.675 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10657.268555, idle connection 187801.000000, request 304999.961376
10/23/2025 02:08:30.676 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10102.173584, idle connection 187947.000000, request 304998.791456
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 130
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4791c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126391604, session_epoch=760, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 764 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126391604, session_epoch=760, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.676 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10698.271240, idle connection 188531.000000, request 304999.962807
10/23/2025 02:08:30.677 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10655.875732, idle connection 187800.000000, request 304998.568535
10/23/2025 02:08:30.677 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10697.405029, idle connection 188530.000000, request 304999.099970
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 27
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47ceb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1484190749, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 748 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1484190749, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.718 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10360.482666, idle connection 187719.000000, request 304999.929190
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 36
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46abb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277879316, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 750 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277879316, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.719 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10869.710205, idle connection 188294.000000, request 304999.961615
10/23/2025 02:08:30.720 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10359.236816, idle connection 187718.000000, request 304998.699665
10/23/2025 02:08:30.720 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10868.894775, idle connection 188293.000000, request 304999.149799
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 100
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479610> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1707088916, session_epoch=762, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 766 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1707088916, session_epoch=762, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.745 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11514.959229, idle connection 188366.000000, request 304999.942780
10/23/2025 02:08:30.746 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11514.464355, idle connection 188366.000000, request 304999.456406
10/23/2025 02:08:30.779 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 267
10/23/2025 02:08:30.779 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
10/23/2025 02:08:30.779 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47ca60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
10/23/2025 02:08:30.779 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.779 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368197022, session_epoch=794, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.780 7f9d6b6507c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 798 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368197022, session_epoch=794, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.780 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10402.104736, idle connection 188374.000000, request 304999.944687
10/23/2025 02:08:30.780 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11606.728760, idle connection 187879.000000, request 304396.212816
10/23/2025 02:08:30.780 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10401.507568, idle connection 188373.000000, request 304999.356985
10/23/2025 02:08:30.781 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 787
10/23/2025 02:08:30.781 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.781 7f9d6b650680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 787 (604.4754981994629 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2014790684, topics=[])
10/23/2025 02:08:30.781 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2014790684 with 0 response partitions (1 implied)
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 352
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47cdf0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1251811946, session_epoch=775, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 779 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1251811946, session_epoch=775, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11191.004883, idle connection 187961.000000, request 304999.961853
10/23/2025 02:08:30.785 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11190.697754, idle connection 187961.000000, request 304999.657393
10/23/2025 02:08:30.811 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3832
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46a160> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=208911105, session_epoch=1091, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 1095 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=208911105, session_epoch=1091, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9225.468506, idle connection 187779.000000, request 304999.948740
10/23/2025 02:08:30.812 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9225.047852, idle connection 187778.000000, request 304999.534369
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46aca0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=506759906, session_epoch=738, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 742 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=506759906, session_epoch=738, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.819 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10249.000000, idle connection 187590.000000, request 304999.958515
10/23/2025 02:08:30.819 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9956.433838, idle connection 188493.000000, request 304397.461176
10/23/2025 02:08:30.820 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10248.508789, idle connection 187589.000000, request 304999.469757
10/23/2025 02:08:30.820 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 748
10/23/2025 02:08:30.820 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.820 7f9d6c1417c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 748 (603.1782627105713 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2132864108, topics=[])
10/23/2025 02:08:30.820 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2132864108 with 0 response partitions (1 implied)
10/23/2025 02:08:30.822 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
10/23/2025 02:08:30.822 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
10/23/2025 02:08:30.822 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46abe0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
10/23/2025 02:08:30.822 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.822 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029254678, session_epoch=738, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.823 7f9d6c141040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 742 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029254678, session_epoch=738, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.823 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10247.401367, idle connection 187587.000000, request 304999.959230
10/23/2025 02:08:30.823 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10247.065674, idle connection 187586.000000, request 304999.626875
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 190
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a65c1c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776426665, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776426665, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.837 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10346.335938, idle connection 187513.000000, request 304999.955416
10/23/2025 02:08:30.838 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10345.991211, idle connection 187513.000000, request 304999.615669
10/23/2025 02:08:30.875 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11203.566650, idle connection 188333.000000, request 304398.864985
10/23/2025 02:08:30.875 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 783
10/23/2025 02:08:30.875 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:30.876 7f9d6b650c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 783 (601.7005443572998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459735899, topics=[])
10/23/2025 02:08:30.876 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1459735899 with 0 response partitions (1 implied)
10/23/2025 02:08:30.981 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 49
10/23/2025 02:08:30.981 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
10/23/2025 02:08:30.981 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4d4280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
10/23/2025 02:08:30.981 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.981 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123674361, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.981 7f9d6c141ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123674361, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.982 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10169.858398, idle connection 187520.000000, request 304999.945402
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 46
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46a8b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=693831948, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=693831948, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.982 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10273.973877, idle connection 188634.000000, request 304999.963760
10/23/2025 02:08:30.983 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10168.739746, idle connection 187519.000000, request 304998.835564
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 23
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5a4070> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1592531477, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 750 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1592531477, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:30.983 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10392.947754, idle connection 187750.000000, request 304999.963522
10/23/2025 02:08:30.984 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10272.655762, idle connection 188633.000000, request 304998.649359
10/23/2025 02:08:30.984 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10392.322266, idle connection 187750.000000, request 304999.340773
10/23/2025 02:08:31.043 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 381
10/23/2025 02:08:31.043 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/23/2025 02:08:31.043 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a81bac0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
10/23/2025 02:08:31.043 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.043 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=803, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.044 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 807 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=803, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.044 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9843.275391, idle connection 187792.000000, request 304999.930143
10/23/2025 02:08:31.044 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9842.831787, idle connection 187791.000000, request 304999.499798
10/23/2025 02:08:31.046 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9630.817627, idle connection 187281.000000, request 304398.301601
10/23/2025 02:08:31.047 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 747
10/23/2025 02:08:31.047 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.047 7f9d6c141220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 747 (602.0979881286621 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1766330240, topics=[])
10/23/2025 02:08:31.047 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1766330240 with 0 response partitions (1 implied)
10/23/2025 02:08:31.047 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11044.459473, idle connection 188404.000000, request 304398.234367
10/23/2025 02:08:31.047 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 759
10/23/2025 02:08:31.047 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.047 7f9d6c141b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 759 (602.0553112030029 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=847983267, topics=[])
10/23/2025 02:08:31.047 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 847983267 with 0 response partitions (1 implied)
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 43
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46d340> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1992472767, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1992472767, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.106 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10274.588135, idle connection 187652.000000, request 304999.927044
10/23/2025 02:08:31.106 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 31
10/23/2025 02:08:31.107 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
10/23/2025 02:08:31.107 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4a9e80> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
10/23/2025 02:08:31.107 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.107 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=198852300, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.107 7f9d6b1622c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=198852300, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.107 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9571.488525, idle connection 188102.000000, request 304999.961138
10/23/2025 02:08:31.107 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 26
10/23/2025 02:08:31.107 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
10/23/2025 02:08:31.107 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5976d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
10/23/2025 02:08:31.107 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.107 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277230090, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.108 7f9d6c141360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277230090, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.108 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10006.157227, idle connection 187370.000000, request 304999.965668
10/23/2025 02:08:31.108 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10272.799805, idle connection 187651.000000, request 304998.150110
10/23/2025 02:08:31.108 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10872.124756, idle connection 187996.000000, request 304398.595572
10/23/2025 02:08:31.109 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9570.001221, idle connection 188100.000000, request 304998.478889
10/23/2025 02:08:31.109 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10004.994385, idle connection 187369.000000, request 304998.806238
10/23/2025 02:08:31.109 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 750
10/23/2025 02:08:31.109 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.109 7f9d6c141cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 750 (602.4367809295654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=406878178, topics=[])
10/23/2025 02:08:31.110 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 406878178 with 0 response partitions (1 implied)
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 139
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4f2d90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416108689, session_epoch=769, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 773 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416108689, session_epoch=769, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.116 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9559.104004, idle connection 187421.000000, request 304999.960423
10/23/2025 02:08:31.117 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9558.786621, idle connection 187421.000000, request 304999.645948
10/23/2025 02:08:31.206 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 18
10/23/2025 02:08:31.206 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
10/23/2025 02:08:31.206 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4a9130> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
10/23/2025 02:08:31.206 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.206 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=465380140, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.206 7f9d6b0c6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 749 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=465380140, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.207 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9174.913086, idle connection 187724.000000, request 304999.940872
10/23/2025 02:08:31.207 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9678.658447, idle connection 187367.000000, request 304396.991730
10/23/2025 02:08:31.207 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9174.248779, idle connection 187723.000000, request 304999.289274
10/23/2025 02:08:31.207 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 747
10/23/2025 02:08:31.207 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.208 7f9d6b134400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 747 (603.7311553955078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=734312328, topics=[])
10/23/2025 02:08:31.208 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 734312328 with 0 response partitions (1 implied)
10/23/2025 02:08:31.214 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 214
10/23/2025 02:08:31.214 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/23/2025 02:08:31.214 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a47c070> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/23/2025 02:08:31.214 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.214 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=619652300, session_epoch=782, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.214 7f9d6b650a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 786 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=619652300, session_epoch=782, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.215 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10572.947266, idle connection 187953.000000, request 304999.955416
10/23/2025 02:08:31.215 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10572.541992, idle connection 187952.000000, request 304999.555588
10/23/2025 02:08:31.246 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 277
10/23/2025 02:08:31.246 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
10/23/2025 02:08:31.246 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46da30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
10/23/2025 02:08:31.246 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.246 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=960564100, session_epoch=806, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.246 7f9d6b6509a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 810 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=960564100, session_epoch=806, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.247 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10340.060791, idle connection 187731.000000, request 304999.839783
10/23/2025 02:08:31.247 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10339.365723, idle connection 187731.000000, request 304999.260426
10/23/2025 02:08:31.277 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9500.590820, idle connection 187345.000000, request 304397.201777
10/23/2025 02:08:31.278 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 784
10/23/2025 02:08:31.278 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.278 7f9d6b650540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 784 (603.3449172973633 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=57599649, topics=[])
10/23/2025 02:08:31.278 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 57599649 with 0 response partitions (1 implied)
10/23/2025 02:08:31.278 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10054.365479, idle connection 187198.000000, request 304397.060633
10/23/2025 02:08:31.278 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10096.297852, idle connection 187929.000000, request 304397.991896
10/23/2025 02:08:31.279 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753
10/23/2025 02:08:31.279 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.279 7f9d6b0c6860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 753 (603.4343242645264 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=844134647, topics=[])
10/23/2025 02:08:31.279 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 844134647 with 0 response partitions (1 implied)
10/23/2025 02:08:31.279 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 764
10/23/2025 02:08:31.279 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.279 7f9d6b6502c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 764 (602.8144359588623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1126391604, topics=[])
10/23/2025 02:08:31.279 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1126391604 with 0 response partitions (1 implied)
10/23/2025 02:08:31.321 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9758.285889, idle connection 187117.000000, request 304397.740841
10/23/2025 02:08:31.321 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 748
10/23/2025 02:08:31.321 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.321 7f9d6b1bcea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 748 (602.7977466583252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1484190749, topics=[])
10/23/2025 02:08:31.321 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1484190749 with 0 response partitions (1 implied)
10/23/2025 02:08:31.321 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10267.388916, idle connection 187691.000000, request 304397.641420
10/23/2025 02:08:31.322 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 750
10/23/2025 02:08:31.322 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.322 7f9d6b0e7400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 750 (602.7302742004395 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277879316, topics=[])
10/23/2025 02:08:31.322 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277879316 with 0 response partitions (1 implied)
10/23/2025 02:08:31.346 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10913.984863, idle connection 187765.000000, request 304398.967505
10/23/2025 02:08:31.347 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 766
10/23/2025 02:08:31.347 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.347 7f9d6b19f360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 766 (601.7429828643799 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1707088916, topics=[])
10/23/2025 02:08:31.347 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1707088916 with 0 response partitions (1 implied)
10/23/2025 02:08:31.381 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 185
10/23/2025 02:08:31.381 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
10/23/2025 02:08:31.382 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479df0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
10/23/2025 02:08:31.382 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.382 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014790684, session_epoch=784, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.382 7f9d6b650680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 788 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014790684, session_epoch=784, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.382 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11004.812012, idle connection 187277.000000, request 304999.938965
10/23/2025 02:08:31.382 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9799.627197, idle connection 187771.000000, request 304397.474527
10/23/2025 02:08:31.383 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 11004.181885, idle connection 187276.000000, request 304999.319792
10/23/2025 02:08:31.383 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 798
10/23/2025 02:08:31.383 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.383 7f9d6b6507c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 798 (603.2307147979736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=368197022, topics=[])
10/23/2025 02:08:31.383 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 368197022 with 0 response partitions (1 implied)
10/23/2025 02:08:31.386 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10590.375488, idle connection 187360.000000, request 304399.331093
10/23/2025 02:08:31.386 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 779
10/23/2025 02:08:31.386 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.386 7f9d6b650400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 779 (601.0463237762451 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1251811946, topics=[])
10/23/2025 02:08:31.386 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1251811946 with 0 response partitions (1 implied)
10/23/2025 02:08:31.413 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8624.526123, idle connection 187178.000000, request 304399.001122
10/23/2025 02:08:31.413 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1095
10/23/2025 02:08:31.413 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.414 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 1095 (601.5517711639404 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=208911105, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3833, last_stable_offset=3833, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xf8\x00\x00\x01\x05\x00\x00\x00\x00\x02\x83P\x99\xad\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...')])])
10/23/2025 02:08:31.414 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 208911105 with 1 response partitions (0 implied)
10/23/2025 02:08:31.414 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3832
10/23/2025 02:08:31.414 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3832 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
10/23/2025 02:08:31.414 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3833 (leader epoch 0)
10/23/2025 02:08:31.420 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
10/23/2025 02:08:31.421 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
10/23/2025 02:08:31.421 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46a430> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
10/23/2025 02:08:31.421 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.421 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2132864108, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.421 7f9d6c1417c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 749 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2132864108, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.421 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9354.754150, idle connection 187891.000000, request 304999.952555
10/23/2025 02:08:31.421 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9646.885254, idle connection 186988.000000, request 304397.844791
10/23/2025 02:08:31.422 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9354.197266, idle connection 187891.000000, request 304999.403238
10/23/2025 02:08:31.422 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742
10/23/2025 02:08:31.422 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.422 7f9d6d3eec20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 742 (602.8225421905518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=506759906, topics=[])
10/23/2025 02:08:31.422 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 506759906 with 0 response partitions (1 implied)
10/23/2025 02:08:31.423 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9646.738525, idle connection 186986.000000, request 304399.298668
10/23/2025 02:08:31.424 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742
10/23/2025 02:08:31.424 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.424 7f9d6c141040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 742 (601.0837554931641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1029254678, topics=[])
10/23/2025 02:08:31.424 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1029254678 with 0 response partitions (1 implied)
10/23/2025 02:08:31.438 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9745.577393, idle connection 186912.000000, request 304399.194002
10/23/2025 02:08:31.438 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 785
10/23/2025 02:08:31.438 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.438 7f9d6d3eef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 785 (601.250410079956 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=776426665, topics=[])
10/23/2025 02:08:31.439 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 776426665 with 0 response partitions (1 implied)
10/23/2025 02:08:31.477 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 174
10/23/2025 02:08:31.477 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
10/23/2025 02:08:31.478 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a54b520> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
10/23/2025 02:08:31.478 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.478 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459735899, session_epoch=780, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.478 7f9d6b650c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 784 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459735899, session_epoch=780, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.478 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10600.489502, idle connection 187730.000000, request 304999.939919
10/23/2025 02:08:31.479 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10599.776367, idle connection 187729.000000, request 304999.236584
10/23/2025 02:08:31.515 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3833
10/23/2025 02:08:31.515 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
10/23/2025 02:08:31.515 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4794f0> 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)])
10/23/2025 02:08:31.515 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.515 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=208911105, session_epoch=1092, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3833, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:31.516 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 1096 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=208911105, session_epoch=1092, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3833, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:31.516 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8521.730713, idle connection 187075.000000, request 304999.942303
10/23/2025 02:08:31.516 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8521.280029, idle connection 187074.000000, request 304999.502659
10/23/2025 02:08:31.584 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9567.332031, idle connection 186918.000000, request 304397.411585
10/23/2025 02:08:31.584 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753
10/23/2025 02:08:31.585 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.585 7f9d6c141ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 753 (603.1832695007324 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=123674361, topics=[])
10/23/2025 02:08:31.585 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 123674361 with 0 response partitions (1 implied)
10/23/2025 02:08:31.585 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9671.199951, idle connection 188031.000000, request 304397.187471
10/23/2025 02:08:31.585 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9791.018555, idle connection 187148.000000, request 304398.030758
10/23/2025 02:08:31.585 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753
10/23/2025 02:08:31.585 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.586 7f9d6c141860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 753 (603.3186912536621 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=693831948, topics=[])
10/23/2025 02:08:31.586 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 693831948 with 0 response partitions (1 implied)
10/23/2025 02:08:31.586 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 750
10/23/2025 02:08:31.586 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.586 7f9d6c141540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 750 (602.8313636779785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1592531477, topics=[])
10/23/2025 02:08:31.586 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1592531477 with 0 response partitions (1 implied)
10/23/2025 02:08:31.645 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9242.283936, idle connection 187191.000000, request 304398.941278
10/23/2025 02:08:31.645 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 807
10/23/2025 02:08:31.645 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.645 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 807 (601.7601490020752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1767298541, topics=[])
10/23/2025 02:08:31.646 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1767298541 with 0 response partitions (1 implied)
10/23/2025 02:08:31.647 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 12
10/23/2025 02:08:31.647 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
10/23/2025 02:08:31.647 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46afd0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
10/23/2025 02:08:31.647 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.647 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1766330240, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.648 7f9d6c141220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 748 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1766330240, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.648 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9029.313477, idle connection 186679.000000, request 304999.949932
10/23/2025 02:08:31.648 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 91
10/23/2025 02:08:31.648 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
10/23/2025 02:08:31.648 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46af40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
10/23/2025 02:08:31.648 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.648 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=847983267, session_epoch=756, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.648 7f9d6c141b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 760 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=847983267, session_epoch=756, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.649 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10442.922852, idle connection 187802.000000, request 304999.948025
10/23/2025 02:08:31.649 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9028.121582, idle connection 186678.000000, request 304998.764277
10/23/2025 02:08:31.649 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10442.195801, idle connection 187801.000000, request 304999.222994
10/23/2025 02:08:31.709 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9671.582520, idle connection 187049.000000, request 304396.922112
10/23/2025 02:08:31.710 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 752
10/23/2025 02:08:31.710 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.710 7f9d6b1bc4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 752 (603.7614345550537 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1992472767, topics=[])
10/23/2025 02:08:31.710 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1992472767 with 0 response partitions (1 implied)
10/23/2025 02:08:31.710 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 33
10/23/2025 02:08:31.711 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
10/23/2025 02:08:31.711 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4b6100> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
10/23/2025 02:08:31.711 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.711 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406878178, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.711 7f9d6c141cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406878178, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.711 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10269.387695, idle connection 187394.000000, request 304999.956608
10/23/2025 02:08:31.711 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8967.346191, idle connection 187498.000000, request 304395.821571
10/23/2025 02:08:31.711 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9402.531006, idle connection 186766.000000, request 304396.342516
10/23/2025 02:08:31.711 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 752
10/23/2025 02:08:31.712 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.712 7f9d6b1622c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 752 (604.6297550201416 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=198852300, topics=[])
10/23/2025 02:08:31.712 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 198852300 with 0 response partitions (1 implied)
10/23/2025 02:08:31.712 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 752
10/23/2025 02:08:31.712 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.712 7f9d6c141360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 752 (604.4342517852783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277230090, topics=[])
10/23/2025 02:08:31.712 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277230090 with 0 response partitions (1 implied)
10/23/2025 02:08:31.713 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10267.821777, idle connection 187392.000000, request 304998.394966
10/23/2025 02:08:31.717 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8958.448975, idle connection 186821.000000, request 304399.307013
10/23/2025 02:08:31.717 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 773
10/23/2025 02:08:31.717 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.717 7f9d6b650180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 773 (601.146936416626 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416108689, topics=[])
10/23/2025 02:08:31.718 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416108689 with 0 response partitions (1 implied)
10/23/2025 02:08:31.808 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15
10/23/2025 02:08:31.808 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
10/23/2025 02:08:31.808 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46dd60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
10/23/2025 02:08:31.809 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.809 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=734312328, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.809 7f9d6b134400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 748 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=734312328, session_epoch=744, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.809 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9076.530762, idle connection 186765.000000, request 304999.946594
10/23/2025 02:08:31.809 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8572.214111, idle connection 187121.000000, request 304397.251844
10/23/2025 02:08:31.810 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9075.863281, idle connection 186764.000000, request 304999.289989
10/23/2025 02:08:31.810 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 749
10/23/2025 02:08:31.810 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.810 7f9d6b0c6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 749 (603.5361289978027 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=465380140, topics=[])
10/23/2025 02:08:31.810 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 465380140 with 0 response partitions (1 implied)
10/23/2025 02:08:31.815 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9972.180176, idle connection 187352.000000, request 304399.191618
10/23/2025 02:08:31.816 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 786
10/23/2025 02:08:31.816 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.816 7f9d6b650a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 786 (601.1815071105957 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=619652300, topics=[])
10/23/2025 02:08:31.816 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 619652300 with 0 response partitions (1 implied)
10/23/2025 02:08:31.848 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9738.866211, idle connection 187130.000000, request 304398.755312
10/23/2025 02:08:31.848 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810
10/23/2025 02:08:31.848 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.848 7f9d6b6509a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 810 (601.7789840698242 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=960564100, topics=[])
10/23/2025 02:08:31.848 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 960564100 with 0 response partitions (1 implied)
10/23/2025 02:08:31.878 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 234
10/23/2025 02:08:31.879 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
10/23/2025 02:08:31.879 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46d0a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
10/23/2025 02:08:31.879 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.879 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=57599649, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.879 7f9d6b650540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=57599649, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.879 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8898.748047, idle connection 186744.000000, request 304999.943733
10/23/2025 02:08:31.879 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 32
10/23/2025 02:08:31.879 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
10/23/2025 02:08:31.880 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479100> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
10/23/2025 02:08:31.880 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.880 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=844134647, session_epoch=750, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.880 7f9d6b0c6860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 754 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=844134647, session_epoch=750, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.880 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9452.604004, idle connection 186597.000000, request 304999.962091
10/23/2025 02:08:31.880 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8897.504150, idle connection 186742.000000, request 304998.710394
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 130
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a597b20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126391604, session_epoch=761, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 765 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126391604, session_epoch=761, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.881 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9493.427734, idle connection 187326.000000, request 304999.963284
10/23/2025 02:08:31.882 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9451.045410, idle connection 186595.000000, request 304998.407125
10/23/2025 02:08:31.882 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9492.775879, idle connection 187326.000000, request 304999.314785
10/23/2025 02:08:31.922 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 27
10/23/2025 02:08:31.923 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
10/23/2025 02:08:31.923 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a57d6a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
10/23/2025 02:08:31.923 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.923 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1484190749, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.923 7f9d6b1bcea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 749 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1484190749, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.923 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9155.433594, idle connection 186514.000000, request 304999.938965
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 36
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46d8b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277879316, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277879316, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.924 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9664.654541, idle connection 187089.000000, request 304999.957323
10/23/2025 02:08:31.925 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9154.270752, idle connection 186513.000000, request 304998.787165
10/23/2025 02:08:31.925 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9663.973389, idle connection 187088.000000, request 304999.281645
10/23/2025 02:08:31.948 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 100
10/23/2025 02:08:31.948 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
10/23/2025 02:08:31.948 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46a1c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
10/23/2025 02:08:31.948 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.949 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1707088916, session_epoch=763, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.949 7f9d6b19f360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 767 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1707088916, session_epoch=763, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.949 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10311.578369, idle connection 187163.000000, request 304999.946833
10/23/2025 02:08:31.949 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10311.063477, idle connection 187162.000000, request 304999.439716
10/23/2025 02:08:31.983 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 267
10/23/2025 02:08:31.984 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
10/23/2025 02:08:31.984 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5cc280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
10/23/2025 02:08:31.984 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.984 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368197022, session_epoch=795, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.984 7f9d6b6507c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 799 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368197022, session_epoch=795, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.984 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9197.774414, idle connection 187170.000000, request 304999.942780
10/23/2025 02:08:31.984 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 10402.405762, idle connection 186674.000000, request 304397.541761
10/23/2025 02:08:31.985 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9197.153076, idle connection 187169.000000, request 304999.330521
10/23/2025 02:08:31.985 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 788
10/23/2025 02:08:31.985 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:31.985 7f9d6b650680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 788 (603.1820774078369 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2014790684, topics=[])
10/23/2025 02:08:31.985 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2014790684 with 0 response partitions (1 implied)
10/23/2025 02:08:31.986 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 352
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5cc6d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1251811946, session_epoch=776, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 780 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1251811946, session_epoch=776, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9989.049072, idle connection 186759.000000, request 304999.958992
10/23/2025 02:08:31.987 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9988.733154, idle connection 186759.000000, request 304999.645948
10/23/2025 02:08:32.022 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
10/23/2025 02:08:32.023 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
10/23/2025 02:08:32.023 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a560b20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
10/23/2025 02:08:32.023 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.023 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=506759906, session_epoch=739, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.023 7f9d6d3eec20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 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=506759906, session_epoch=739, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.023 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9044.750000, idle connection 186385.000000, request 304999.938011
10/23/2025 02:08:32.024 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8752.080811, idle connection 187289.000000, request 304397.284269
10/23/2025 02:08:32.024 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9044.087402, idle connection 186385.000000, request 304999.288082
10/23/2025 02:08:32.024 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 749
10/23/2025 02:08:32.024 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.024 7f9d6c1417c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 749 (603.4629344940186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2132864108, topics=[])
10/23/2025 02:08:32.025 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2132864108 with 0 response partitions (1 implied)
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5879d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029254678, session_epoch=739, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 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=1029254678, session_epoch=739, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.025 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9044.706299, idle connection 186384.000000, request 304999.961376
10/23/2025 02:08:32.026 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9044.218750, idle connection 186384.000000, request 304999.477625
10/23/2025 02:08:32.039 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 190
10/23/2025 02:08:32.039 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
10/23/2025 02:08:32.039 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a460910> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
10/23/2025 02:08:32.039 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.039 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776426665, session_epoch=782, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.040 7f9d6d3eef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 786 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776426665, session_epoch=782, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.040 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9143.764160, idle connection 186311.000000, request 304999.934196
10/23/2025 02:08:32.040 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9143.330811, idle connection 186310.000000, request 304999.509335
10/23/2025 02:08:32.079 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9999.264648, idle connection 187129.000000, request 304398.714066
10/23/2025 02:08:32.080 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 784
10/23/2025 02:08:32.080 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.080 7f9d6b650c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 784 (601.839542388916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459735899, topics=[])
10/23/2025 02:08:32.080 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1459735899 with 0 response partitions (1 implied)
10/23/2025 02:08:32.117 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7920.722412, idle connection 186474.000000, request 304398.934364
10/23/2025 02:08:32.117 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1096
10/23/2025 02:08:32.117 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.117 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 1096 (601.6159057617188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=208911105, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3834, last_stable_offset=3834, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xf9\x00\x00\x01\x05\x00\x00\x00\x00\x02\x08\x0b\xacd\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...')])])
10/23/2025 02:08:32.118 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 208911105 with 1 response partitions (0 implied)
10/23/2025 02:08:32.118 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3833
10/23/2025 02:08:32.118 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3833 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
10/23/2025 02:08:32.118 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3834 (leader epoch 0)
10/23/2025 02:08:32.185 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 49
10/23/2025 02:08:32.185 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
10/23/2025 02:08:32.186 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4ea2b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
10/23/2025 02:08:32.186 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.186 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123674361, session_epoch=750, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.186 7f9d6c141ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 754 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123674361, session_epoch=750, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.186 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8965.408936, idle connection 186316.000000, request 304999.942541
10/23/2025 02:08:32.186 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 46
10/23/2025 02:08:32.186 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
10/23/2025 02:08:32.186 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4795b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
10/23/2025 02:08:32.186 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.186 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=693831948, session_epoch=750, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.187 7f9d6c141860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 754 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=693831948, session_epoch=750, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.187 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9069.552734, idle connection 187430.000000, request 304999.963045
10/23/2025 02:08:32.187 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8964.285645, idle connection 186315.000000, request 304998.831034
10/23/2025 02:08:32.187 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 23
10/23/2025 02:08:32.187 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
10/23/2025 02:08:32.187 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46d880> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
10/23/2025 02:08:32.187 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.188 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1592531477, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.188 7f9d6c141540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1592531477, session_epoch=747, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.188 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9188.488770, idle connection 186546.000000, request 304999.964952
10/23/2025 02:08:32.188 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9068.201172, idle connection 187428.000000, request 304998.615503
10/23/2025 02:08:32.188 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9187.879150, idle connection 186545.000000, request 304999.357939
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3834
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a54b520> 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)])
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=208911105, session_epoch=1093, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3834, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 1097 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=208911105, session_epoch=1093, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3834, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:32.219 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7818.157959, idle connection 186371.000000, request 304999.948025
10/23/2025 02:08:32.220 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7817.725586, idle connection 186371.000000, request 304999.522686
10/23/2025 02:08:32.246 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 381
10/23/2025 02:08:32.246 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/23/2025 02:08:32.246 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4794c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
10/23/2025 02:08:32.247 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.247 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=804, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.247 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 808 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=804, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.247 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8640.051025, idle connection 186589.000000, request 304999.944687
10/23/2025 02:08:32.247 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8639.583008, idle connection 186588.000000, request 304999.484777
10/23/2025 02:08:32.250 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8427.470215, idle connection 186078.000000, request 304398.111105
10/23/2025 02:08:32.250 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 748
10/23/2025 02:08:32.250 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.250 7f9d6c141220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 748 (602.3013591766357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1766330240, topics=[])
10/23/2025 02:08:32.250 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1766330240 with 0 response partitions (1 implied)
10/23/2025 02:08:32.250 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9841.029297, idle connection 187200.000000, request 304398.056269
10/23/2025 02:08:32.251 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 760
10/23/2025 02:08:32.251 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.251 7f9d6c141b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 760 (602.299690246582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=847983267, topics=[])
10/23/2025 02:08:32.251 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 847983267 with 0 response partitions (1 implied)
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 43
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479f10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1992472767, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1992472767, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.311 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9069.524658, idle connection 186447.000000, request 304999.945402
10/23/2025 02:08:32.312 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9069.082764, idle connection 186447.000000, request 304999.512911
10/23/2025 02:08:32.312 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 31
10/23/2025 02:08:32.312 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
10/23/2025 02:08:32.312 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a490310> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
10/23/2025 02:08:32.312 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.312 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=198852300, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.312 7f9d6b1622c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=198852300, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.313 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8366.003662, idle connection 186896.000000, request 304999.965668
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 26
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a583fa0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277230090, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277230090, session_epoch=749, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.313 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8800.708252, idle connection 186164.000000, request 304999.967813
10/23/2025 02:08:32.313 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8365.120117, idle connection 186895.000000, request 304999.083519
10/23/2025 02:08:32.314 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9666.769775, idle connection 186791.000000, request 304397.342443
10/23/2025 02:08:32.314 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8800.013184, idle connection 186164.000000, request 304999.274969
10/23/2025 02:08:32.314 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 751
10/23/2025 02:08:32.314 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.314 7f9d6c141cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 751 (603.313684463501 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=406878178, topics=[])
10/23/2025 02:08:32.314 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 406878178 with 0 response partitions (1 implied)
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 139
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4603a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416108689, session_epoch=770, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 774 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416108689, session_epoch=770, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.318 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8357.173340, idle connection 186219.000000, request 304999.965429
10/23/2025 02:08:32.319 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8356.851562, idle connection 186219.000000, request 304999.645948
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 18
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a5dc670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=465380140, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 750 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=465380140, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.411 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7970.143555, idle connection 186519.000000, request 304999.944925
10/23/2025 02:08:32.412 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8473.927979, idle connection 186162.000000, request 304397.352934
10/23/2025 02:08:32.412 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7969.517090, idle connection 186518.000000, request 304999.326706
10/23/2025 02:08:32.412 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 748
10/23/2025 02:08:32.412 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.412 7f9d6b134400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 748 (603.377103805542 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=734312328, topics=[])
10/23/2025 02:08:32.412 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 734312328 with 0 response partitions (1 implied)
10/23/2025 02:08:32.416 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 214
10/23/2025 02:08:32.416 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/23/2025 02:08:32.416 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4a9130> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/23/2025 02:08:32.416 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.416 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=619652300, session_epoch=783, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.416 7f9d6b650a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 787 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=619652300, session_epoch=783, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.417 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9370.848633, idle connection 186751.000000, request 304999.948740
10/23/2025 02:08:32.417 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9370.510254, idle connection 186750.000000, request 304999.614000
10/23/2025 02:08:32.449 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 277
10/23/2025 02:08:32.449 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
10/23/2025 02:08:32.449 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479340> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
10/23/2025 02:08:32.450 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.450 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=960564100, session_epoch=807, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.450 7f9d6b6509a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 811 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=960564100, session_epoch=807, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.450 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9136.658691, idle connection 186528.000000, request 304999.944925
10/23/2025 02:08:32.450 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9136.223389, idle connection 186528.000000, request 304999.517441
10/23/2025 02:08:32.482 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8295.863037, idle connection 186141.000000, request 304397.061586
10/23/2025 02:08:32.482 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 785
10/23/2025 02:08:32.482 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.483 7f9d6b650540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 785 (603.4848690032959 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=57599649, topics=[])
10/23/2025 02:08:32.483 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 57599649 with 0 response partitions (1 implied)
10/23/2025 02:08:32.483 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8849.619141, idle connection 185994.000000, request 304396.978378
10/23/2025 02:08:32.483 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8891.577393, idle connection 186724.000000, request 304398.116112
10/23/2025 02:08:32.483 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 754
10/23/2025 02:08:32.483 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.483 7f9d6b0c6860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 754 (603.4355163574219 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=844134647, topics=[])
10/23/2025 02:08:32.483 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 844134647 with 0 response partitions (1 implied)
10/23/2025 02:08:32.484 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 765
10/23/2025 02:08:32.484 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.484 7f9d6b6502c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 765 (602.6327610015869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1126391604, topics=[])
10/23/2025 02:08:32.484 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1126391604 with 0 response partitions (1 implied)
10/23/2025 02:08:32.526 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8552.931885, idle connection 185912.000000, request 304397.437096
10/23/2025 02:08:32.526 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 749
10/23/2025 02:08:32.526 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.526 7f9d6b1bcea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 749 (603.1196117401123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1484190749, topics=[])
10/23/2025 02:08:32.527 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1484190749 with 0 response partitions (1 implied)
10/23/2025 02:08:32.527 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9061.987549, idle connection 186486.000000, request 304397.293329
10/23/2025 02:08:32.527 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 751
10/23/2025 02:08:32.527 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.527 7f9d6b0e7400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 751 (602.9930114746094 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277879316, topics=[])
10/23/2025 02:08:32.527 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277879316 with 0 response partitions (1 implied)
10/23/2025 02:08:32.550 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9710.528320, idle connection 186562.000000, request 304398.896456
10/23/2025 02:08:32.550 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 767
10/23/2025 02:08:32.550 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.550 7f9d6b19f360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 767 (601.7236709594727 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1707088916, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=101, last_stable_offset=101, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00d\x00\x00\x01\x18\x00\x00\x00\x00\x02\x0bt\xe1f\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\xca\x03\x00\x00\x00\x8c\x03ObjectVMITable:default-global-sy...')])])
10/23/2025 02:08:32.551 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1707088916 with 1 response partitions (0 implied)
10/23/2025 02:08:32.551 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 292 bytes of data for partition TopicPartition(topic='-uve-topic-13', partition=0) with offset 100
10/23/2025 02:08:32.551 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 100 for assigned partition TopicPartition(topic='-uve-topic-13', partition=0)
10/23/2025 02:08:32.551 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-13', partition=0) to 101 (leader epoch 0)
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 185
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a552d60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014790684, session_epoch=785, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 789 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014790684, session_epoch=785, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.586 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9800.412109, idle connection 186072.000000, request 304999.940634
10/23/2025 02:08:32.587 7f9d6b6507c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8595.221436, idle connection 186567.000000, request 304397.396326
10/23/2025 02:08:32.587 7f9d6b650680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9799.753906, idle connection 186072.000000, request 304999.293089
10/23/2025 02:08:32.587 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 799
10/23/2025 02:08:32.587 7f9d6b6507c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.587 7f9d6b6507c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 799 (603.3318042755127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=368197022, topics=[])
10/23/2025 02:08:32.588 7f9d6b6507c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 368197022 with 0 response partitions (1 implied)
10/23/2025 02:08:32.588 7f9d6b650400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9388.336426, idle connection 186158.000000, request 304399.246931
10/23/2025 02:08:32.588 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 780
10/23/2025 02:08:32.588 7f9d6b650400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.588 7f9d6b650400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 780 (601.11403465271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1251811946, topics=[])
10/23/2025 02:08:32.588 7f9d6b650400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1251811946 with 0 response partitions (1 implied)
10/23/2025 02:08:32.625 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
10/23/2025 02:08:32.626 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
10/23/2025 02:08:32.626 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46abb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
10/23/2025 02:08:32.626 7f9d6c1417c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.626 7f9d6c1417c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2132864108, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.626 7f9d6c1417c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 750 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2132864108, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.626 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8149.622559, idle connection 186686.000000, request 304999.943256
10/23/2025 02:08:32.626 7f9d6d3eec20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8441.685791, idle connection 185782.000000, request 304396.883488
10/23/2025 02:08:32.627 7f9d6c141040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8443.460693, idle connection 185783.000000, request 304398.718357
10/23/2025 02:08:32.627 7f9d6c1417c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8148.820557, idle connection 186685.000000, request 304999.151707
10/23/2025 02:08:32.627 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743
10/23/2025 02:08:32.627 7f9d6d3eec20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.627 7f9d6d3eec20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 743 (604.050874710083 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=506759906, topics=[])
10/23/2025 02:08:32.628 7f9d6d3eec20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 506759906 with 0 response partitions (1 implied)
10/23/2025 02:08:32.628 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743
10/23/2025 02:08:32.628 7f9d6c141040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.628 7f9d6c141040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 743 (602.5772094726562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1029254678, topics=[])
10/23/2025 02:08:32.628 7f9d6c141040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1029254678 with 0 response partitions (1 implied)
10/23/2025 02:08:32.641 7f9d6d3eef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8542.667480, idle connection 185710.000000, request 304398.833990
10/23/2025 02:08:32.641 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 786
10/23/2025 02:08:32.641 7f9d6d3eef40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.641 7f9d6d3eef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 786 (601.7086505889893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=776426665, topics=[])
10/23/2025 02:08:32.642 7f9d6d3eef40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 776426665 with 0 response partitions (1 implied)
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 101
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a57d6a0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-13', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1707088916, session_epoch=764, topics=[(topic='-uve-topic-13', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=101, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 768 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1707088916, session_epoch=764, topics=[(topic='-uve-topic-13', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=101, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:32.652 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9607.991943, idle connection 186459.000000, request 304999.948263
10/23/2025 02:08:32.653 7f9d6b19f360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9607.531738, idle connection 186459.000000, request 304999.496937
10/23/2025 02:08:32.680 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 174
10/23/2025 02:08:32.681 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
10/23/2025 02:08:32.681 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479940> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
10/23/2025 02:08:32.681 7f9d6b650c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.681 7f9d6b650c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459735899, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.681 7f9d6b650c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459735899, session_epoch=781, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.681 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9397.348145, idle connection 186527.000000, request 304999.941826
10/23/2025 02:08:32.682 7f9d6b650c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9396.870850, idle connection 186527.000000, request 304999.474049
10/23/2025 02:08:32.789 7f9d6c141ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8362.829102, idle connection 185713.000000, request 304397.362709
10/23/2025 02:08:32.789 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 754
10/23/2025 02:08:32.789 7f9d6c141ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.789 7f9d6c141ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 754 (603.295087814331 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=123674361, topics=[])
10/23/2025 02:08:32.789 7f9d6c141ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 123674361 with 0 response partitions (1 implied)
10/23/2025 02:08:32.790 7f9d6c141860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8466.591797, idle connection 186827.000000, request 304397.002459
10/23/2025 02:08:32.790 7f9d6c141540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8586.457764, idle connection 185944.000000, request 304397.935390
10/23/2025 02:08:32.790 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 754
10/23/2025 02:08:32.790 7f9d6c141860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.790 7f9d6c141860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 754 (603.4946441650391 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=693831948, topics=[])
10/23/2025 02:08:32.790 7f9d6c141860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 693831948 with 0 response partitions (1 implied)
10/23/2025 02:08:32.791 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 751
10/23/2025 02:08:32.791 7f9d6c141540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.791 7f9d6c141540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 751 (602.9422283172607 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1592531477, topics=[])
10/23/2025 02:08:32.791 7f9d6c141540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1592531477 with 0 response partitions (1 implied)
10/23/2025 02:08:32.820 7f9d6d3eee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7217.283936, idle connection 185770.000000, request 304399.072409
10/23/2025 02:08:32.821 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1097
10/23/2025 02:08:32.821 7f9d6d3eee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.821 7f9d6d3eee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 1097 (601.520299911499 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=208911105, topics=[])
10/23/2025 02:08:32.821 7f9d6d3eee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 208911105 with 0 response partitions (1 implied)
10/23/2025 02:08:32.848 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8039.012939, idle connection 185987.000000, request 304398.874760
10/23/2025 02:08:32.848 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808
10/23/2025 02:08:32.849 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.849 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 808 (601.7119884490967 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1767298541, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=382, last_stable_offset=382, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01}\x00\x00\x00\xfd\x00\x00\x00\x00\x02\xa1\xb0\xb3\xe2\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\x94\x03\x00\x00\x00\xd6\x02ObjectVNTable:default-domain:def...')])])
10/23/2025 02:08:32.849 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1767298541 with 1 response partitions (0 implied)
10/23/2025 02:08:32.849 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 265 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 381
10/23/2025 02:08:32.849 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 381 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0)
10/23/2025 02:08:32.849 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 382 (leader epoch 0)
10/23/2025 02:08:32.850 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 12
10/23/2025 02:08:32.851 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
10/23/2025 02:08:32.851 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4b6460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
10/23/2025 02:08:32.851 7f9d6c141220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.851 7f9d6c141220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1766330240, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.851 7f9d6c141220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 749 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1766330240, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.851 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7826.041016, idle connection 185476.000000, request 304999.955416
10/23/2025 02:08:32.851 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 91
10/23/2025 02:08:32.851 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
10/23/2025 02:08:32.851 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46a370> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
10/23/2025 02:08:32.851 7f9d6c141b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.851 7f9d6c141b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=847983267, session_epoch=757, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.852 7f9d6c141b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 761 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=847983267, session_epoch=757, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.852 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9239.764893, idle connection 186599.000000, request 304999.965668
10/23/2025 02:08:32.852 7f9d6c141220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7825.031982, idle connection 185475.000000, request 304998.950720
10/23/2025 02:08:32.852 7f9d6c141b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9239.100098, idle connection 186598.000000, request 304999.303102
10/23/2025 02:08:32.913 7f9d6b1bc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8468.041748, idle connection 185846.000000, request 304398.461103
10/23/2025 02:08:32.913 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753
10/23/2025 02:08:32.913 7f9d6b1bc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.913 7f9d6b1bc4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 753 (602.0598411560059 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1992472767, topics=[])
10/23/2025 02:08:32.913 7f9d6b1bc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1992472767 with 0 response partitions (1 implied)
10/23/2025 02:08:32.914 7f9d6b1622c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7764.435791, idle connection 186295.000000, request 304398.396492
10/23/2025 02:08:32.914 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753
10/23/2025 02:08:32.914 7f9d6b1622c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.914 7f9d6b1622c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 753 (601.9527912139893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=198852300, topics=[])
10/23/2025 02:08:32.915 7f9d6b1622c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 198852300 with 0 response partitions (1 implied)
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 33
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4bc910> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406878178, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406878178, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:32.915 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9065.104004, idle connection 186189.000000, request 304999.960661
10/23/2025 02:08:32.915 7f9d6c141360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8198.388184, idle connection 185562.000000, request 304397.647858
10/23/2025 02:08:32.916 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753
10/23/2025 02:08:32.916 7f9d6c141360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.916 7f9d6c141360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 753 (602.686882019043 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277230090, topics=[])
10/23/2025 02:08:32.916 7f9d6c141360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277230090 with 0 response partitions (1 implied)
10/23/2025 02:08:32.916 7f9d6c141cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 9064.098633, idle connection 186188.000000, request 304998.957396
10/23/2025 02:08:32.919 7f9d6b650180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7756.538818, idle connection 185619.000000, request 304399.331808
10/23/2025 02:08:32.919 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 774
10/23/2025 02:08:32.919 7f9d6b650180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:32.919 7f9d6b650180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 774 (600.989818572998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416108689, topics=[])
10/23/2025 02:08:32.919 7f9d6b650180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416108689 with 0 response partitions (1 implied)
10/23/2025 02:08:32.950 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 382
10/23/2025 02:08:32.950 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/23/2025 02:08:32.950 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a546100> 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)])
10/23/2025 02:08:32.950 7f9d6b650040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:32.950 7f9d6b650040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=805, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=382, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:32.950 7f9d6b650040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1767298541, session_epoch=805, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=382, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/23/2025 02:08:32.951 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7936.386719, idle connection 185885.000000, request 304999.944925
10/23/2025 02:08:32.951 7f9d6b650040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7935.957275, idle connection 185884.000000, request 304999.523163
10/23/2025 02:08:33.013 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15
10/23/2025 02:08:33.013 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
10/23/2025 02:08:33.013 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a583850> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
10/23/2025 02:08:33.013 7f9d6b134400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:33.013 7f9d6b134400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=734312328, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.013 7f9d6b134400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 749 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=734312328, session_epoch=745, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.014 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7871.951660, idle connection 185560.000000, request 304999.947309
10/23/2025 02:08:33.014 7f9d6b0c6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7367.638916, idle connection 185916.000000, request 304397.446632
10/23/2025 02:08:33.014 7f9d6b134400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7871.067627, idle connection 185559.000000, request 304999.071360
10/23/2025 02:08:33.015 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 750
10/23/2025 02:08:33.015 7f9d6b0c6c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:33.015 7f9d6b0c6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 750 (603.6040782928467 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=465380140, topics=[])
10/23/2025 02:08:33.015 7f9d6b0c6c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 465380140 with 0 response partitions (1 implied)
10/23/2025 02:08:33.017 7f9d6b650a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8770.201416, idle connection 186150.000000, request 304399.303675
10/23/2025 02:08:33.017 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 787
10/23/2025 02:08:33.018 7f9d6b650a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:33.018 7f9d6b650a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 787 (601.0613441467285 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=619652300, topics=[])
10/23/2025 02:08:33.018 7f9d6b650a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 619652300 with 0 response partitions (1 implied)
10/23/2025 02:08:33.052 7f9d6b6509a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8535.013916, idle connection 185926.000000, request 304398.297310
10/23/2025 02:08:33.052 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 811
10/23/2025 02:08:33.052 7f9d6b6509a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/23/2025 02:08:33.052 7f9d6b6509a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Response 811 (602.2822856903076 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=960564100, topics=[])
10/23/2025 02:08:33.052 7f9d6b6509a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 960564100 with 0 response partitions (1 implied)
10/23/2025 02:08:33.083 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 234
10/23/2025 02:08:33.083 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
10/23/2025 02:08:33.083 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a4cb0a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
10/23/2025 02:08:33.084 7f9d6b650540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:33.084 7f9d6b650540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=57599649, session_epoch=782, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.084 7f9d6b650540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 786 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=57599649, session_epoch=782, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.084 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7693.901611, idle connection 185539.000000, request 304999.942303
10/23/2025 02:08:33.084 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 32
10/23/2025 02:08:33.084 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
10/23/2025 02:08:33.084 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a54ca00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
10/23/2025 02:08:33.084 7f9d6b0c6860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:33.084 7f9d6b0c6860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=844134647, session_epoch=751, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.085 7f9d6b0c6860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 755 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=844134647, session_epoch=751, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.085 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8247.837158, idle connection 185392.000000, request 304999.947309
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 130
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a46adf0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126391604, session_epoch=762, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 766 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1126391604, session_epoch=762, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.085 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8289.302002, idle connection 186122.000000, request 304999.966145
10/23/2025 02:08:33.086 7f9d6b650540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7692.122559, idle connection 185537.000000, request 304998.176098
10/23/2025 02:08:33.086 7f9d6b0c6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8246.503418, idle connection 185391.000000, request 304998.621225
10/23/2025 02:08:33.086 7f9d6b6502c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8288.165771, idle connection 186121.000000, request 304998.832464
10/23/2025 02:08:33.128 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 27
10/23/2025 02:08:33.129 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
10/23/2025 02:08:33.129 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479dc0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
10/23/2025 02:08:33.129 7f9d6b1bcea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:33.129 7f9d6b1bcea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1484190749, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.129 7f9d6b1bcea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 750 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1484190749, session_epoch=746, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.129 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7949.620117, idle connection 185308.000000, request 304999.945641
10/23/2025 02:08:33.129 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 36
10/23/2025 02:08:33.129 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
10/23/2025 02:08:33.130 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9d6a479100> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
10/23/2025 02:08:33.130 7f9d6b0e7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/23/2025 02:08:33.130 7f9d6b0e7400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277879316, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.130 7f9d6b0e7400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.241:9092 <connected> [IPv4 ('10.0.0.241', 9092)]>: Request 752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277879316, session_epoch=748, topics=[], forgotten_topics_data=[])
10/23/2025 02:08:33.130 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8458.923096, idle connection 185883.000000, request 304999.960423
10/23/2025 02:08:33.130 7f9d6b1bcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7948.337158, idle connection 185307.000000, request 304998.668671
10/23/2025 02:08:33.131 7f9d6b0e7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 8457.887939, idle connection 185882.000000, request 304998.930216