03/09/2026 04:17:43.738 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1803853565, session_epoch=6819, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.739 7ff679f8b180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6837 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1803853565, session_epoch=6819, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.739 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258382.123047, idle connection 197087.000000, request 304999.957085
03/09/2026 04:17:43.739 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 1952
03/09/2026 04:17:43.739 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
03/09/2026 04:17:43.739 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b4490> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
03/09/2026 04:17:43.739 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:43.739 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=566619994, session_epoch=7062, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.740 7ff677885cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7084 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=566619994, session_epoch=7062, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.740 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259869.514893, idle connection 197726.000000, request 304999.966383
03/09/2026 04:17:43.740 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258379.154541, idle connection 197084.000000, request 304996.746302
03/09/2026 04:17:43.741 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258380.594727, idle connection 197086.000000, request 304998.434782
03/09/2026 04:17:43.741 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259868.632324, idle connection 197725.000000, request 304999.088049
03/09/2026 04:17:43.755 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 193
03/09/2026 04:17:43.755 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
03/09/2026 04:17:43.756 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b0e50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
03/09/2026 04:17:43.756 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:43.756 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=130937824, session_epoch=6798, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.756 7ff679f8b400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6824 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=130937824, session_epoch=6798, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.756 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256047.786133, idle connection 432232.000000, request 304999.952555
03/09/2026 04:17:43.756 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256047.434570, idle connection 432232.000000, request 304999.607086
03/09/2026 04:17:43.963 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 476
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b08e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247075688, session_epoch=6827, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6838 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247075688, session_epoch=6827, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260849.806152, idle connection 199366.000000, request 304999.948978
03/09/2026 04:17:43.964 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260849.415771, idle connection 199366.000000, request 304999.567270
03/09/2026 04:17:44.011 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1569
03/09/2026 04:17:44.011 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
03/09/2026 04:17:44.011 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b0160> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
03/09/2026 04:17:44.011 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:44.011 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2073197722, session_epoch=7098, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.012 7ff67971f7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7113 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2073197722, session_epoch=7098, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.012 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264276.093506, idle connection 202706.000000, request 304999.947309
03/09/2026 04:17:44.012 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264275.585449, idle connection 202706.000000, request 304999.447584
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 329
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b04f0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2057722023, session_epoch=6836, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6858 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2057722023, session_epoch=6836, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.166 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259660.350342, idle connection 372238.000000, request 304999.948502
03/09/2026 04:17:44.167 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259659.965332, idle connection 372238.000000, request 304999.570847
03/09/2026 04:17:44.190 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1044
03/09/2026 04:17:44.190 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
03/09/2026 04:17:44.190 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b0910> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
03/09/2026 04:17:44.190 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:44.191 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370366723, session_epoch=6961, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.191 7ff679f8b0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6979 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370366723, session_epoch=6961, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.191 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261375.485596, idle connection 200619.000000, request 304999.951601
03/09/2026 04:17:44.191 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261375.095215, idle connection 200618.000000, request 304999.567986
03/09/2026 04:17:44.342 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257777.509033, idle connection 196482.000000, request 304395.090342
03/09/2026 04:17:44.342 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6777
03/09/2026 04:17:44.342 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.342 7ff679f8b720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6777 (605.4418087005615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=532089858, topics=[])
03/09/2026 04:17:44.343 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 532089858 with 0 response partitions (1 implied)
03/09/2026 04:17:44.343 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257778.299316, idle connection 196483.000000, request 304396.136284
03/09/2026 04:17:44.343 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259266.430420, idle connection 197123.000000, request 304396.884441
03/09/2026 04:17:44.343 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6837
03/09/2026 04:17:44.343 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.343 7ff679f8b180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6837 (604.3586730957031 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1803853565, topics=[])
03/09/2026 04:17:44.343 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1803853565 with 0 response partitions (1 implied)
03/09/2026 04:17:44.344 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7084
03/09/2026 04:17:44.344 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.344 7ff677885cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7084 (604.0012836456299 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=566619994, topics=[])
03/09/2026 04:17:44.344 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 566619994 with 0 response partitions (1 implied)
03/09/2026 04:17:44.357 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255446.564697, idle connection 431631.000000, request 304398.728132
03/09/2026 04:17:44.358 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6824
03/09/2026 04:17:44.358 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.358 7ff679f8b400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6824 (601.7360687255859 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=130937824, topics=[])
03/09/2026 04:17:44.358 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 130937824 with 0 response partitions (1 implied)
03/09/2026 04:17:44.566 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260247.979492, idle connection 198764.000000, request 304398.122787
03/09/2026 04:17:44.566 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6838
03/09/2026 04:17:44.566 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.567 7ff678c290e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6838 (602.5519371032715 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=247075688, topics=[])
03/09/2026 04:17:44.567 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 247075688 with 0 response partitions (1 implied)
03/09/2026 04:17:44.614 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263674.234131, idle connection 202104.000000, request 304398.087978
03/09/2026 04:17:44.614 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7113
03/09/2026 04:17:44.614 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.614 7ff67971f7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7113 (602.4308204650879 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2073197722, topics=[])
03/09/2026 04:17:44.614 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2073197722 with 0 response partitions (1 implied)
03/09/2026 04:17:44.767 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259059.448730, idle connection 371637.000000, request 304399.038315
03/09/2026 04:17:44.768 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6858
03/09/2026 04:17:44.768 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.768 7ff679f8b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6858 (601.5028953552246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2057722023, topics=[])
03/09/2026 04:17:44.768 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2057722023 with 0 response partitions (1 implied)
03/09/2026 04:17:44.792 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260774.566406, idle connection 200018.000000, request 304399.029970
03/09/2026 04:17:44.792 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6979
03/09/2026 04:17:44.792 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:44.792 7ff679f8b0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6979 (601.4916896820068 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=370366723, topics=[])
03/09/2026 04:17:44.792 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 370366723 with 0 response partitions (1 implied)
03/09/2026 04:17:44.944 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
03/09/2026 04:17:44.944 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
03/09/2026 04:17:44.945 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b02b0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
03/09/2026 04:17:44.945 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:44.945 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=532089858, session_epoch=6758, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.945 7ff679f8b720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6778 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=532089858, session_epoch=6758, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.945 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257174.426270, idle connection 195879.000000, request 304999.948025
03/09/2026 04:17:44.945 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 270
03/09/2026 04:17:44.945 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
03/09/2026 04:17:44.945 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b0d00> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
03/09/2026 04:17:44.945 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:44.946 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1803853565, session_epoch=6820, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.946 7ff679f8b180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6838 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1803853565, session_epoch=6820, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.946 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257175.419189, idle connection 195881.000000, request 304999.966860
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 1952
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b09d0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=566619994, session_epoch=7063, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7085 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=566619994, session_epoch=7063, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.946 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258663.126709, idle connection 196520.000000, request 304999.967098
03/09/2026 04:17:44.947 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257172.770264, idle connection 195877.000000, request 304998.299837
03/09/2026 04:17:44.947 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257174.185303, idle connection 195879.000000, request 304998.736143
03/09/2026 04:17:44.947 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258662.254883, idle connection 196519.000000, request 304999.098539
03/09/2026 04:17:44.960 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 193
03/09/2026 04:17:44.960 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
03/09/2026 04:17:44.960 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b0a00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
03/09/2026 04:17:44.960 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:44.961 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=130937824, session_epoch=6799, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.961 7ff679f8b400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6825 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=130937824, session_epoch=6799, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:44.961 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254842.446045, idle connection 431027.000000, request 304999.942064
03/09/2026 04:17:44.962 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254842.052979, idle connection 431026.000000, request 304999.558210
03/09/2026 04:17:45.169 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 476
03/09/2026 04:17:45.169 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
03/09/2026 04:17:45.169 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff678709640> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
03/09/2026 04:17:45.169 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:45.169 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247075688, session_epoch=6828, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.169 7ff678c290e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6839 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247075688, session_epoch=6828, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.170 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259644.348145, idle connection 198161.000000, request 304999.949455
03/09/2026 04:17:45.170 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259643.937256, idle connection 198160.000000, request 304999.546766
03/09/2026 04:17:45.215 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1569
03/09/2026 04:17:45.216 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
03/09/2026 04:17:45.216 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff678168340> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
03/09/2026 04:17:45.216 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:45.216 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2073197722, session_epoch=7099, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.216 7ff67971f7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7114 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2073197722, session_epoch=7099, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.216 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263071.640625, idle connection 201502.000000, request 304999.948025
03/09/2026 04:17:45.217 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263071.200684, idle connection 201501.000000, request 304999.517679
03/09/2026 04:17:45.369 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 329
03/09/2026 04:17:45.370 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
03/09/2026 04:17:45.370 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff67817ed30> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
03/09/2026 04:17:45.370 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:45.370 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2057722023, session_epoch=6837, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.370 7ff679f8b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6859 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2057722023, session_epoch=6837, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.370 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258456.469727, idle connection 371034.000000, request 304999.948263
03/09/2026 04:17:45.371 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258456.051758, idle connection 371034.000000, request 304999.539375
03/09/2026 04:17:45.394 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1044
03/09/2026 04:17:45.394 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
03/09/2026 04:17:45.394 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff678168e80> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
03/09/2026 04:17:45.394 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:45.395 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370366723, session_epoch=6962, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.395 7ff679f8b0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6980 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370366723, session_epoch=6962, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:45.395 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260171.499268, idle connection 199415.000000, request 304999.950647
03/09/2026 04:17:45.395 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260171.103760, idle connection 199414.000000, request 304999.562263
03/09/2026 04:17:45.548 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256571.146973, idle connection 195276.000000, request 304396.667480
03/09/2026 04:17:45.549 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6778
03/09/2026 04:17:45.549 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.549 7ff679f8b720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6778 (603.8994789123535 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=532089858, topics=[])
03/09/2026 04:17:45.549 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 532089858 with 0 response partitions (1 implied)
03/09/2026 04:17:45.549 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256571.888428, idle connection 195277.000000, request 304396.436214
03/09/2026 04:17:45.549 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258060.041260, idle connection 195916.000000, request 304396.883965
03/09/2026 04:17:45.550 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6838
03/09/2026 04:17:45.550 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.550 7ff679f8b180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6838 (604.001522064209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1803853565, topics=[])
03/09/2026 04:17:45.550 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1803853565 with 0 response partitions (1 implied)
03/09/2026 04:17:45.550 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7085
03/09/2026 04:17:45.550 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.550 7ff677885cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7085 (603.8534641265869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=566619994, topics=[])
03/09/2026 04:17:45.550 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 566619994 with 0 response partitions (1 implied)
03/09/2026 04:17:45.563 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254241.179199, idle connection 430425.000000, request 304398.678303
03/09/2026 04:17:45.563 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6825
03/09/2026 04:17:45.563 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.563 7ff679f8b400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6825 (601.759672164917 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=130937824, topics=[])
03/09/2026 04:17:45.563 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 130937824 with 0 response partitions (1 implied)
03/09/2026 04:17:45.771 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259042.661377, idle connection 197559.000000, request 304398.263216
03/09/2026 04:17:45.772 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6839
03/09/2026 04:17:45.772 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.772 7ff678c290e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6839 (602.2570133209229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=247075688, topics=[])
03/09/2026 04:17:45.772 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 247075688 with 0 response partitions (1 implied)
03/09/2026 04:17:45.817 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262470.359131, idle connection 200901.000000, request 304398.668766
03/09/2026 04:17:45.818 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7114
03/09/2026 04:17:45.818 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.818 7ff67971f7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7114 (601.8252372741699 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2073197722, topics=[])
03/09/2026 04:17:45.818 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2073197722 with 0 response partitions (1 implied)
03/09/2026 04:17:45.971 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257855.498535, idle connection 370433.000000, request 304398.976326
03/09/2026 04:17:45.972 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6859
03/09/2026 04:17:45.972 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.972 7ff679f8b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6859 (601.5429496765137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2057722023, topics=[])
03/09/2026 04:17:45.972 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2057722023 with 0 response partitions (1 implied)
03/09/2026 04:17:45.996 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259570.440918, idle connection 198814.000000, request 304398.883343
03/09/2026 04:17:45.996 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6980
03/09/2026 04:17:45.996 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:45.996 7ff679f8b0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6980 (601.7317771911621 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=370366723, topics=[])
03/09/2026 04:17:45.997 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 370366723 with 0 response partitions (1 implied)
03/09/2026 04:17:46.151 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
03/09/2026 04:17:46.151 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
03/09/2026 04:17:46.151 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff678168eb0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
03/09/2026 04:17:46.151 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:46.151 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=532089858, session_epoch=6759, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.152 7ff679f8b720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6779 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=532089858, session_epoch=6759, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.152 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255967.736328, idle connection 194672.000000, request 304999.929667
03/09/2026 04:17:46.152 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 270
03/09/2026 04:17:46.152 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
03/09/2026 04:17:46.152 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff67813a1c0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
03/09/2026 04:17:46.152 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:46.152 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1803853565, session_epoch=6821, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.153 7ff679f8b180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6839 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1803853565, session_epoch=6821, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.153 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255968.428711, idle connection 194674.000000, request 304999.945879
03/09/2026 04:17:46.153 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 1952
03/09/2026 04:17:46.153 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
03/09/2026 04:17:46.153 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff678168160> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
03/09/2026 04:17:46.153 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:46.153 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=566619994, session_epoch=7064, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.153 7ff677885cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7086 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=566619994, session_epoch=7064, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.154 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257455.811523, idle connection 195312.000000, request 304999.948740
03/09/2026 04:17:46.154 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255965.281494, idle connection 194670.000000, request 304997.487307
03/09/2026 04:17:46.155 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255966.573975, idle connection 194672.000000, request 304998.097420
03/09/2026 04:17:46.155 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257454.501953, idle connection 195311.000000, request 304998.643398
03/09/2026 04:17:46.165 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 193
03/09/2026 04:17:46.165 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
03/09/2026 04:17:46.165 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff67813d340> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
03/09/2026 04:17:46.165 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:46.165 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=130937824, session_epoch=6800, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.165 7ff679f8b400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6826 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=130937824, session_epoch=6800, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.166 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253638.221924, idle connection 429822.000000, request 304999.933481
03/09/2026 04:17:46.166 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253637.743652, idle connection 429822.000000, request 304999.464273
03/09/2026 04:17:46.373 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 476
03/09/2026 04:17:46.373 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
03/09/2026 04:17:46.374 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6780b0a00> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
03/09/2026 04:17:46.374 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:46.374 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247075688, session_epoch=6829, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.374 7ff678c290e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6840 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247075688, session_epoch=6829, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.374 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258439.923584, idle connection 196956.000000, request 304999.941587
03/09/2026 04:17:46.375 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258439.045654, idle connection 196956.000000, request 304999.073744
03/09/2026 04:17:46.419 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1569
03/09/2026 04:17:46.420 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
03/09/2026 04:17:46.420 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff67813ad00> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
03/09/2026 04:17:46.420 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:46.420 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2073197722, session_epoch=7100, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.420 7ff67971f7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7115 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2073197722, session_epoch=7100, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.420 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261867.626709, idle connection 200298.000000, request 304999.951124
03/09/2026 04:17:46.421 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261867.195068, idle connection 200297.000000, request 304999.526978
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 329
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff678168340> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2057722023, session_epoch=6838, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6860 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2057722023, session_epoch=6838, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.574 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257252.320068, idle connection 369830.000000, request 304999.948740
03/09/2026 04:17:46.575 7ff679f8b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257251.844238, idle connection 369829.000000, request 304999.481201
03/09/2026 04:17:46.598 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1044
03/09/2026 04:17:46.598 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
03/09/2026 04:17:46.599 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff6781e8850> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
03/09/2026 04:17:46.599 7ff679f8b0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:46.599 7ff679f8b0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370366723, session_epoch=6963, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.599 7ff679f8b0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6981 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370366723, session_epoch=6963, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:46.599 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258967.258057, idle connection 198211.000000, request 304999.946594
03/09/2026 04:17:46.599 7ff679f8b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258966.857666, idle connection 198210.000000, request 304999.554634
03/09/2026 04:17:46.756 7ff679f8b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255363.648193, idle connection 194068.000000, request 304395.843744
03/09/2026 04:17:46.756 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6779
03/09/2026 04:17:46.756 7ff679f8b720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:46.757 7ff679f8b720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6779 (604.8991680145264 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=532089858, topics=[])
03/09/2026 04:17:46.757 7ff679f8b720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 532089858 with 0 response partitions (1 implied)
03/09/2026 04:17:46.757 7ff679f8b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255364.072754, idle connection 194069.000000, request 304395.591497
03/09/2026 04:17:46.757 7ff677885cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256852.144287, idle connection 194709.000000, request 304396.283865
03/09/2026 04:17:46.758 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6839
03/09/2026 04:17:46.758 7ff679f8b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:46.758 7ff679f8b180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6839 (605.0910949707031 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1803853565, topics=[])
03/09/2026 04:17:46.758 7ff679f8b180 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1803853565 with 0 response partitions (1 implied)
03/09/2026 04:17:46.758 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7086
03/09/2026 04:17:46.758 7ff677885cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:46.758 7ff677885cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7086 (604.8665046691895 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=566619994, topics=[])
03/09/2026 04:17:46.759 7ff677885cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 566619994 with 0 response partitions (1 implied)
03/09/2026 04:17:46.767 7ff679f8b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253036.660400, idle connection 429221.000000, request 304398.374081
03/09/2026 04:17:46.768 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6826
03/09/2026 04:17:46.768 7ff679f8b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:46.768 7ff679f8b400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6826 (602.2934913635254 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=130937824, topics=[])
03/09/2026 04:17:46.768 7ff679f8b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 130937824 with 0 response partitions (1 implied)
03/09/2026 04:17:46.976 7ff678c290e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257837.578369, idle connection 196354.000000, request 304397.601843
03/09/2026 04:17:46.977 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6840
03/09/2026 04:17:46.977 7ff678c290e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:46.977 7ff678c290e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6840 (602.9484272003174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=247075688, topics=[])
03/09/2026 04:17:46.977 7ff678c290e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 247075688 with 0 response partitions (1 implied)
03/09/2026 04:17:47.022 7ff67971f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261266.234375, idle connection 199696.000000, request 304398.558617
03/09/2026 04:17:47.022 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7115
03/09/2026 04:17:47.022 7ff67971f7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:47.022 7ff67971f7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7115 (601.940393447876 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2073197722, topics=[])
03/09/2026 04:17:47.022 7ff67971f7c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2073197722 with 0 response partitions (1 implied)