05/11/2026 02:30:25.402 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
05/11/2026 02:30:25.404 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
05/11/2026 02:30:25.404 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3fc10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
05/11/2026 02:30:25.404 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.404 7f831a83de00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=350025834, session_epoch=794, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.404 7f831a83de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=350025834, session_epoch=794, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.404 7f831a83de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242669.553223, idle connection 118724.000000, request 304999.953985
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 13
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab8db80> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2054941229, session_epoch=799, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 804 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2054941229, session_epoch=799, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.405 7f831bdd04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242670.544434, idle connection 118846.000000, request 304999.959230
05/11/2026 02:30:25.406 7f831a83de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242668.266846, idle connection 118722.000000, request 304998.671055
05/11/2026 02:30:25.407 7f831bdd04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242669.221680, idle connection 118844.000000, request 304998.636007
05/11/2026 02:30:25.470 7f831dc6e180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242617.769531, idle connection 119095.000000, request 304398.923635
05/11/2026 02:30:25.470 7f831dc6e180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 839
05/11/2026 02:30:25.470 7f831dc6e180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.470 7f831dc6e180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 839 (601.7413139343262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1327178209, topics=[])
05/11/2026 02:30:25.470 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1327178209 with 0 response partitions (1 implied)
05/11/2026 02:30:25.472 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 305
05/11/2026 02:30:25.472 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
05/11/2026 02:30:25.473 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3feb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
05/11/2026 02:30:25.473 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.473 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668321322, session_epoch=867, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.474 7f831c68b4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 872 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668321322, session_epoch=867, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.474 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242150.296387, idle connection 119830.000000, request 304999.772549
05/11/2026 02:30:25.474 7f831c68b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243868.209229, idle connection 119036.000000, request 304395.983219
05/11/2026 02:30:25.475 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242149.256104, idle connection 119829.000000, request 304998.898268
05/11/2026 02:30:25.475 7f831c68b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 861
05/11/2026 02:30:25.475 7f831c68b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.475 7f831c68b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 861 (604.9802303314209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1916111490, topics=[])
05/11/2026 02:30:25.476 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1916111490 with 0 response partitions (1 implied)
05/11/2026 02:30:25.476 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 163
05/11/2026 02:30:25.476 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
05/11/2026 02:30:25.476 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3f5b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
05/11/2026 02:30:25.476 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.476 7f831c68b680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1364955298, session_epoch=831, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.476 7f831c68b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 836 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1364955298, session_epoch=831, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.476 7f831c68b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242451.481934, idle connection 118786.000000, request 304999.930143
05/11/2026 02:30:25.477 7f831c68b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242450.930176, idle connection 118786.000000, request 304999.382019
05/11/2026 02:30:25.477 7f831be94d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242142.917480, idle connection 118773.000000, request 304399.300575
05/11/2026 02:30:25.478 7f831be94d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 801
05/11/2026 02:30:25.478 7f831be94d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.478 7f831be94d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 801 (601.1478900909424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1702341855, topics=[])
05/11/2026 02:30:25.478 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1702341855 with 0 response partitions (1 implied)
05/11/2026 02:30:25.526 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 40
05/11/2026 02:30:25.526 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
05/11/2026 02:30:25.526 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69b20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
05/11/2026 02:30:25.526 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.527 7f831c7cd7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1520784030, session_epoch=801, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.527 7f831c7cd7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=1520784030, session_epoch=801, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.527 7f831c7cd7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242748.664551, idle connection 118899.000000, request 304999.939680
05/11/2026 02:30:25.527 7f831bdd0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242095.417480, idle connection 119144.000000, request 304396.949768
05/11/2026 02:30:25.528 7f831c7cd7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242747.717529, idle connection 118899.000000, request 304999.000788
05/11/2026 02:30:25.528 7f831bdd0860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808
05/11/2026 02:30:25.528 7f831bdd0860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.528 7f831bdd0860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 808 (604.0892601013184 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=165782580, topics=[])
05/11/2026 02:30:25.528 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 165782580 with 0 response partitions (1 implied)
05/11/2026 02:30:25.565 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 57
05/11/2026 02:30:25.565 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
05/11/2026 02:30:25.565 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69e50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
05/11/2026 02:30:25.566 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.566 7f831c7cdc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=12315375, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.566 7f831c7cdc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=12315375, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.566 7f831c7cdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242753.011963, idle connection 119314.000000, request 304999.936104
05/11/2026 02:30:25.566 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
05/11/2026 02:30:25.566 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
05/11/2026 02:30:25.566 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab697f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
05/11/2026 02:30:25.567 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.567 7f831c7cd0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=836786288, session_epoch=794, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.567 7f831c7cd0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=836786288, session_epoch=794, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.567 7f831c7cd0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242753.625488, idle connection 118808.000000, request 304999.944448
05/11/2026 02:30:25.567 7f831c7cdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242751.474365, idle connection 119312.000000, request 304998.412371
05/11/2026 02:30:25.568 7f831c7cd0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242752.715332, idle connection 118808.000000, request 304999.040842
05/11/2026 02:30:25.636 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 71
05/11/2026 02:30:25.636 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
05/11/2026 02:30:25.636 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
05/11/2026 02:30:25.637 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.637 7f831c7cda40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=945040578, session_epoch=810, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.637 7f831c7cda40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 815 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=945040578, session_epoch=810, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.637 7f831c7cda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242747.079834, idle connection 119295.000000, request 304999.927521
05/11/2026 02:30:25.637 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 8
05/11/2026 02:30:25.637 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
05/11/2026 02:30:25.638 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
05/11/2026 02:30:25.638 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.638 7f831c7cd5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=632062475, session_epoch=797, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.638 7f831c7cd5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 802 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=632062475, session_epoch=797, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.638 7f831c7cd5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242748.088623, idle connection 118380.000000, request 304999.958277
05/11/2026 02:30:25.638 7f831c7cda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242745.781982, idle connection 119293.000000, request 304998.641491
05/11/2026 02:30:25.639 7f831c7cd5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242747.171143, idle connection 118379.000000, request 304999.042749
05/11/2026 02:30:25.700 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
05/11/2026 02:30:25.700 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
05/11/2026 02:30:25.700 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab696a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
05/11/2026 02:30:25.700 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.700 7f831c7cd9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1107506862, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.700 7f831c7cd9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=1107506862, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.701 7f831c7cd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242766.547119, idle connection 118486.000000, request 304999.941111
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 378
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab699a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=299924601, session_epoch=863, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 868 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=299924601, session_epoch=863, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.701 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242786.734375, idle connection 119069.000000, request 304999.957800
05/11/2026 02:30:25.701 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 199
05/11/2026 02:30:25.702 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
05/11/2026 02:30:25.702 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abc0a00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
05/11/2026 02:30:25.702 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.702 7f831c68bae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883137347, session_epoch=844, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.702 7f831c68bae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 849 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883137347, session_epoch=844, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.702 7f831c68bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243257.358887, idle connection 119587.000000, request 304999.963999
05/11/2026 02:30:25.702 7f831c7cd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242764.693115, idle connection 118485.000000, request 304998.098135
05/11/2026 02:30:25.703 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242785.224609, idle connection 119068.000000, request 304998.452902
05/11/2026 02:30:25.703 7f831c68bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243256.199951, idle connection 119586.000000, request 304998.807669
05/11/2026 02:30:25.812 7f831c7cdb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242147.080566, idle connection 118270.000000, request 304398.759842
05/11/2026 02:30:25.813 7f831c7cdb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 809
05/11/2026 02:30:25.813 7f831c7cdb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.813 7f831c7cdb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 809 (602.0843982696533 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2049156008, topics=[])
05/11/2026 02:30:25.813 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2049156008 with 0 response partitions (1 implied)
05/11/2026 02:30:25.883 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241521.653076, idle connection 118339.000000, request 304398.543358
05/11/2026 02:30:25.884 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1187
05/11/2026 02:30:25.884 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.884 7f831a83dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 1187 (602.3859977722168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=221238372, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3904, last_stable_offset=3904, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f?\x00\x00\x01\x04\x00\x00\x00\x00\x02+\xeb\xee,\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
05/11/2026 02:30:25.885 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 221238372 with 1 response partitions (0 implied)
05/11/2026 02:30:25.885 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3903
05/11/2026 02:30:25.885 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3903 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
05/11/2026 02:30:25.886 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3904 (leader epoch 0)
05/11/2026 02:30:25.894 7f831be94720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243270.779297, idle connection 118830.000000, request 304398.904324
05/11/2026 02:30:25.895 7f831be94720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 804
05/11/2026 02:30:25.895 7f831be94720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.895 7f831be94720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 804 (601.8626689910889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=670978976, topics=[])
05/11/2026 02:30:25.895 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 670978976 with 0 response partitions (1 implied)
05/11/2026 02:30:25.898 7f831c7cd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242066.335449, idle connection 118787.000000, request 304398.655415
05/11/2026 02:30:25.898 7f831c7cd4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 819
05/11/2026 02:30:25.898 7f831c7cd4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.898 7f831c7cd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 819 (601.9754409790039 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=334942729, topics=[])
05/11/2026 02:30:25.899 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 334942729 with 0 response partitions (1 implied)
05/11/2026 02:30:25.901 7f831a655f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242087.479004, idle connection 118199.000000, request 304398.830414
05/11/2026 02:30:25.902 7f831a655f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 806
05/11/2026 02:30:25.902 7f831a655f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.902 7f831a655f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 806 (601.6905307769775 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1553695583, topics=[])
05/11/2026 02:30:25.902 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1553695583 with 0 response partitions (1 implied)
05/11/2026 02:30:25.911 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
05/11/2026 02:30:25.911 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
05/11/2026 02:30:25.911 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831b43ab80> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
05/11/2026 02:30:25.911 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.912 7f831be94b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1140640769, session_epoch=796, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.912 7f831be94b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 801 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1140640769, session_epoch=796, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.912 7f831be94b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242619.664551, idle connection 118690.000000, request 304999.942303
05/11/2026 02:30:25.912 7f831c7cdd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242106.659912, idle connection 118136.000000, request 304396.381617
05/11/2026 02:30:25.912 7f831c7cd180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241234.238281, idle connection 118462.000000, request 304396.919250
05/11/2026 02:30:25.913 7f831be94b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242618.762695, idle connection 118689.000000, request 304999.048710
05/11/2026 02:30:25.913 7f831c7cdd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 809
05/11/2026 02:30:25.913 7f831c7cdd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.913 7f831c7cdd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 809 (604.6884059906006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=336313164, topics=[])
05/11/2026 02:30:25.913 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 336313164 with 0 response partitions (1 implied)
05/11/2026 02:30:25.914 7f831c7cd180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 839
05/11/2026 02:30:25.914 7f831c7cd180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.914 7f831c7cd180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 839 (604.5060157775879 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=795144772, topics=[])
05/11/2026 02:30:25.914 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 795144772 with 0 response partitions (1 implied)
05/11/2026 02:30:25.959 7f831c7cd400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241400.774414, idle connection 118651.000000, request 304395.394325
05/11/2026 02:30:25.959 7f831c7cd400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 820
05/11/2026 02:30:25.959 7f831c7cd400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.960 7f831c7cd400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 820 (605.2632331848145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1689488680, topics=[])
05/11/2026 02:30:25.960 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1689488680 with 0 response partitions (1 implied)
05/11/2026 02:30:25.960 7f831dc6e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242438.836670, idle connection 118838.000000, request 304395.372629
05/11/2026 02:30:25.960 7f831c68b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242632.937500, idle connection 118369.000000, request 304395.967484
05/11/2026 02:30:25.960 7f831c68bd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241104.879395, idle connection 119132.000000, request 304397.061586
05/11/2026 02:30:25.961 7f831dc6e360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 852
05/11/2026 02:30:25.961 7f831dc6e360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.961 7f831dc6e360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 852 (605.5698394775391 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1431797282, topics=[])
05/11/2026 02:30:25.961 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1431797282 with 0 response partitions (1 implied)
05/11/2026 02:30:25.961 7f831c68b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 827
05/11/2026 02:30:25.961 7f831c68b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.961 7f831c68b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 827 (605.2370071411133 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=129929129, topics=[])
05/11/2026 02:30:25.962 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 129929129 with 0 response partitions (1 implied)
05/11/2026 02:30:25.962 7f831c68bd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 839
05/11/2026 02:30:25.962 7f831c68bd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:25.962 7f831c68bd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 839 (604.40993309021 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=641577395, topics=[])
05/11/2026 02:30:25.962 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 641577395 with 0 response partitions (1 implied)
05/11/2026 02:30:25.986 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3904
05/11/2026 02:30:25.986 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
05/11/2026 02:30:25.986 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51f70> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
05/11/2026 02:30:25.987 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.987 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=221238372, session_epoch=1183, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3904, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:25.987 7f831a83dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 1188 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=221238372, session_epoch=1183, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3904, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:25.987 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241417.738281, idle connection 118235.000000, request 304999.933720
05/11/2026 02:30:25.988 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241417.236572, idle connection 118235.000000, request 304999.442577
05/11/2026 02:30:25.998 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 54
05/11/2026 02:30:25.998 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
05/11/2026 02:30:25.998 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51d60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
05/11/2026 02:30:25.998 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:25.998 7f831c68b2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1097158467, session_epoch=808, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.999 7f831c68b2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 813 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1097158467, session_epoch=808, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:25.999 7f831c68b2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242726.130615, idle connection 118781.000000, request 304999.917030
05/11/2026 02:30:26.000 7f831c68b2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242725.369873, idle connection 118781.000000, request 304999.168873
05/11/2026 02:30:26.001 7f831c68b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241149.946533, idle connection 118994.000000, request 304399.055243
05/11/2026 02:30:26.001 7f831c68b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 844
05/11/2026 02:30:26.001 7f831c68b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.001 7f831c68b220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 844 (601.4266014099121 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1060807590, topics=[])
05/11/2026 02:30:26.002 7f831c68b220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1060807590 with 0 response partitions (1 implied)
05/11/2026 02:30:26.007 7f831a83de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242066.863037, idle connection 118121.000000, request 304397.252560
05/11/2026 02:30:26.008 7f831a83de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 799
05/11/2026 02:30:26.008 7f831a83de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.008 7f831a83de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 799 (603.4269332885742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=350025834, topics=[])
05/11/2026 02:30:26.008 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 350025834 with 0 response partitions (1 implied)
05/11/2026 02:30:26.008 7f831bdd04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242067.416748, idle connection 118243.000000, request 304396.829605
05/11/2026 02:30:26.009 7f831bdd04a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 804
05/11/2026 02:30:26.009 7f831bdd04a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.009 7f831bdd04a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 804 (603.543758392334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2054941229, topics=[])
05/11/2026 02:30:26.009 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2054941229 with 0 response partitions (1 implied)
05/11/2026 02:30:26.071 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 207
05/11/2026 02:30:26.071 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
05/11/2026 02:30:26.071 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
05/11/2026 02:30:26.071 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.071 7f831dc6e180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1327178209, session_epoch=835, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.072 7f831dc6e180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 840 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1327178209, session_epoch=835, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.072 7f831dc6e180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242015.582764, idle connection 118493.000000, request 304999.935865
05/11/2026 02:30:26.072 7f831dc6e180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242015.113525, idle connection 118493.000000, request 304999.478340
05/11/2026 02:30:26.076 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 313
05/11/2026 02:30:26.076 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
05/11/2026 02:30:26.076 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab513a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
05/11/2026 02:30:26.076 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.076 7f831c68b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1916111490, session_epoch=857, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.076 7f831c68b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 862 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1916111490, session_epoch=857, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.077 7f831c68b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243265.956787, idle connection 118434.000000, request 304999.947548
05/11/2026 02:30:26.077 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241547.233887, idle connection 119227.000000, request 304396.875858
05/11/2026 02:30:26.077 7f831c68b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243265.415039, idle connection 118433.000000, request 304999.413013
05/11/2026 02:30:26.077 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 872
05/11/2026 02:30:26.077 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.078 7f831c68b4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 872 (603.7940979003906 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1668321322, topics=[])
05/11/2026 02:30:26.078 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1668321322 with 0 response partitions (1 implied)
05/11/2026 02:30:26.078 7f831c68b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241850.051025, idle connection 118185.000000, request 304398.500919
05/11/2026 02:30:26.078 7f831c68b680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 836
05/11/2026 02:30:26.078 7f831c68b680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.078 7f831c68b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 836 (601.9937992095947 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1364955298, topics=[])
05/11/2026 02:30:26.079 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1364955298 with 0 response partitions (1 implied)
05/11/2026 02:30:26.079 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 11
05/11/2026 02:30:26.079 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
05/11/2026 02:30:26.079 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab8d7f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
05/11/2026 02:30:26.079 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.079 7f831be94d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1702341855, session_epoch=797, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.079 7f831be94d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 802 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1702341855, session_epoch=797, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.079 7f831be94d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241540.774658, idle connection 118171.000000, request 304999.955177
05/11/2026 02:30:26.080 7f831be94d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241540.438232, idle connection 118170.000000, request 304999.623060
05/11/2026 02:30:26.129 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 26
05/11/2026 02:30:26.129 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
05/11/2026 02:30:26.129 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb91f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
05/11/2026 02:30:26.129 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.130 7f831bdd0860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=165782580, session_epoch=804, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.130 7f831bdd0860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=165782580, session_epoch=804, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.130 7f831bdd0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241492.863770, idle connection 118541.000000, request 304999.943018
05/11/2026 02:30:26.130 7f831c7cd7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242145.431641, idle connection 118296.000000, request 304396.717310
05/11/2026 02:30:26.130 7f831bdd0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241492.236328, idle connection 118540.000000, request 304999.326468
05/11/2026 02:30:26.131 7f831c7cd7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 806
05/11/2026 02:30:26.131 7f831c7cd7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.131 7f831c7cd7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 806 (604.0880680084229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1520784030, topics=[])
05/11/2026 02:30:26.131 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1520784030 with 0 response partitions (1 implied)
05/11/2026 02:30:26.169 7f831c7cdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242150.391846, idle connection 118711.000000, request 304397.319794
05/11/2026 02:30:26.169 7f831c7cdc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 811
05/11/2026 02:30:26.169 7f831c7cdc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.169 7f831c7cdc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 811 (603.3182144165039 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=12315375, topics=[])
05/11/2026 02:30:26.169 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 12315375 with 0 response partitions (1 implied)
05/11/2026 02:30:26.170 7f831c7cd0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242150.880859, idle connection 118206.000000, request 304397.202730
05/11/2026 02:30:26.170 7f831c7cd0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 799
05/11/2026 02:30:26.170 7f831c7cd0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.170 7f831c7cd0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 799 (603.2226085662842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=836786288, topics=[])
05/11/2026 02:30:26.170 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 836786288 with 0 response partitions (1 implied)
05/11/2026 02:30:26.239 7f831c7cda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242144.684814, idle connection 118692.000000, request 304397.534370
05/11/2026 02:30:26.240 7f831c7cda40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 815
05/11/2026 02:30:26.240 7f831c7cda40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.240 7f831c7cda40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 815 (603.1436920166016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=945040578, topics=[])
05/11/2026 02:30:26.240 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 945040578 with 0 response partitions (1 implied)
05/11/2026 02:30:26.241 7f831c7cd5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242145.404297, idle connection 117777.000000, request 304397.274017
05/11/2026 02:30:26.241 7f831c7cd5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 802
05/11/2026 02:30:26.241 7f831c7cd5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.241 7f831c7cd5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 802 (603.0707359313965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=632062475, topics=[])
05/11/2026 02:30:26.241 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 632062475 with 0 response partitions (1 implied)
05/11/2026 02:30:26.304 7f831c7cd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242163.397217, idle connection 117883.000000, request 304396.790028
05/11/2026 02:30:26.304 7f831c7cd9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810
05/11/2026 02:30:26.304 7f831c7cd9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.304 7f831c7cd9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 810 (603.7914752960205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1107506862, topics=[])
05/11/2026 02:30:26.305 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1107506862 with 0 response partitions (1 implied)
05/11/2026 02:30:26.305 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242183.257812, idle connection 118466.000000, request 304396.478176
05/11/2026 02:30:26.305 7f831c68bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242654.340820, idle connection 118984.000000, request 304396.945715
05/11/2026 02:30:26.305 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 868
05/11/2026 02:30:26.305 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.305 7f831c68bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 868 (604.1409969329834 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=299924601, topics=[])
05/11/2026 02:30:26.306 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 299924601 with 0 response partitions (1 implied)
05/11/2026 02:30:26.306 7f831c68bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 849
05/11/2026 02:30:26.306 7f831c68bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.306 7f831c68bae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 849 (604.0732860565186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=883137347, topics=[])
05/11/2026 02:30:26.306 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 883137347 with 0 response partitions (1 implied)
05/11/2026 02:30:26.414 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 51
05/11/2026 02:30:26.415 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
05/11/2026 02:30:26.415 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab511c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
05/11/2026 02:30:26.415 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.415 7f831c7cdb80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2049156008, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.416 7f831c7cdb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=2049156008, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.416 7f831c7cdb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241543.767822, idle connection 117667.000000, request 304999.934912
05/11/2026 02:30:26.416 7f831c7cdb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241543.258301, idle connection 117666.000000, request 304999.435425
05/11/2026 02:30:26.496 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 19
05/11/2026 02:30:26.496 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
05/11/2026 02:30:26.496 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ac3c430> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
05/11/2026 02:30:26.496 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.496 7f831be94720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=670978976, session_epoch=800, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.496 7f831be94720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 805 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=670978976, session_epoch=800, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.496 7f831be94720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242668.418213, idle connection 118228.000000, request 304999.941111
05/11/2026 02:30:26.497 7f831be94720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242667.955811, idle connection 118228.000000, request 304999.488115
05/11/2026 02:30:26.499 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 75
05/11/2026 02:30:26.499 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
05/11/2026 02:30:26.499 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb93d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
05/11/2026 02:30:26.500 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.500 7f831c7cd4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=334942729, session_epoch=815, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.500 7f831c7cd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 820 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=334942729, session_epoch=815, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.500 7f831c7cd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241464.117432, idle connection 118185.000000, request 304999.947548
05/11/2026 02:30:26.500 7f831c7cd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241463.703857, idle connection 118184.000000, request 304999.535561
05/11/2026 02:30:26.502 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 21
05/11/2026 02:30:26.502 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
05/11/2026 02:30:26.503 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab6f5e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
05/11/2026 02:30:26.503 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.503 7f831a655f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1553695583, session_epoch=802, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.503 7f831a655f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=1553695583, session_epoch=802, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.503 7f831a655f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241485.674561, idle connection 117597.000000, request 304999.954700
05/11/2026 02:30:26.503 7f831a655f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241485.277344, idle connection 117597.000000, request 304999.559402
05/11/2026 02:30:26.514 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44
05/11/2026 02:30:26.514 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
05/11/2026 02:30:26.514 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab6f490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
05/11/2026 02:30:26.514 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.514 7f831c7cdd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=336313164, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.514 7f831c7cdd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=336313164, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.515 7f831c7cdd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241504.247314, idle connection 117533.000000, request 304999.925852
05/11/2026 02:30:26.515 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 202
05/11/2026 02:30:26.515 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
05/11/2026 02:30:26.515 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51f40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
05/11/2026 02:30:26.515 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.516 7f831c7cd180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=795144772, session_epoch=835, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.516 7f831c7cd180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 840 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=795144772, session_epoch=835, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.516 7f831c7cd180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240630.678467, idle connection 117858.000000, request 304999.932051
05/11/2026 02:30:26.516 7f831be94b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242015.323975, idle connection 118086.000000, request 304395.608187
05/11/2026 02:30:26.517 7f831c7cdd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241501.940674, idle connection 117531.000000, request 304997.630119
05/11/2026 02:30:26.517 7f831be94b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 801
05/11/2026 02:30:26.517 7f831be94b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.517 7f831be94b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 801 (605.614423751831 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1140640769, topics=[])
05/11/2026 02:30:26.518 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1140640769 with 0 response partitions (1 implied)
05/11/2026 02:30:26.518 7f831c7cd180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240628.239014, idle connection 117856.000000, request 304997.500896
05/11/2026 02:30:26.560 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 84
05/11/2026 02:30:26.561 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
05/11/2026 02:30:26.561 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51610> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
05/11/2026 02:30:26.561 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.561 7f831c7cd400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1689488680, session_epoch=816, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.562 7f831c7cd400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 821 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1689488680, session_epoch=816, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.562 7f831c7cd400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240797.981445, idle connection 118048.000000, request 304999.940157
05/11/2026 02:30:26.562 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 251
05/11/2026 02:30:26.562 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
05/11/2026 02:30:26.562 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab514c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
05/11/2026 02:30:26.563 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.563 7f831dc6e360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1431797282, session_epoch=848, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.563 7f831dc6e360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 853 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1431797282, session_epoch=848, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.563 7f831dc6e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241835.916260, idle connection 118235.000000, request 304999.945164
05/11/2026 02:30:26.563 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 157
05/11/2026 02:30:26.563 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
05/11/2026 02:30:26.563 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831b56f3a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
05/11/2026 02:30:26.563 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.564 7f831c68b7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=129929129, session_epoch=823, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.564 7f831c68b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 828 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=129929129, session_epoch=823, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.564 7f831c68b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242029.160645, idle connection 117766.000000, request 304999.959230
05/11/2026 02:30:26.564 7f831c7cd400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240795.231201, idle connection 118045.000000, request 304997.200012
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 230
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab8d700> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641577395, session_epoch=835, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 840 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641577395, session_epoch=835, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.565 7f831c68bd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240500.071289, idle connection 118528.000000, request 304999.957085
05/11/2026 02:30:26.566 7f831dc6e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241833.274170, idle connection 118232.000000, request 304997.308254
05/11/2026 02:30:26.566 7f831c68b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242027.302490, idle connection 117764.000000, request 304998.105764
05/11/2026 02:30:26.566 7f831c68bd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240498.902588, idle connection 118526.000000, request 304998.794556
05/11/2026 02:30:26.588 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240816.648438, idle connection 117634.000000, request 304398.844242
05/11/2026 02:30:26.589 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1188
05/11/2026 02:30:26.589 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.589 7f831a83dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 1188 (601.8621921539307 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=221238372, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3905, last_stable_offset=3905, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f@\x00\x00\x01\x04\x00\x00\x00\x00\x02\xe4\x9f\x1fH\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
05/11/2026 02:30:26.589 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 221238372 with 1 response partitions (0 implied)
05/11/2026 02:30:26.589 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3904
05/11/2026 02:30:26.589 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3904 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
05/11/2026 02:30:26.590 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3905 (leader epoch 0)
05/11/2026 02:30:26.600 7f831c68b2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242124.683594, idle connection 118180.000000, request 304398.479939
05/11/2026 02:30:26.601 7f831c68b2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 813
05/11/2026 02:30:26.601 7f831c68b2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.601 7f831c68b2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 813 (602.3075580596924 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1097158467, topics=[])
05/11/2026 02:30:26.601 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1097158467 with 0 response partitions (1 implied)
05/11/2026 02:30:26.602 7f831c68b220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 213
05/11/2026 02:30:26.602 7f831c68b220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
05/11/2026 02:30:26.602 7f831c68b220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb9af0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
05/11/2026 02:30:26.602 7f831c68b220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.602 7f831c68b220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1060807590, session_epoch=840, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.603 7f831c68b220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 845 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1060807590, session_epoch=840, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.603 7f831c68b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240548.036621, idle connection 118392.000000, request 304999.847889
05/11/2026 02:30:26.603 7f831c68b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240547.620361, idle connection 118392.000000, request 304999.437332
05/11/2026 02:30:26.608 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
05/11/2026 02:30:26.609 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
05/11/2026 02:30:26.609 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3f1c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
05/11/2026 02:30:26.609 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.609 7f831a83de00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=350025834, session_epoch=795, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.609 7f831a83de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 800 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=350025834, session_epoch=795, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.609 7f831a83de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241464.803467, idle connection 117519.000000, request 304999.947309
05/11/2026 02:30:26.609 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 13
05/11/2026 02:30:26.609 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
05/11/2026 02:30:26.609 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51190> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
05/11/2026 02:30:26.610 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.610 7f831bdd04a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2054941229, session_epoch=800, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.610 7f831bdd04a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 805 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2054941229, session_epoch=800, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.610 7f831bdd04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241465.902832, idle connection 117641.000000, request 304999.962091
05/11/2026 02:30:26.610 7f831a83de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241463.751465, idle connection 117518.000000, request 304998.896360
05/11/2026 02:30:26.611 7f831bdd04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241465.060303, idle connection 117640.000000, request 304999.121904
05/11/2026 02:30:26.673 7f831dc6e180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241414.609619, idle connection 117892.000000, request 304398.964882
05/11/2026 02:30:26.673 7f831dc6e180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 840
05/11/2026 02:30:26.673 7f831dc6e180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.673 7f831dc6e180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 840 (601.5963554382324 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1327178209, topics=[])
05/11/2026 02:30:26.673 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1327178209 with 0 response partitions (1 implied)
05/11/2026 02:30:26.678 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 305
05/11/2026 02:30:26.678 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
05/11/2026 02:30:26.678 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51c40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
05/11/2026 02:30:26.679 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.679 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668321322, session_epoch=868, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.679 7f831c68b4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 873 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668321322, session_epoch=868, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.679 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240945.233643, idle connection 118625.000000, request 304999.947071
05/11/2026 02:30:26.679 7f831c68b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242663.466064, idle connection 117831.000000, request 304397.459507
05/11/2026 02:30:26.679 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 163
05/11/2026 02:30:26.679 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
05/11/2026 02:30:26.679 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831c1f5460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
05/11/2026 02:30:26.680 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.680 7f831c68b680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1364955298, session_epoch=832, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.680 7f831c68b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 837 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1364955298, session_epoch=832, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.680 7f831c68b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241247.930664, idle connection 117583.000000, request 304999.956369
05/11/2026 02:30:26.681 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240943.113770, idle connection 118623.000000, request 304997.833014
05/11/2026 02:30:26.681 7f831c68b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 862
05/11/2026 02:30:26.681 7f831c68b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.681 7f831c68b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 862 (604.8104763031006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1916111490, topics=[])
05/11/2026 02:30:26.682 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1916111490 with 0 response partitions (1 implied)
05/11/2026 02:30:26.682 7f831be94d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240938.391846, idle connection 117568.000000, request 304397.574902
05/11/2026 02:30:26.682 7f831c68b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241245.908936, idle connection 117581.000000, request 304997.940540
05/11/2026 02:30:26.683 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 873
05/11/2026 02:30:26.683 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.683 7f831c68b4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 873 (4.471540451049805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1668321322, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=306, last_stable_offset=306, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x011\x00\x00\x00\xfc\x00\x00\x00\x00\x02\x13A\x00\xe7\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...')])])
05/11/2026 02:30:26.684 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1668321322 with 1 response partitions (0 implied)
05/11/2026 02:30:26.684 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 264 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 305
05/11/2026 02:30:26.684 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 305 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0)
05/11/2026 02:30:26.685 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 306 (leader epoch 0)
05/11/2026 02:30:26.685 7f831be94d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 802
05/11/2026 02:30:26.685 7f831be94d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.685 7f831be94d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 802 (605.6075096130371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1702341855, topics=[])
05/11/2026 02:30:26.685 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1702341855 with 0 response partitions (1 implied)
05/11/2026 02:30:26.691 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3905
05/11/2026 02:30:26.691 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
05/11/2026 02:30:26.691 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69940> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
05/11/2026 02:30:26.691 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.692 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=221238372, session_epoch=1184, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3905, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:26.692 7f831a83dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 1189 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=221238372, session_epoch=1184, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3905, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:26.693 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240712.305176, idle connection 117530.000000, request 304999.824286
05/11/2026 02:30:26.693 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240711.499023, idle connection 117529.000000, request 304999.031067
05/11/2026 02:30:26.732 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 40
05/11/2026 02:30:26.732 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
05/11/2026 02:30:26.732 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831b46f1f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
05/11/2026 02:30:26.732 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.732 7f831c7cd7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1520784030, session_epoch=802, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.733 7f831c7cd7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=1520784030, session_epoch=802, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.733 7f831c7cd7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241542.429199, idle connection 117693.000000, request 304999.932766
05/11/2026 02:30:26.733 7f831bdd0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240889.275391, idle connection 117937.000000, request 304396.362305
05/11/2026 02:30:26.734 7f831c7cd7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241541.594482, idle connection 117692.000000, request 304999.108076
05/11/2026 02:30:26.734 7f831bdd0860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 809
05/11/2026 02:30:26.734 7f831bdd0860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.734 7f831bdd0860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 809 (604.6514511108398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=165782580, topics=[])
05/11/2026 02:30:26.735 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 165782580 with 0 response partitions (1 implied)
05/11/2026 02:30:26.770 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 57
05/11/2026 02:30:26.770 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
05/11/2026 02:30:26.770 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3ffa0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
05/11/2026 02:30:26.770 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.770 7f831c7cdc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=12315375, session_epoch=807, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.770 7f831c7cdc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 812 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=12315375, session_epoch=807, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.771 7f831c7cdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241548.335449, idle connection 118109.000000, request 304999.944687
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831b56feb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=836786288, session_epoch=795, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 800 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=836786288, session_epoch=795, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.771 7f831c7cd0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241549.239014, idle connection 117604.000000, request 304999.964952
05/11/2026 02:30:26.772 7f831c7cdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241547.153809, idle connection 118108.000000, request 304998.772144
05/11/2026 02:30:26.772 7f831c7cd0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241548.415039, idle connection 117603.000000, request 304999.142647
05/11/2026 02:30:26.785 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 306
05/11/2026 02:30:26.785 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
05/11/2026 02:30:26.785 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb9250> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
05/11/2026 02:30:26.785 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.785 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668321322, session_epoch=869, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=306, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:26.786 7f831c68b4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 874 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668321322, session_epoch=869, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=306, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:26.786 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240838.257812, idle connection 118518.000000, request 304999.944687
05/11/2026 02:30:26.787 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240837.594482, idle connection 118517.000000, request 304999.288321
05/11/2026 02:30:26.841 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 71
05/11/2026 02:30:26.841 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
05/11/2026 02:30:26.841 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb9580> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
05/11/2026 02:30:26.842 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.842 7f831c7cda40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=945040578, session_epoch=811, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.842 7f831c7cda40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 816 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=945040578, session_epoch=811, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.842 7f831c7cda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241541.855225, idle connection 118089.000000, request 304999.908447
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 8
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69ca0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=632062475, session_epoch=798, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 803 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=632062475, session_epoch=798, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.843 7f831c7cd5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241542.706055, idle connection 117175.000000, request 304999.956846
05/11/2026 02:30:26.844 7f831c7cda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241540.250244, idle connection 118088.000000, request 304998.324871
05/11/2026 02:30:26.844 7f831c7cd5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241541.835449, idle connection 117174.000000, request 304999.091387
05/11/2026 02:30:26.905 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
05/11/2026 02:30:26.906 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
05/11/2026 02:30:26.906 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69790> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
05/11/2026 02:30:26.906 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.906 7f831c7cd9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1107506862, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.907 7f831c7cd9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=1107506862, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.907 7f831c7cd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241560.335449, idle connection 117280.000000, request 304999.912262
05/11/2026 02:30:26.907 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 378
05/11/2026 02:30:26.907 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
05/11/2026 02:30:26.908 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab693d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
05/11/2026 02:30:26.908 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.908 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=299924601, session_epoch=864, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.908 7f831c68bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 869 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=299924601, session_epoch=864, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.908 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241579.730225, idle connection 117862.000000, request 304999.927998
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 199
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab692e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883137347, session_epoch=845, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 850 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883137347, session_epoch=845, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:26.909 7f831c68bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242049.900146, idle connection 118380.000000, request 304999.949455
05/11/2026 02:30:26.910 7f831c7cd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241557.128174, idle connection 117277.000000, request 304996.724367
05/11/2026 02:30:26.910 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241577.669189, idle connection 117860.000000, request 304997.874260
05/11/2026 02:30:26.911 7f831c68bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242048.425293, idle connection 118378.000000, request 304998.469591
05/11/2026 02:30:26.911 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 869
05/11/2026 02:30:26.911 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:26.912 7f831c68bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 869 (3.333568572998047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=299924601, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=380, last_stable_offset=380, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01z\x00\x00\x02\x13\x00\x00\x00\x00\x02\xdc\xae9\x11\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
05/11/2026 02:30:26.912 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 299924601 with 1 response partitions (0 implied)
05/11/2026 02:30:26.912 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 543 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 378
05/11/2026 02:30:26.912 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 378 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0)
05/11/2026 02:30:26.913 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 380 (leader epoch 0)
05/11/2026 02:30:27.014 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 380
05/11/2026 02:30:27.014 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
05/11/2026 02:30:27.014 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831dc2fb20> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
05/11/2026 02:30:27.014 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.014 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=299924601, session_epoch=865, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=380, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:27.015 7f831c68bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 870 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=299924601, session_epoch=865, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=380, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:27.015 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241473.048584, idle connection 117755.000000, request 304999.904871
05/11/2026 02:30:27.016 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241472.237793, idle connection 117755.000000, request 304999.107599
05/11/2026 02:30:27.018 7f831c7cdb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240941.370117, idle connection 117064.000000, request 304397.541046
05/11/2026 02:30:27.019 7f831c7cdb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810
05/11/2026 02:30:27.019 7f831c7cdb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.019 7f831c7cdb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 810 (603.224515914917 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2049156008, topics=[])
05/11/2026 02:30:27.019 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2049156008 with 0 response partitions (1 implied)
05/11/2026 02:30:27.097 7f831be94720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242067.418945, idle connection 117627.000000, request 304398.939133
05/11/2026 02:30:27.098 7f831be94720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 805
05/11/2026 02:30:27.098 7f831be94720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.098 7f831be94720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 805 (601.8097400665283 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=670978976, topics=[])
05/11/2026 02:30:27.098 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 670978976 with 0 response partitions (1 implied)
05/11/2026 02:30:27.102 7f831c7cd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240862.311523, idle connection 117583.000000, request 304398.135900
05/11/2026 02:30:27.102 7f831c7cd4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 820
05/11/2026 02:30:27.102 7f831c7cd4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.103 7f831c7cd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 820 (602.6396751403809 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=334942729, topics=[])
05/11/2026 02:30:27.103 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 334942729 with 0 response partitions (1 implied)
05/11/2026 02:30:27.104 7f831a655f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240884.889404, idle connection 116997.000000, request 304399.168968
05/11/2026 02:30:27.104 7f831a655f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 807
05/11/2026 02:30:27.104 7f831a655f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.104 7f831a655f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 807 (601.1931896209717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1553695583, topics=[])
05/11/2026 02:30:27.104 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1553695583 with 0 response partitions (1 implied)
05/11/2026 02:30:27.118 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
05/11/2026 02:30:27.118 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
05/11/2026 02:30:27.118 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab819d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
05/11/2026 02:30:27.118 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.119 7f831be94b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1140640769, session_epoch=797, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.119 7f831be94b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 802 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1140640769, session_epoch=797, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.119 7f831be94b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241412.718506, idle connection 117483.000000, request 304999.942064
05/11/2026 02:30:27.119 7f831c7cdd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240899.772949, idle connection 116929.000000, request 304395.466805
05/11/2026 02:30:27.119 7f831c7cd180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240027.407227, idle connection 117255.000000, request 304396.673441
05/11/2026 02:30:27.120 7f831be94b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241411.852539, idle connection 117482.000000, request 304999.084949
05/11/2026 02:30:27.120 7f831c7cdd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810
05/11/2026 02:30:27.120 7f831c7cdd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.120 7f831c7cdd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 810 (605.548620223999 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=336313164, topics=[])
05/11/2026 02:30:27.120 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 336313164 with 0 response partitions (1 implied)
05/11/2026 02:30:27.121 7f831c7cd180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 840
05/11/2026 02:30:27.121 7f831c7cd180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.121 7f831c7cd180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 840 (604.9168109893799 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=795144772, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xca\x00\x00\x01\xc7\x00\x00\x00\x00\x02uj\x95\xea\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\x90\x03\x00\x00\x00\xd2\x02ObjectVRouter:cn-jenkins-deploy-...')])])
05/11/2026 02:30:27.121 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 795144772 with 1 response partitions (0 implied)
05/11/2026 02:30:27.121 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 467 bytes of data for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 202
05/11/2026 02:30:27.121 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 202 for assigned partition TopicPartition(topic='-uve-topic-2', partition=0)
05/11/2026 02:30:27.122 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) to 204 (leader epoch 0)
05/11/2026 02:30:27.167 7f831c7cd400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240193.128418, idle connection 117443.000000, request 304395.080566
05/11/2026 02:30:27.167 7f831c7cd400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 821
05/11/2026 02:30:27.167 7f831c7cd400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.167 7f831c7cd400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 821 (605.8344841003418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1689488680, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=85, last_stable_offset=85, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00T\x00\x00\x01\x17\x00\x00\x00\x00\x02\xc0\xf0\x7f\x00\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xc8\x03\x00\x00\x00\x8a\x03ObjectVMITable:default-global-sy...')])])
05/11/2026 02:30:27.168 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1689488680 with 1 response partitions (0 implied)
05/11/2026 02:30:27.168 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-15', partition=0) with offset 84
05/11/2026 02:30:27.168 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 84 for assigned partition TopicPartition(topic='-uve-topic-15', partition=0)
05/11/2026 02:30:27.169 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-15', partition=0) to 85 (leader epoch 0)
05/11/2026 02:30:27.169 7f831dc6e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241229.654297, idle connection 117628.000000, request 304393.684864
05/11/2026 02:30:27.169 7f831c68b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241423.811035, idle connection 117160.000000, request 304394.613504
05/11/2026 02:30:27.170 7f831c68bd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239895.767822, idle connection 117923.000000, request 304395.657778
05/11/2026 02:30:27.170 7f831dc6e360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 853
05/11/2026 02:30:27.170 7f831dc6e360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.170 7f831dc6e360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 853 (607.180118560791 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1431797282, topics=[])
05/11/2026 02:30:27.170 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1431797282 with 0 response partitions (1 implied)
05/11/2026 02:30:27.171 7f831c68b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 828
05/11/2026 02:30:27.171 7f831c68b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.171 7f831c68b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 828 (607.11669921875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=129929129, topics=[])
05/11/2026 02:30:27.172 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 129929129 with 0 response partitions (1 implied)
05/11/2026 02:30:27.172 7f831c68bd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 840
05/11/2026 02:30:27.172 7f831c68bd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.172 7f831c68bd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 840 (606.8809032440186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=641577395, topics=[])
05/11/2026 02:30:27.172 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 641577395 with 0 response partitions (1 implied)
05/11/2026 02:30:27.202 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 54
05/11/2026 02:30:27.202 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
05/11/2026 02:30:27.202 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb98e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
05/11/2026 02:30:27.202 7f831c68b2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.202 7f831c68b2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1097158467, session_epoch=809, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.202 7f831c68b2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 814 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1097158467, session_epoch=809, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.203 7f831c68b2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241522.376221, idle connection 117578.000000, request 304999.940872
05/11/2026 02:30:27.203 7f831c68b2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241521.896240, idle connection 117577.000000, request 304999.471664
05/11/2026 02:30:27.204 7f831c68b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239947.235596, idle connection 117792.000000, request 304399.051905
05/11/2026 02:30:27.204 7f831c68b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 845
05/11/2026 02:30:27.204 7f831c68b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.204 7f831c68b220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 845 (601.5732288360596 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1060807590, topics=[])
05/11/2026 02:30:27.204 7f831c68b220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1060807590 with 0 response partitions (1 implied)
05/11/2026 02:30:27.211 7f831a83de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240862.850342, idle connection 116917.000000, request 304397.990465
05/11/2026 02:30:27.212 7f831a83de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 800
05/11/2026 02:30:27.212 7f831a83de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.212 7f831a83de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 800 (602.7631759643555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=350025834, topics=[])
05/11/2026 02:30:27.212 7f831a83de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 350025834 with 0 response partitions (1 implied)
05/11/2026 02:30:27.212 7f831bdd04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240863.372314, idle connection 117039.000000, request 304397.432566
05/11/2026 02:30:27.213 7f831bdd04a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 805
05/11/2026 02:30:27.213 7f831bdd04a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.213 7f831bdd04a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 805 (602.8735637664795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2054941229, topics=[])
05/11/2026 02:30:27.213 7f831bdd04a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2054941229 with 0 response partitions (1 implied)
05/11/2026 02:30:27.222 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 204
05/11/2026 02:30:27.222 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
05/11/2026 02:30:27.222 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab694f0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-2', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
05/11/2026 02:30:27.222 7f831c7cd180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.223 7f831c7cd180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=795144772, session_epoch=836, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=204, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:27.223 7f831c7cd180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=795144772, session_epoch=836, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=204, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:27.223 7f831c7cd180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239923.546875, idle connection 117151.000000, request 304999.924660
05/11/2026 02:30:27.224 7f831c7cd180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239922.517090, idle connection 117150.000000, request 304998.907566
05/11/2026 02:30:27.270 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 85
05/11/2026 02:30:27.270 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
05/11/2026 02:30:27.270 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3f7c0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-15', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
05/11/2026 02:30:27.270 7f831c7cd400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.270 7f831c7cd400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1689488680, session_epoch=817, topics=[(topic='-uve-topic-15', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=85, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:27.271 7f831c7cd400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1689488680, session_epoch=817, topics=[(topic='-uve-topic-15', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=85, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/11/2026 02:30:27.271 7f831c7cd400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240088.709229, idle connection 117339.000000, request 304999.938011
05/11/2026 02:30:27.272 7f831c7cd400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240088.129883, idle connection 117338.000000, request 304999.366999
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 207
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab69250> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1327178209, session_epoch=836, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1327178209, session_epoch=836, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.274 7f831dc6e180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240812.848145, idle connection 117290.000000, request 304999.948025
05/11/2026 02:30:27.275 7f831dc6e180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240812.512207, idle connection 117290.000000, request 304999.625444
05/11/2026 02:30:27.282 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 313
05/11/2026 02:30:27.282 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
05/11/2026 02:30:27.282 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab90ac0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
05/11/2026 02:30:27.282 7f831c68b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.282 7f831c68b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1916111490, session_epoch=858, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.283 7f831c68b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 863 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1916111490, session_epoch=858, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.283 7f831c68b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242059.838135, idle connection 117228.000000, request 304999.946594
05/11/2026 02:30:27.283 7f831c68b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242059.433350, idle connection 117227.000000, request 304999.548435
05/11/2026 02:30:27.286 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 11
05/11/2026 02:30:27.286 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
05/11/2026 02:30:27.286 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abd1250> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
05/11/2026 02:30:27.287 7f831be94d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.287 7f831be94d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1702341855, session_epoch=798, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.287 7f831be94d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 803 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1702341855, session_epoch=798, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.287 7f831be94d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240333.187744, idle connection 116963.000000, request 304999.952555
05/11/2026 02:30:27.287 7f831c68b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240640.751953, idle connection 116975.000000, request 304392.781973
05/11/2026 02:30:27.288 7f831be94d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240332.679443, idle connection 116963.000000, request 304999.448299
05/11/2026 02:30:27.288 7f831c68b680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 837
05/11/2026 02:30:27.288 7f831c68b680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.288 7f831c68b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 837 (607.8596115112305 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1364955298, topics=[])
05/11/2026 02:30:27.288 7f831c68b680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1364955298 with 0 response partitions (1 implied)
05/11/2026 02:30:27.294 7f831a83dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240111.003418, idle connection 116929.000000, request 304398.536921
05/11/2026 02:30:27.294 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1189
05/11/2026 02:30:27.294 7f831a83dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.294 7f831a83dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 1189 (601.9296646118164 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=221238372, topics=[])
05/11/2026 02:30:27.295 7f831a83dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 221238372 with 0 response partitions (1 implied)
05/11/2026 02:30:27.335 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 26
05/11/2026 02:30:27.336 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
05/11/2026 02:30:27.336 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3f2b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
05/11/2026 02:30:27.336 7f831bdd0860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.336 7f831bdd0860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=165782580, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.336 7f831bdd0860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=165782580, session_epoch=805, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.337 7f831bdd0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240286.083740, idle connection 117334.000000, request 304999.913692
05/11/2026 02:30:27.337 7f831c7cd7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240938.369873, idle connection 117089.000000, request 304395.879030
05/11/2026 02:30:27.338 7f831bdd0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240285.091309, idle connection 117333.000000, request 304998.938799
05/11/2026 02:30:27.338 7f831c7cd7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 807
05/11/2026 02:30:27.338 7f831c7cd7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.338 7f831c7cd7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 807 (604.9549579620361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1520784030, topics=[])
05/11/2026 02:30:27.338 7f831c7cd7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1520784030 with 0 response partitions (1 implied)
05/11/2026 02:30:27.373 7f831c7cdc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240946.231445, idle connection 117507.000000, request 304397.833824
05/11/2026 02:30:27.373 7f831c7cd0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240947.484619, idle connection 117002.000000, request 304398.211241
05/11/2026 02:30:27.373 7f831c7cdc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 812
05/11/2026 02:30:27.373 7f831c7cdc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.373 7f831c7cdc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 812 (602.8814315795898 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=12315375, topics=[])
05/11/2026 02:30:27.374 7f831c7cdc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 12315375 with 0 response partitions (1 implied)
05/11/2026 02:30:27.374 7f831c7cd0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 800
05/11/2026 02:30:27.374 7f831c7cd0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.374 7f831c7cd0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 800 (602.9093265533447 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=836786288, topics=[])
05/11/2026 02:30:27.374 7f831c7cd0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 836786288 with 0 response partitions (1 implied)
05/11/2026 02:30:27.387 7f831c68b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240236.817383, idle connection 117916.000000, request 304398.501873
05/11/2026 02:30:27.388 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 874
05/11/2026 02:30:27.388 7f831c68b4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.388 7f831c68b4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 874 (602.2708415985107 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1668321322, topics=[])
05/11/2026 02:30:27.388 7f831c68b4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1668321322 with 0 response partitions (1 implied)
05/11/2026 02:30:27.445 7f831c7cda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240939.260010, idle connection 117487.000000, request 304397.318602
05/11/2026 02:30:27.446 7f831c7cda40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 816
05/11/2026 02:30:27.446 7f831c7cda40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.446 7f831c7cda40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 816 (603.6298274993896 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=945040578, topics=[])
05/11/2026 02:30:27.446 7f831c7cda40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 945040578 with 0 response partitions (1 implied)
05/11/2026 02:30:27.447 7f831c7cd5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240939.663330, idle connection 116572.000000, request 304396.910906
05/11/2026 02:30:27.447 7f831c7cd5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 803
05/11/2026 02:30:27.447 7f831c7cd5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.447 7f831c7cd5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 803 (603.7325859069824 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=632062475, topics=[])
05/11/2026 02:30:27.447 7f831c7cd5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 632062475 with 0 response partitions (1 implied)
05/11/2026 02:30:27.512 7f831c7cd9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240955.316406, idle connection 116675.000000, request 304394.901991
05/11/2026 02:30:27.512 7f831c7cd9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 811
05/11/2026 02:30:27.513 7f831c7cd9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.513 7f831c7cd9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 811 (605.938196182251 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1107506862, topics=[])
05/11/2026 02:30:27.513 7f831c7cd9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1107506862 with 0 response partitions (1 implied)
05/11/2026 02:30:27.516 7f831c68bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241443.715820, idle connection 117774.000000, request 304393.759251
05/11/2026 02:30:27.516 7f831c68bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 850
05/11/2026 02:30:27.516 7f831c68bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.516 7f831c68bae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 850 (606.8201065063477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=883137347, topics=[])
05/11/2026 02:30:27.517 7f831c68bae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 883137347 with 0 response partitions (1 implied)
05/11/2026 02:30:27.616 7f831c68bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240871.618896, idle connection 117154.000000, request 304398.479700
05/11/2026 02:30:27.617 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 870
05/11/2026 02:30:27.617 7f831c68bb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.617 7f831c68bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 870 (602.2665500640869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=299924601, topics=[])
05/11/2026 02:30:27.617 7f831c68bb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 299924601 with 0 response partitions (1 implied)
05/11/2026 02:30:27.622 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 51
05/11/2026 02:30:27.622 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
05/11/2026 02:30:27.622 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3fbb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
05/11/2026 02:30:27.622 7f831c7cdb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.622 7f831c7cdb80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2049156008, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.623 7f831c7cdb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=2049156008, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.623 7f831c7cdb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240336.611328, idle connection 116459.000000, request 304999.928236
05/11/2026 02:30:27.623 7f831c7cdb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240336.040771, idle connection 116459.000000, request 304999.366045
05/11/2026 02:30:27.699 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 19
05/11/2026 02:30:27.699 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
05/11/2026 02:30:27.699 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab51760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
05/11/2026 02:30:27.699 7f831be94720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.699 7f831be94720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=670978976, session_epoch=801, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.700 7f831be94720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=670978976, session_epoch=801, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.700 7f831be94720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241464.995361, idle connection 117025.000000, request 304999.917507
05/11/2026 02:30:27.700 7f831be94720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241464.395020, idle connection 117024.000000, request 304999.334574
05/11/2026 02:30:27.703 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 75
05/11/2026 02:30:27.704 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
05/11/2026 02:30:27.704 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ac3c640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
05/11/2026 02:30:27.704 7f831c7cd4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.704 7f831c7cd4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=334942729, session_epoch=816, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.704 7f831c7cd4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 821 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=334942729, session_epoch=816, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.704 7f831c7cd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240259.798096, idle connection 116981.000000, request 304999.948740
05/11/2026 02:30:27.705 7f831c7cd4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240259.412598, idle connection 116980.000000, request 304999.564648
05/11/2026 02:30:27.705 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 21
05/11/2026 02:30:27.705 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
05/11/2026 02:30:27.705 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3fbe0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
05/11/2026 02:30:27.705 7f831a655f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.705 7f831a655f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1553695583, session_epoch=803, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.705 7f831a655f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=1553695583, session_epoch=803, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.706 7f831a655f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240283.066406, idle connection 116395.000000, request 304999.939203
05/11/2026 02:30:27.706 7f831a655f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240282.684570, idle connection 116394.000000, request 304999.441385
05/11/2026 02:30:27.721 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44
05/11/2026 02:30:27.721 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
05/11/2026 02:30:27.721 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb9400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
05/11/2026 02:30:27.721 7f831c7cdd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.721 7f831c7cdd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=336313164, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.721 7f831c7cdd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 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=336313164, session_epoch=806, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.722 7f831c7cdd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240297.312988, idle connection 116326.000000, request 304999.924660
05/11/2026 02:30:27.722 7f831c7cdd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240296.822266, idle connection 116326.000000, request 304999.445677
05/11/2026 02:30:27.723 7f831be94b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240808.039795, idle connection 116878.000000, request 304395.270586
05/11/2026 02:30:27.724 7f831be94b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 802
05/11/2026 02:30:27.724 7f831be94b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/11/2026 02:30:27.724 7f831be94b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 802 (605.1974296569824 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1140640769, topics=[])
05/11/2026 02:30:27.724 7f831be94b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1140640769 with 0 response partitions (1 implied)
05/11/2026 02:30:27.771 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 251
05/11/2026 02:30:27.772 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
05/11/2026 02:30:27.772 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831abb9460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
05/11/2026 02:30:27.772 7f831dc6e360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.772 7f831dc6e360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1431797282, session_epoch=849, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.772 7f831dc6e360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 854 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1431797282, session_epoch=849, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.772 7f831dc6e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240626.595703, idle connection 117025.000000, request 304999.938726
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 157
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab3f5b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=129929129, session_epoch=824, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 829 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=129929129, session_epoch=824, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.773 7f831c68b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240820.172852, idle connection 116557.000000, request 304999.961853
05/11/2026 02:30:27.773 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 230
05/11/2026 02:30:27.773 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
05/11/2026 02:30:27.773 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f831ab6f5e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
05/11/2026 02:30:27.773 7f831c68bd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/11/2026 02:30:27.774 7f831c68bd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641577395, session_epoch=836, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.774 7f831c68bd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641577395, session_epoch=836, topics=[], forgotten_topics_data=[])
05/11/2026 02:30:27.774 7f831c68bd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239291.455566, idle connection 117319.000000, request 304999.960423
05/11/2026 02:30:27.774 7f831dc6e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240624.487305, idle connection 117023.000000, request 304997.842789
05/11/2026 02:30:27.775 7f831c68b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240818.361816, idle connection 116555.000000, request 304998.153210
05/11/2026 02:30:27.775 7f831c68bd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239290.178711, idle connection 117318.000000, request 304998.686552