07/06/2026 17:26:21.737 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6834 (602.5500297546387 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349155562, topics=[])
07/06/2026 17:26:21.738 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1349155562 with 0 response partitions (1 implied)
07/06/2026 17:26:21.777 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260756.878418, idle connection 136054.000000, request 304398.050785
07/06/2026 17:26:21.777 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7519
07/06/2026 17:26:21.777 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:21.777 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7519 (602.471113204956 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1219887922, topics=[])
07/06/2026 17:26:21.778 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1219887922 with 0 response partitions (1 implied)
07/06/2026 17:26:21.801 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 263
07/06/2026 17:26:21.801 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
07/06/2026 17:26:21.801 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd75970> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
07/06/2026 17:26:21.801 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:21.801 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=446879189, session_epoch=6819, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:21.802 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 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=446879189, session_epoch=6819, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:21.802 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258451.600830, idle connection 197155.000000, request 304999.938250
07/06/2026 17:26:21.802 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4943
07/06/2026 17:26:21.802 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
07/06/2026 17:26:21.802 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd3b5b0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
07/06/2026 17:26:21.802 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:21.802 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7414, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:21.802 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 7429 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7414, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:21.803 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257740.494385, idle connection 196475.000000, request 304999.956608
07/06/2026 17:26:21.803 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258450.369629, idle connection 197154.000000, request 304998.720407
07/06/2026 17:26:21.803 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257739.770752, idle connection 196474.000000, request 304999.238968
07/06/2026 17:26:22.096 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 351
07/06/2026 17:26:22.096 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
07/06/2026 17:26:22.096 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde080d90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
07/06/2026 17:26:22.096 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:22.096 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6858, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.097 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6878 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6858, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.097 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257235.548828, idle connection 372141.000000, request 304999.935865
07/06/2026 17:26:22.097 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257235.147705, idle connection 372140.000000, request 304999.542952
07/06/2026 17:26:22.097 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256634.724609, idle connection 69288.000000, request 304397.950649
07/06/2026 17:26:22.097 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 459
07/06/2026 17:26:22.098 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
07/06/2026 17:26:22.098 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde6753a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
07/06/2026 17:26:22.098 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:22.098 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6856, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.099 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6861 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6856, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.099 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259644.714844, idle connection 197983.000000, request 304999.950647
07/06/2026 17:26:22.099 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6843
07/06/2026 17:26:22.099 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.099 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6843 (603.9016246795654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2139049738, topics=[])
07/06/2026 17:26:22.099 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2139049738 with 0 response partitions (1 implied)
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 892
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde4746a0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6947, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 6966 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6947, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.100 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255346.101562, idle connection 430718.000000, request 304999.965668
07/06/2026 17:26:22.100 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259643.197021, idle connection 197981.000000, request 304998.435497
07/06/2026 17:26:22.101 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255345.532471, idle connection 430717.000000, request 304999.399185
07/06/2026 17:26:22.190 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 729
07/06/2026 17:26:22.190 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
07/06/2026 17:26:22.190 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde55ca60> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
07/06/2026 17:26:22.190 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:22.191 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6941, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.191 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6952 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6941, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.191 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257748.302490, idle connection 196687.000000, request 304999.945402
07/06/2026 17:26:22.191 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257747.893555, idle connection 196686.000000, request 304999.544621
07/06/2026 17:26:22.303 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258466.246094, idle connection 134832.000000, request 304398.093462
07/06/2026 17:26:22.304 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7379
07/06/2026 17:26:22.304 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.304 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7379 (602.4432182312012 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464566025, topics=[])
07/06/2026 17:26:22.304 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1464566025 with 0 response partitions (1 implied)
07/06/2026 17:26:22.339 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 475
07/06/2026 17:26:22.339 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
07/06/2026 17:26:22.339 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde20b070> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
07/06/2026 17:26:22.339 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:22.339 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349155562, session_epoch=6821, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.339 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6835 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349155562, session_epoch=6821, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.340 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259658.740479, idle connection 198418.000000, request 304999.953270
07/06/2026 17:26:22.340 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259658.357910, idle connection 198417.000000, request 304999.576569
07/06/2026 17:26:22.378 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4436
07/06/2026 17:26:22.378 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
07/06/2026 17:26:22.378 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdd0c8400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
07/06/2026 17:26:22.379 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:22.379 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7508, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.379 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7520 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7508, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.379 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260154.824219, idle connection 135452.000000, request 304999.950886
07/06/2026 17:26:22.379 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260154.312256, idle connection 135451.000000, request 304999.446392
07/06/2026 17:26:22.404 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257848.832764, idle connection 196552.000000, request 304397.175312
07/06/2026 17:26:22.405 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6837
07/06/2026 17:26:22.405 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.405 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6837 (603.3141613006592 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=446879189, topics=[])
07/06/2026 17:26:22.405 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 446879189 with 0 response partitions (1 implied)
07/06/2026 17:26:22.405 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257137.766602, idle connection 195872.000000, request 304397.232533
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7429
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 7429 (603.2009124755859 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1026616079, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=4945, last_stable_offset=4945, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x13O\x00\x00\x01\xfb\x00\x00\x00\x00\x02\x15kj\x7f\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xc6\x03\x00\x00\x00\x88\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1026616079 with 1 response partitions (0 implied)
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 519 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 4943
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4943 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0)
07/06/2026 17:26:22.406 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 4945 (leader epoch 0)
07/06/2026 17:26:22.508 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4945
07/06/2026 17:26:22.508 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
07/06/2026 17:26:22.508 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde2567f0> for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
07/06/2026 17:26:22.508 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:22.508 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7415, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4945, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
07/06/2026 17:26:22.508 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 7430 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7415, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4945, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
07/06/2026 17:26:22.509 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257034.386719, idle connection 195769.000000, request 304999.946117
07/06/2026 17:26:22.509 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257033.977051, idle connection 195768.000000, request 304999.544621
07/06/2026 17:26:22.700 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256632.477051, idle connection 371538.000000, request 304396.863222
07/06/2026 17:26:22.700 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6878
07/06/2026 17:26:22.700 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.700 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6878 (603.69873046875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609241726, topics=[])
07/06/2026 17:26:22.701 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609241726 with 0 response partitions (1 implied)
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 442
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde2251c0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6826, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6844 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6826, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.701 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256030.752441, idle connection 68684.000000, request 304999.927044
07/06/2026 17:26:22.702 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256030.331299, idle connection 68683.000000, request 304999.515772
07/06/2026 17:26:22.702 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259041.521973, idle connection 197380.000000, request 304396.760225
07/06/2026 17:26:22.702 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254744.000977, idle connection 430115.000000, request 304397.867680
07/06/2026 17:26:22.702 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6861
07/06/2026 17:26:22.702 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.703 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6861 (603.7814617156982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=959691841, topics=[])
07/06/2026 17:26:22.703 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 959691841 with 0 response partitions (1 implied)
07/06/2026 17:26:22.703 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6966
07/06/2026 17:26:22.703 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.703 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6966 (602.9834747314453 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=702899083, topics=[])
07/06/2026 17:26:22.703 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 702899083 with 0 response partitions (1 implied)
07/06/2026 17:26:22.792 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257147.330078, idle connection 196086.000000, request 304398.974180
07/06/2026 17:26:22.792 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6952
07/06/2026 17:26:22.792 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.792 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6952 (601.5236377716064 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1639658999, topics=[])
07/06/2026 17:26:22.792 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1639658999 with 0 response partitions (1 implied)
07/06/2026 17:26:22.904 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3445
07/06/2026 17:26:22.905 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
07/06/2026 17:26:22.905 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde231760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
07/06/2026 17:26:22.905 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:22.905 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7364, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.905 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7380 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7364, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:22.905 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257864.339355, idle connection 134230.000000, request 304999.949694
07/06/2026 17:26:22.906 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257863.909912, idle connection 134230.000000, request 304999.527693
07/06/2026 17:26:22.941 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259057.392578, idle connection 197816.000000, request 304398.603916
07/06/2026 17:26:22.941 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6835
07/06/2026 17:26:22.941 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.941 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6835 (601.9184589385986 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349155562, topics=[])
07/06/2026 17:26:22.942 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1349155562 with 0 response partitions (1 implied)
07/06/2026 17:26:22.980 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259553.533691, idle connection 134851.000000, request 304398.659945
07/06/2026 17:26:22.981 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7520
07/06/2026 17:26:22.981 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:22.981 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7520 (601.9461154937744 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1219887922, topics=[])
07/06/2026 17:26:22.981 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1219887922 with 0 response partitions (1 implied)
07/06/2026 17:26:23.006 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 263
07/06/2026 17:26:23.007 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
07/06/2026 17:26:23.007 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde48d5e0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
07/06/2026 17:26:23.007 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:23.007 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=446879189, session_epoch=6820, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.007 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 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=446879189, session_epoch=6820, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.007 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257246.099365, idle connection 195949.000000, request 304999.950886
07/06/2026 17:26:23.008 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257245.690186, idle connection 195949.000000, request 304999.549150
07/06/2026 17:26:23.110 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256433.416016, idle connection 195168.000000, request 304398.974419
07/06/2026 17:26:23.110 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7430
07/06/2026 17:26:23.110 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.110 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 7430 (601.520299911499 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1026616079, topics=[])
07/06/2026 17:26:23.110 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1026616079 with 0 response partitions (1 implied)
07/06/2026 17:26:23.302 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 351
07/06/2026 17:26:23.302 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
07/06/2026 17:26:23.302 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde2965e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
07/06/2026 17:26:23.302 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:23.302 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6859, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.303 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6879 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6859, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.303 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256029.625977, idle connection 370935.000000, request 304999.944210
07/06/2026 17:26:23.303 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256029.226562, idle connection 370934.000000, request 304999.552965
07/06/2026 17:26:23.303 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255428.809326, idle connection 68082.000000, request 304397.994041
07/06/2026 17:26:23.303 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 459
07/06/2026 17:26:23.304 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
07/06/2026 17:26:23.304 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde7e0a60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
07/06/2026 17:26:23.304 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:23.304 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6857, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.304 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6862 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6857, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.304 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258439.506104, idle connection 196778.000000, request 304999.961853
07/06/2026 17:26:23.304 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6844
07/06/2026 17:26:23.304 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.304 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6844 (603.1546592712402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2139049738, topics=[])
07/06/2026 17:26:23.305 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2139049738 with 0 response partitions (1 implied)
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 892
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde296220> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6948, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 6967 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6948, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.305 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254140.896240, idle connection 429512.000000, request 304999.966860
07/06/2026 17:26:23.305 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258438.006104, idle connection 196776.000000, request 304998.465776
07/06/2026 17:26:23.306 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254140.335449, idle connection 429512.000000, request 304999.408007
07/06/2026 17:26:23.394 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 729
07/06/2026 17:26:23.394 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
07/06/2026 17:26:23.394 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdcbced60> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
07/06/2026 17:26:23.394 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:23.394 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6942, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.394 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6953 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6942, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.395 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256544.586670, idle connection 195483.000000, request 304999.941826
07/06/2026 17:26:23.395 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256543.890381, idle connection 195482.000000, request 304999.250889
07/06/2026 17:26:23.507 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257262.995117, idle connection 133629.000000, request 304398.604631
07/06/2026 17:26:23.507 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7380
07/06/2026 17:26:23.507 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.507 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7380 (601.9322872161865 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464566025, topics=[])
07/06/2026 17:26:23.507 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1464566025 with 0 response partitions (1 implied)
07/06/2026 17:26:23.542 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 475
07/06/2026 17:26:23.542 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
07/06/2026 17:26:23.542 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde225400> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
07/06/2026 17:26:23.542 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:23.542 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349155562, session_epoch=6822, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.543 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6836 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349155562, session_epoch=6822, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.543 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258455.593994, idle connection 197215.000000, request 304999.951124
07/06/2026 17:26:23.543 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258455.204346, idle connection 197214.000000, request 304999.568701
07/06/2026 17:26:23.581 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4436
07/06/2026 17:26:23.581 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
07/06/2026 17:26:23.582 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde20b460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
07/06/2026 17:26:23.582 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:23.582 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7509, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.582 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7521 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7509, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.582 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258951.717041, idle connection 134249.000000, request 304999.949932
07/06/2026 17:26:23.582 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258951.279785, idle connection 134248.000000, request 304999.518871
07/06/2026 17:26:23.608 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256645.258789, idle connection 195348.000000, request 304399.111986
07/06/2026 17:26:23.608 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6838
07/06/2026 17:26:23.608 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.609 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6838 (601.3944149017334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=446879189, topics=[])
07/06/2026 17:26:23.609 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 446879189 with 0 response partitions (1 implied)
07/06/2026 17:26:23.711 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4945
07/06/2026 17:26:23.711 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
07/06/2026 17:26:23.711 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd756a0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
07/06/2026 17:26:23.711 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:23.711 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7416, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.712 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 7431 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7416, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.712 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255831.297119, idle connection 194566.000000, request 304999.949217
07/06/2026 17:26:23.712 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255830.864014, idle connection 194565.000000, request 304999.523878
07/06/2026 17:26:23.906 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255425.857910, idle connection 370331.000000, request 304396.170616
07/06/2026 17:26:23.907 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6879
07/06/2026 17:26:23.907 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.907 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6879 (604.515552520752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609241726, topics=[])
07/06/2026 17:26:23.907 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609241726 with 0 response partitions (1 implied)
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 442
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdcbc63a0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6827, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6845 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6827, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:23.908 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254823.944824, idle connection 67477.000000, request 304999.957561
07/06/2026 17:26:23.908 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257835.127930, idle connection 196173.000000, request 304395.585299
07/06/2026 17:26:23.908 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253537.603516, idle connection 428909.000000, request 304396.675587
07/06/2026 17:26:23.909 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6862
07/06/2026 17:26:23.909 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.909 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6862 (604.8283576965332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=959691841, topics=[])
07/06/2026 17:26:23.909 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 959691841 with 0 response partitions (1 implied)
07/06/2026 17:26:23.909 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6967
07/06/2026 17:26:23.909 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.909 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6967 (604.0315628051758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=702899083, topics=[])
07/06/2026 17:26:23.909 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 702899083 with 0 response partitions (1 implied)
07/06/2026 17:26:23.910 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254822.387695, idle connection 67475.000000, request 304998.400927
07/06/2026 17:26:23.996 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255942.880615, idle connection 194881.000000, request 304398.236275
07/06/2026 17:26:23.997 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6953
07/06/2026 17:26:23.997 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:23.997 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6953 (602.2770404815674 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1639658999, topics=[])
07/06/2026 17:26:23.997 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1639658999 with 0 response partitions (1 implied)
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3445
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde296fa0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7365, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7381 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7365, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.108 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256661.168457, idle connection 133027.000000, request 304999.936342
07/06/2026 17:26:24.109 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256660.760742, idle connection 133027.000000, request 304999.538183
07/06/2026 17:26:24.144 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257854.039795, idle connection 196613.000000, request 304398.395777
07/06/2026 17:26:24.145 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6836
07/06/2026 17:26:24.145 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:24.145 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6836 (602.2024154663086 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349155562, topics=[])
07/06/2026 17:26:24.145 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1349155562 with 0 response partitions (1 implied)
07/06/2026 17:26:24.184 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258350.177246, idle connection 133647.000000, request 304398.408175
07/06/2026 17:26:24.184 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7521
07/06/2026 17:26:24.184 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:24.184 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7521 (602.0691394805908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1219887922, topics=[])
07/06/2026 17:26:24.184 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1219887922 with 0 response partitions (1 implied)
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 263
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde2251f0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=446879189, session_epoch=6821, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 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=446879189, session_epoch=6821, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.211 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256041.919434, idle connection 194745.000000, request 304999.932051
07/06/2026 17:26:24.212 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256041.535889, idle connection 194745.000000, request 304999.557018
07/06/2026 17:26:24.313 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255230.349854, idle connection 193965.000000, request 304399.002552
07/06/2026 17:26:24.313 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7431
07/06/2026 17:26:24.313 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:24.313 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 7431 (601.546049118042 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1026616079, topics=[])
07/06/2026 17:26:24.313 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1026616079 with 0 response partitions (1 implied)
07/06/2026 17:26:24.509 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 351
07/06/2026 17:26:24.509 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
07/06/2026 17:26:24.509 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde186610> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
07/06/2026 17:26:24.509 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:24.509 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6860, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.509 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6880 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6860, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.510 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254822.790039, idle connection 369728.000000, request 304999.949217
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 459
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde1b2070> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6858, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6863 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6858, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.510 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257233.294189, idle connection 195572.000000, request 304999.948502
07/06/2026 17:26:24.511 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254821.268799, idle connection 369726.000000, request 304998.434782
07/06/2026 17:26:24.511 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 892
07/06/2026 17:26:24.511 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
07/06/2026 17:26:24.511 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd75490> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
07/06/2026 17:26:24.512 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:24.512 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6949, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.512 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 6968 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6949, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.512 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252934.288574, idle connection 428306.000000, request 304999.965191
07/06/2026 17:26:24.512 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254220.128906, idle connection 66873.000000, request 304396.143913
07/06/2026 17:26:24.512 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257231.261963, idle connection 195570.000000, request 304997.935534
07/06/2026 17:26:24.512 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6845
07/06/2026 17:26:24.513 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:24.513 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6845 (604.5293807983398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2139049738, topics=[])
07/06/2026 17:26:24.513 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2139049738 with 0 response partitions (1 implied)
07/06/2026 17:26:24.513 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252933.029053, idle connection 428305.000000, request 304998.708010
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 729
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde7e0a60> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6943, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6954 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6943, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.598 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255340.706787, idle connection 194279.000000, request 304999.945402
07/06/2026 17:26:24.599 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255340.261475, idle connection 194279.000000, request 304999.506474
07/06/2026 17:26:24.710 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256059.828613, idle connection 132426.000000, request 304398.590565
07/06/2026 17:26:24.710 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7381
07/06/2026 17:26:24.710 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:24.710 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7381 (601.9656658172607 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464566025, topics=[])
07/06/2026 17:26:24.710 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1464566025 with 0 response partitions (1 implied)
07/06/2026 17:26:24.745 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 475
07/06/2026 17:26:24.746 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
07/06/2026 17:26:24.746 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd5d8b0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
07/06/2026 17:26:24.746 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:24.746 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349155562, session_epoch=6823, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.746 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 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=1349155562, session_epoch=6823, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.746 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257252.222900, idle connection 196011.000000, request 304999.947548
07/06/2026 17:26:24.747 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257251.789551, idle connection 196011.000000, request 304999.521732
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4436
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde225700> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7510, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7522 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7510, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.785 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257748.489258, idle connection 133046.000000, request 304999.948978
07/06/2026 17:26:24.786 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257748.084961, idle connection 133045.000000, request 304999.552727
07/06/2026 17:26:24.812 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255441.099121, idle connection 194144.000000, request 304399.112701
07/06/2026 17:26:24.813 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6839
07/06/2026 17:26:24.813 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:24.813 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6839 (601.4056205749512 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=446879189, topics=[])
07/06/2026 17:26:24.813 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 446879189 with 0 response partitions (1 implied)
07/06/2026 17:26:24.915 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4945
07/06/2026 17:26:24.915 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
07/06/2026 17:26:24.915 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdd0c8df0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
07/06/2026 17:26:24.915 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:24.915 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7417, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.915 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 7432 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7417, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:24.916 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254627.393066, idle connection 193362.000000, request 304999.944210
07/06/2026 17:26:24.916 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254626.997559, idle connection 193361.000000, request 304999.557734
07/06/2026 17:26:25.113 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254219.441162, idle connection 369125.000000, request 304396.588802
07/06/2026 17:26:25.114 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6880
07/06/2026 17:26:25.114 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.114 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6880 (604.3078899383545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609241726, topics=[])
07/06/2026 17:26:25.114 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609241726 with 0 response partitions (1 implied)
07/06/2026 17:26:25.114 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 442
07/06/2026 17:26:25.114 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
07/06/2026 17:26:25.114 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdcc586a0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
07/06/2026 17:26:25.114 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:25.115 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6828, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.115 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6846 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6828, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.115 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253617.311523, idle connection 66270.000000, request 304999.947548
07/06/2026 17:26:25.115 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256628.468750, idle connection 194967.000000, request 304395.140409
07/06/2026 17:26:25.115 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252330.937500, idle connection 427702.000000, request 304396.614552
07/06/2026 17:26:25.115 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6863
07/06/2026 17:26:25.115 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.116 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6863 (605.4229736328125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=959691841, topics=[])
07/06/2026 17:26:25.116 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 959691841 with 0 response partitions (1 implied)
07/06/2026 17:26:25.116 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6968
07/06/2026 17:26:25.116 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.116 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6968 (604.302167892456 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=702899083, topics=[])
07/06/2026 17:26:25.116 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 702899083 with 0 response partitions (1 implied)
07/06/2026 17:26:25.117 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253615.532959, idle connection 66268.000000, request 304998.174191
07/06/2026 17:26:25.199 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254739.701172, idle connection 193678.000000, request 304398.940325
07/06/2026 17:26:25.200 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6954
07/06/2026 17:26:25.200 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.200 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6954 (601.6213893890381 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1639658999, topics=[])
07/06/2026 17:26:25.200 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1639658999 with 0 response partitions (1 implied)
07/06/2026 17:26:25.311 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3445
07/06/2026 17:26:25.311 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
07/06/2026 17:26:25.311 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdef90a00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
07/06/2026 17:26:25.311 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:25.311 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7366, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.311 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7382 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7366, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.312 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255457.957275, idle connection 131824.000000, request 304999.949217
07/06/2026 17:26:25.312 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255457.556885, idle connection 131824.000000, request 304999.556780
07/06/2026 17:26:25.347 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256650.943359, idle connection 195410.000000, request 304398.668289
07/06/2026 17:26:25.348 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6837
07/06/2026 17:26:25.348 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.348 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6837 (601.8285751342773 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349155562, topics=[])
07/06/2026 17:26:25.348 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1349155562 with 0 response partitions (1 implied)
07/06/2026 17:26:25.387 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257147.067383, idle connection 132444.000000, request 304398.525715
07/06/2026 17:26:25.387 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7522
07/06/2026 17:26:25.387 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.387 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7522 (601.9845008850098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1219887922, topics=[])
07/06/2026 17:26:25.387 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1219887922 with 0 response partitions (1 implied)
07/06/2026 17:26:25.414 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 263
07/06/2026 17:26:25.414 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
07/06/2026 17:26:25.414 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdd0f7a00> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
07/06/2026 17:26:25.415 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:25.415 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=446879189, session_epoch=6822, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.415 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 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=446879189, session_epoch=6822, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.415 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254838.200439, idle connection 193541.000000, request 304999.930620
07/06/2026 17:26:25.416 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254837.549316, idle connection 193541.000000, request 304999.292135
07/06/2026 17:26:25.517 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254026.437012, idle connection 192761.000000, request 304398.984909
07/06/2026 17:26:25.517 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7432
07/06/2026 17:26:25.517 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.517 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 7432 (601.7749309539795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1026616079, topics=[])
07/06/2026 17:26:25.518 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1026616079 with 0 response partitions (1 implied)
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 351
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdd319520> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6861, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6881 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6861, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.715 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253616.947754, idle connection 368522.000000, request 304999.948978
07/06/2026 17:26:25.716 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253616.530518, idle connection 368522.000000, request 304999.539614
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 459
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdef9e9a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6859, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6864 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6859, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.717 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256026.307617, idle connection 194365.000000, request 304999.963522
07/06/2026 17:26:25.717 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 892
07/06/2026 17:26:25.717 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
07/06/2026 17:26:25.717 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde1b2070> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
07/06/2026 17:26:25.718 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:25.718 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6950, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.718 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 6969 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6950, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.718 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251728.294434, idle connection 427100.000000, request 304999.966145
07/06/2026 17:26:25.718 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256025.415771, idle connection 194364.000000, request 304999.073505
07/06/2026 17:26:25.718 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253013.840332, idle connection 65667.000000, request 304396.482468
07/06/2026 17:26:25.718 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251727.582031, idle connection 427099.000000, request 304999.256372
07/06/2026 17:26:25.719 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6846
07/06/2026 17:26:25.719 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.719 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6846 (604.1600704193115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2139049738, topics=[])
07/06/2026 17:26:25.719 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2139049738 with 0 response partitions (1 implied)
07/06/2026 17:26:25.801 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 729
07/06/2026 17:26:25.801 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
07/06/2026 17:26:25.801 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdcc2dcd0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
07/06/2026 17:26:25.801 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:25.801 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6944, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.801 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6955 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6944, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.802 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254137.562744, idle connection 193076.000000, request 304999.945641
07/06/2026 17:26:25.802 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254137.158936, idle connection 193075.000000, request 304999.552011
07/06/2026 17:26:25.913 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254856.620605, idle connection 131223.000000, request 304398.612976
07/06/2026 17:26:25.913 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7382
07/06/2026 17:26:25.913 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:25.913 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7382 (601.8979549407959 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464566025, topics=[])
07/06/2026 17:26:25.914 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1464566025 with 0 response partitions (1 implied)
07/06/2026 17:26:25.948 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 475
07/06/2026 17:26:25.949 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
07/06/2026 17:26:25.949 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd5d2e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
07/06/2026 17:26:25.949 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:25.949 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349155562, session_epoch=6824, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.949 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 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=1349155562, session_epoch=6824, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.949 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256049.133057, idle connection 194808.000000, request 304999.950647
07/06/2026 17:26:25.950 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256048.731934, idle connection 194808.000000, request 304999.556780
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4436
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd5d820> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7511, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7523 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1219887922, session_epoch=7511, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:25.988 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256545.333496, idle connection 131842.000000, request 304999.950886
07/06/2026 17:26:25.989 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256544.961182, idle connection 131842.000000, request 304999.586105
07/06/2026 17:26:26.016 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254236.986328, idle connection 192940.000000, request 304398.727655
07/06/2026 17:26:26.017 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6840
07/06/2026 17:26:26.017 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.017 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6840 (601.7420291900635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=446879189, topics=[])
07/06/2026 17:26:26.017 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 446879189 with 0 response partitions (1 implied)
07/06/2026 17:26:26.119 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4945
07/06/2026 17:26:26.119 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
07/06/2026 17:26:26.119 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde2965e0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
07/06/2026 17:26:26.119 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:26.119 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7418, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.120 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 7433 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1026616079, session_epoch=7418, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.120 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253423.297363, idle connection 192158.000000, request 304999.945402
07/06/2026 17:26:26.120 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253422.897705, idle connection 192157.000000, request 304999.555588
07/06/2026 17:26:26.316 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253016.030762, idle connection 367921.000000, request 304399.031639
07/06/2026 17:26:26.317 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6881
07/06/2026 17:26:26.317 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.317 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6881 (601.4864444732666 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609241726, topics=[])
07/06/2026 17:26:26.317 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609241726 with 0 response partitions (1 implied)
07/06/2026 17:26:26.319 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255424.710938, idle connection 193763.000000, request 304398.364782
07/06/2026 17:26:26.319 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6864
07/06/2026 17:26:26.319 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.319 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 6864 (601.9530296325684 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=959691841, topics=[])
07/06/2026 17:26:26.319 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 959691841 with 0 response partitions (1 implied)
07/06/2026 17:26:26.319 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 442
07/06/2026 17:26:26.319 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
07/06/2026 17:26:26.320 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdcbaf370> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
07/06/2026 17:26:26.320 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:26.320 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6829, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.320 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6847 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2139049738, session_epoch=6829, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.320 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252412.187256, idle connection 65065.000000, request 304999.960423
07/06/2026 17:26:26.320 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251125.992432, idle connection 426497.000000, request 304397.664547
07/06/2026 17:26:26.320 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6969
07/06/2026 17:26:26.320 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.320 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 6969 (602.6489734649658 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=702899083, topics=[])
07/06/2026 17:26:26.321 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 702899083 with 0 response partitions (1 implied)
07/06/2026 17:26:26.321 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252411.240723, idle connection 65064.000000, request 304999.016047
07/06/2026 17:26:26.402 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253536.642822, idle connection 192475.000000, request 304399.020433
07/06/2026 17:26:26.403 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6955
07/06/2026 17:26:26.403 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.403 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6955 (601.4962196350098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1639658999, topics=[])
07/06/2026 17:26:26.403 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1639658999 with 0 response partitions (1 implied)
07/06/2026 17:26:26.514 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3445
07/06/2026 17:26:26.514 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
07/06/2026 17:26:26.514 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fddd5dd60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
07/06/2026 17:26:26.514 7f0fdc927e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:26.514 7f0fdc927e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7367, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.515 7f0fdc927e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7383 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464566025, session_epoch=7367, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.515 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254254.790039, idle connection 130621.000000, request 304999.946833
07/06/2026 17:26:26.515 7f0fdc927e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254254.393799, idle connection 130620.000000, request 304999.559402
07/06/2026 17:26:26.550 7f0fdd298900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255447.814209, idle connection 194207.000000, request 304398.633718
07/06/2026 17:26:26.551 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6838
07/06/2026 17:26:26.551 7f0fdd298900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.551 7f0fdd298900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6838 (601.8242835998535 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349155562, topics=[])
07/06/2026 17:26:26.551 7f0fdd298900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1349155562 with 0 response partitions (1 implied)
07/06/2026 17:26:26.590 7f0fdf0692c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255943.891846, idle connection 131241.000000, request 304398.501158
07/06/2026 17:26:26.590 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7523
07/06/2026 17:26:26.590 7f0fdf0692c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.591 7f0fdf0692c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7523 (602.2226810455322 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1219887922, topics=[])
07/06/2026 17:26:26.591 7f0fdf0692c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1219887922 with 0 response partitions (1 implied)
07/06/2026 17:26:26.618 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 263
07/06/2026 17:26:26.618 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
07/06/2026 17:26:26.619 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdcc2d8e0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
07/06/2026 17:26:26.619 7f0fdd1c39a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:26.619 7f0fdd1c39a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=446879189, session_epoch=6823, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.619 7f0fdd1c39a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 6841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=446879189, session_epoch=6823, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.619 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253634.295898, idle connection 192337.000000, request 304999.948740
07/06/2026 17:26:26.619 7f0fdd1c39a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253633.889404, idle connection 192337.000000, request 304999.549627
07/06/2026 17:26:26.721 7f0fdc927b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252822.411133, idle connection 191557.000000, request 304399.061441
07/06/2026 17:26:26.721 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7433
07/06/2026 17:26:26.721 7f0fdc927b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.721 7f0fdc927b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 7433 (601.4590263366699 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1026616079, topics=[])
07/06/2026 17:26:26.721 7f0fdc927b80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1026616079 with 0 response partitions (1 implied)
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 351
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde20bc40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6862, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6882 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609241726, session_epoch=6862, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.918 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252413.823730, idle connection 367319.000000, request 304999.948263
07/06/2026 17:26:26.919 7f0fdd2987c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252413.423584, idle connection 367319.000000, request 304999.556541
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 459
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde20bbb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6860, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 6865 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=959691841, session_epoch=6860, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.920 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254823.152344, idle connection 193161.000000, request 304999.952793
07/06/2026 17:26:26.921 7f0fdf0690e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254822.841797, idle connection 193161.000000, request 304999.644995
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 892
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fde20b070> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6951, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 6970 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702899083, session_epoch=6951, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:26.921 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 250524.728516, idle connection 425896.000000, request 304999.965668
07/06/2026 17:26:26.922 7f0fdd298720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 250524.441650, idle connection 425896.000000, request 304999.680281
07/06/2026 17:26:26.922 7f0fdd298cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251810.059814, idle connection 64463.000000, request 304397.831917
07/06/2026 17:26:26.922 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6847
07/06/2026 17:26:26.922 7f0fdd298cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
07/06/2026 17:26:26.922 7f0fdd298cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6847 (602.5731563568115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2139049738, topics=[])
07/06/2026 17:26:26.923 7f0fdd298cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2139049738 with 0 response partitions (1 implied)
07/06/2026 17:26:27.004 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 729
07/06/2026 17:26:27.004 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
07/06/2026 17:26:27.004 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f0fdef908e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
07/06/2026 17:26:27.004 7f0fdd298ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
07/06/2026 17:26:27.004 7f0fdd298ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6945, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:27.005 7f0fdd298ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6956 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639658999, session_epoch=6945, topics=[], forgotten_topics_data=[])
07/06/2026 17:26:27.005 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252934.459717, idle connection 191873.000000, request 304999.948263
07/06/2026 17:26:27.005 7f0fdd298ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252934.065186, idle connection 191872.000000, request 304999.561548