03/09/2026 04:17:00.133 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5559.660156, idle connection 245557.000000, request 304999.311209
03/09/2026 04:17:00.231 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2261.708740, idle connection 242260.000000, request 304398.020029
03/09/2026 04:17:00.231 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6840
03/09/2026 04:17:00.231 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.232 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6840 (602.9279232025146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:00.232 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:00.269 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1409.963135, idle connection 116570.000000, request 304398.157120
03/09/2026 04:17:00.269 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7512
03/09/2026 04:17:00.269 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.270 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7512 (602.6270389556885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[])
03/09/2026 04:17:00.270 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 0 response partitions (1 implied)
03/09/2026 04:17:00.296 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1478
03/09/2026 04:17:00.297 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:00.297 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be90a90> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:00.297 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:00.297 7ff46c425e00 [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=1226254613, session_epoch=6974, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.297 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6990 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6974, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.298 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1509.150635, idle connection 480650.000000, request 304999.937773
03/09/2026 04:17:00.298 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1508.674316, idle connection 480649.000000, request 304999.471188
03/09/2026 04:17:00.301 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:00.302 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:00.302 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be371f0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:00.302 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:00.302 7ff46ced7860 [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=1397803103, session_epoch=7186, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.302 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7200 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7186, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.303 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6729.717285, idle connection 246727.000000, request 304999.921560
03/09/2026 04:17:00.303 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6729.106201, idle connection 246727.000000, request 304999.318838
03/09/2026 04:17:00.397 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 372.134033, idle connection 417888.000000, request 304398.245811
03/09/2026 04:17:00.398 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7322
03/09/2026 04:17:00.398 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.398 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7322 (602.3430824279785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[])
03/09/2026 04:17:00.398 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 0 response partitions (1 implied)
03/09/2026 04:17:00.496 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:00.496 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:00.496 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be5b2b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:00.496 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:00.496 7ff46c425cc0 [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=426809941, session_epoch=6806, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.497 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6806, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.497 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 797.176270, idle connection 240795.000000, request 304999.948025
03/09/2026 04:17:00.497 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 796.682861, idle connection 240794.000000, request 304999.462366
03/09/2026 04:17:00.542 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:00.542 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:00.542 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be291f0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:00.542 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:00.542 7ff46b090c20 [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=671034879, session_epoch=6799, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.543 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6816 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6799, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.543 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3356.626953, idle connection 243353.000000, request 304999.942064
03/09/2026 04:17:00.543 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3356.136719, idle connection 243353.000000, request 304999.461651
03/09/2026 04:17:00.694 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72.416992, idle connection 177430.000000, request 304398.689508
03/09/2026 04:17:00.694 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6827
03/09/2026 04:17:00.694 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.695 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6827 (602.0181179046631 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:00.695 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:00.734 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4958.138672, idle connection 244956.000000, request 304397.783518
03/09/2026 04:17:00.735 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6816
03/09/2026 04:17:00.735 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.735 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6816 (602.7297973632812 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:00.735 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)
03/09/2026 04:17:00.832 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 441
03/09/2026 04:17:00.833 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
03/09/2026 04:17:00.833 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be39820> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
03/09/2026 04:17:00.833 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:00.833 7ff46c425b80 [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=1008506252, session_epoch=6826, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.833 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008506252, session_epoch=6826, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.833 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1659.088867, idle connection 241657.000000, request 304999.935627
03/09/2026 04:17:00.834 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1658.556152, idle connection 241656.000000, request 304999.416590
03/09/2026 04:17:00.870 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3380
03/09/2026 04:17:00.871 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:00.871 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be8df10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:00.871 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:00.871 7ff46ced7360 [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=1065290795, session_epoch=7498, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.871 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7513 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7498, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:00.871 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 807.672607, idle connection 115968.000000, request 304999.946356
03/09/2026 04:17:00.872 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 807.052246, idle connection 115967.000000, request 304999.334097
03/09/2026 04:17:00.899 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 907.207031, idle connection 480048.000000, request 304397.991419
03/09/2026 04:17:00.900 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6990
03/09/2026 04:17:00.900 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.900 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6990 (602.7655601501465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1226254613, topics=[])
03/09/2026 04:17:00.900 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1226254613 with 0 response partitions (1 implied)
03/09/2026 04:17:00.905 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6127.695801, idle connection 246125.000000, request 304397.908688
03/09/2026 04:17:00.905 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7200
03/09/2026 04:17:00.905 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:00.905 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7200 (602.5640964508057 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1397803103, topics=[])
03/09/2026 04:17:00.905 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1397803103 with 0 response partitions (1 implied)
03/09/2026 04:17:00.999 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:00.999 7ff46ced7680 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-28'], allow_auto_topic_creation=True) to node 3
03/09/2026 04:17:00.999 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-28'], allow_auto_topic_creation=True)
03/09/2026 04:17:00.999 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7323 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-28'], allow_auto_topic_creation=True)
03/09/2026 04:17:01.000 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 417285.000000, request 304999.963284
03/09/2026 04:17:01.098 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 196.091553, idle connection 240194.000000, request 304398.862362
03/09/2026 04:17:01.098 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6822
03/09/2026 04:17:01.098 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:01.098 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6822 (601.7289161682129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426809941, topics=[])
03/09/2026 04:17:01.099 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426809941 with 0 response partitions (1 implied)
03/09/2026 04:17:01.144 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2755.588867, idle connection 242752.000000, request 304398.904085
03/09/2026 04:17:01.144 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6816
03/09/2026 04:17:01.144 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:01.145 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6816 (601.7274856567383 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=671034879, topics=[])
03/09/2026 04:17:01.145 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 671034879 with 0 response partitions (1 implied)
03/09/2026 04:17:01.297 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:01.297 7ff46c425a40 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-19'], allow_auto_topic_creation=True) to node 2
03/09/2026 04:17:01.297 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-19'], allow_auto_topic_creation=True)
03/09/2026 04:17:01.297 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6828 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-19'], allow_auto_topic_creation=True)
03/09/2026 04:17:01.297 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 176827.000000, request 304999.973774
03/09/2026 04:17:01.338 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
03/09/2026 04:17:01.338 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/09/2026 04:17:01.338 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be922e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/09/2026 04:17:01.338 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:01.338 7ff46c425f40 [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=553538520, session_epoch=6803, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.338 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6817 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=553538520, session_epoch=6803, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.338 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4353.953369, idle connection 244351.000000, request 304999.946117
03/09/2026 04:17:01.339 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4353.520020, idle connection 244351.000000, request 304999.521017
03/09/2026 04:17:01.435 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1057.435791, idle connection 241055.000000, request 304398.288488
03/09/2026 04:17:01.435 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6841
03/09/2026 04:17:01.435 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:01.435 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6841 (602.2958755493164 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:01.436 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:01.473 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205.702148, idle connection 115366.000000, request 304397.974014
03/09/2026 04:17:01.474 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7513
03/09/2026 04:17:01.474 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:01.474 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7513 (602.6227474212646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[])
03/09/2026 04:17:01.474 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 0 response partitions (1 implied)
03/09/2026 04:17:01.501 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1478
03/09/2026 04:17:01.501 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:01.502 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c618b20> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:01.502 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:01.502 7ff46c425e00 [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=1226254613, session_epoch=6975, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.502 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6991 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6975, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.503 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 304.086914, idle connection 479445.000000, request 304999.933720
03/09/2026 04:17:01.503 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 303.593262, idle connection 479444.000000, request 304999.454975
03/09/2026 04:17:01.507 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:01.507 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:01.507 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be90df0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:01.507 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:01.507 7ff46ced7860 [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=1397803103, session_epoch=7187, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.507 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7201 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7187, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.507 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5525.130615, idle connection 245523.000000, request 304999.954224
03/09/2026 04:17:01.508 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5524.629395, idle connection 245522.000000, request 304999.457598
03/09/2026 04:17:01.602 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:01.602 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 416683.000000, request 304397.912025
03/09/2026 04:17:01.603 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7323
03/09/2026 04:17:01.603 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:01.603 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7323 (603.0778884887695 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-28', is_internal=False, partitions=[(error_code=0, partition=0, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=5, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=10, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=20, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=15, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=25, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=26, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=9, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=11, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=4, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=16, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=17, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=3, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=24, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=23, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=13, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=28, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=18, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=22, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=8, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=2, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=12, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=29, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=19, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=14, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=1, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=6, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=7, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=21, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=27, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[])])])
03/09/2026 04:17:01.604 7ff46ced7680 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:01.700 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:01.701 7ff46c425cc0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-9'], allow_auto_topic_creation=True) to node 1
03/09/2026 04:17:01.701 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-9'], allow_auto_topic_creation=True)
03/09/2026 04:17:01.701 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6823 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-9'], allow_auto_topic_creation=True)
03/09/2026 04:17:01.701 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239590.000000, request 304999.961853
03/09/2026 04:17:01.746 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:01.746 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:01.747 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda2e20> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:01.747 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:01.747 7ff46b090c20 [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=671034879, session_epoch=6800, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.747 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6817 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6800, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:01.747 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2152.227051, idle connection 242149.000000, request 304999.922276
03/09/2026 04:17:01.748 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2151.754150, idle connection 242148.000000, request 304999.466419
03/09/2026 04:17:01.898 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:01.899 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 176226.000000, request 304398.912668
03/09/2026 04:17:01.899 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6828
03/09/2026 04:17:01.899 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:01.900 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6828 (602.6074886322021 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-19', is_internal=False, partitions=[(error_code=0, partition=0, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=5, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=10, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=20, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=15, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=25, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=26, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=9, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=11, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=4, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=16, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=17, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=3, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=24, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=23, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=13, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=28, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=18, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=22, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=8, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=2, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=12, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=29, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=19, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=14, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=1, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=6, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=7, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=21, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=27, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[])])])
03/09/2026 04:17:01.901 7ff46c425a40 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:01.939 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3752.977295, idle connection 243750.000000, request 304398.968458
03/09/2026 04:17:01.940 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6817
03/09/2026 04:17:01.940 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:01.940 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6817 (601.585865020752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:01.940 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)
03/09/2026 04:17:02.036 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 441
03/09/2026 04:17:02.037 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
03/09/2026 04:17:02.037 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be90820> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
03/09/2026 04:17:02.037 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:02.037 7ff46c425b80 [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=1008506252, session_epoch=6827, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.037 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6842 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008506252, session_epoch=6827, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.037 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 455.127930, idle connection 240453.000000, request 304999.946833
03/09/2026 04:17:02.038 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 454.727051, idle connection 240453.000000, request 304999.553919
03/09/2026 04:17:02.075 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:02.075 7ff46ced7360 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-25'], allow_auto_topic_creation=True) to node 1
03/09/2026 04:17:02.075 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-25'], allow_auto_topic_creation=True)
03/09/2026 04:17:02.075 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7514 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-25'], allow_auto_topic_creation=True)
03/09/2026 04:17:02.075 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 114764.000000, request 304999.974489
03/09/2026 04:17:02.105 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:02.105 7ff46c425e00 [kafka.client] [DEBUG]: Initializing connection to node 1 for metadata request
03/09/2026 04:17:02.105 7ff46c425e00 [kafka.client] [DEBUG]: Initiating connection to node 1 at 10.0.0.22:9092
03/09/2026 04:17:02.106 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connecting> [IPv4 None]>: creating new socket
03/09/2026 04:17:02.106 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connecting> [IPv4 ('10.0.0.22', 9092)]>: setting socket option (6, 1, 1)
03/09/2026 04:17:02.106 7ff46c425e00 [kafka.conn] [INFO]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connecting> [IPv4 ('10.0.0.22', 9092)]>: connecting to 10.0.0.22:9092 [('10.0.0.22', 9092) IPv4]
03/09/2026 04:17:02.106 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata inf, idle connection 478841.000000, request 304396.127701
03/09/2026 04:17:02.107 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6991
03/09/2026 04:17:02.107 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:02.107 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6991 (604.2990684509277 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1226254613, topics=[])
03/09/2026 04:17:02.107 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1226254613 with 0 response partitions (1 implied)
03/09/2026 04:17:02.109 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4923.227783, idle connection 244921.000000, request 304398.052216
03/09/2026 04:17:02.109 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7201
03/09/2026 04:17:02.109 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:02.109 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7201 (602.2939682006836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1397803103, topics=[])
03/09/2026 04:17:02.110 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1397803103 with 0 response partitions (1 implied)
03/09/2026 04:17:02.205 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4553
03/09/2026 04:17:02.205 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:02.205 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be5b460> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:02.205 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:02.206 7ff46ced7680 [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=1109539399, session_epoch=7307, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.206 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7324 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7307, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.206 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.640869, idle connection 416079.000000, request 304999.953985
03/09/2026 04:17:02.206 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.231934, idle connection 416079.000000, request 304999.553680
03/09/2026 04:17:02.302 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:02.302 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 238989.000000, request 304398.520708
03/09/2026 04:17:02.303 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6823
03/09/2026 04:17:02.303 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:02.303 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6823 (602.4065017700195 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-9', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=5, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=10, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=20, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=15, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=25, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=26, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=9, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=11, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=4, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=16, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=17, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=3, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=24, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=23, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=13, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=28, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=18, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=22, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=8, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=2, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=12, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=29, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=19, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=14, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=1, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=6, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=7, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=21, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=27, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[])])])
03/09/2026 04:17:02.304 7ff46c425cc0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:02.348 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1551.221924, idle connection 241548.000000, request 304398.924828
03/09/2026 04:17:02.349 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6817
03/09/2026 04:17:02.349 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:02.349 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6817 (601.6051769256592 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=671034879, topics=[])
03/09/2026 04:17:02.349 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 671034879 with 0 response partitions (1 implied)
03/09/2026 04:17:02.503 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 550
03/09/2026 04:17:02.503 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/09/2026 04:17:02.503 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be7f160> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/09/2026 04:17:02.503 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:02.503 7ff46c425a40 [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=969738151, session_epoch=6806, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.503 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6829 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=969738151, session_epoch=6806, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.503 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.720215, idle connection 175621.000000, request 304999.951363
03/09/2026 04:17:02.504 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.317139, idle connection 175620.000000, request 304999.558210
03/09/2026 04:17:02.542 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
03/09/2026 04:17:02.542 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/09/2026 04:17:02.542 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda28b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/09/2026 04:17:02.542 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:02.542 7ff46c425f40 [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=553538520, session_epoch=6804, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.542 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6818 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=553538520, session_epoch=6804, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.542 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3150.011230, idle connection 243147.000000, request 304999.939919
03/09/2026 04:17:02.543 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3149.361816, idle connection 243147.000000, request 304999.291658
03/09/2026 04:17:02.638 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:02.638 7ff46c425b80 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-7'], allow_auto_topic_creation=True) to node 1
03/09/2026 04:17:02.638 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-7'], allow_auto_topic_creation=True)
03/09/2026 04:17:02.639 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 3 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-7'], allow_auto_topic_creation=True)
03/09/2026 04:17:02.639 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239851.000000, request 304398.498774
03/09/2026 04:17:02.639 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6842
03/09/2026 04:17:02.639 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:02.639 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6842 (601.9887924194336 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:02.639 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:02.677 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:02.677 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 114162.000000, request 304398.271322
03/09/2026 04:17:02.677 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7514
03/09/2026 04:17:02.677 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:02.678 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7514 (602.637529373169 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-25', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=5, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=10, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=20, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=15, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=25, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=26, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=9, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=11, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=16, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=4, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=17, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=3, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=24, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=23, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=28, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=13, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=18, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=22, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=8, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=2, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=12, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=29, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=19, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=14, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=1, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=6, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=7, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=27, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=21, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[])])])
03/09/2026 04:17:02.679 7ff46ced7360 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:02.707 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-24'], allow_auto_topic_creation=True) to node 2
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-24'], allow_auto_topic_creation=True)
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6992 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-24'], allow_auto_topic_creation=True)
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 478239.000000, request 304999.975204
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connecting> [IPv4 ('10.0.0.22', 9092)]>: established TCP connection
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <checking_api_versions_send> [IPv4 ('10.0.0.22', 9092)]>: checking broker Api Versions
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <checking_api_versions_send> [IPv4 ('10.0.0.22', 9092)]>: Using pre-configured api_version (2, 6) for ApiVersions
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.conn] [INFO]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Connection complete.
03/09/2026 04:17:02.708 7ff46c425e00 [kafka.client] [DEBUG]: Node 1 connected
03/09/2026 04:17:02.710 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:02.710 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:02.710 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda2310> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:02.710 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:02.710 7ff46ced7860 [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=1397803103, session_epoch=7188, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.710 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7202 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7188, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.710 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4321.941406, idle connection 244320.000000, request 304999.957800
03/09/2026 04:17:02.711 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4321.598145, idle connection 244319.000000, request 304999.617815
03/09/2026 04:17:02.807 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298797.757568, idle connection 415478.000000, request 304399.065018
03/09/2026 04:17:02.807 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7324
03/09/2026 04:17:02.807 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:02.808 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7324 (601.7804145812988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[])
03/09/2026 04:17:02.808 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 0 response partitions (1 implied)
03/09/2026 04:17:02.905 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:02.905 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:02.905 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdc2cd0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:02.905 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:02.905 7ff46c425cc0 [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=426809941, session_epoch=6807, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.905 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6824 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6807, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.905 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.827148, idle connection 238386.000000, request 304999.951124
03/09/2026 04:17:02.906 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.403809, idle connection 238386.000000, request 304999.536514
03/09/2026 04:17:02.949 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:02.950 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:02.950 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be7fdf0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:02.950 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:02.950 7ff46b090c20 [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=671034879, session_epoch=6801, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.950 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6818 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6801, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:02.950 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 949.365967, idle connection 240946.000000, request 304999.943733
03/09/2026 04:17:02.950 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 948.954346, idle connection 240946.000000, request 304999.541759
03/09/2026 04:17:03.104 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298796.738281, idle connection 175020.000000, request 304398.963451
03/09/2026 04:17:03.105 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6829
03/09/2026 04:17:03.105 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:03.105 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6829 (601.7401218414307 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:03.105 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:03.144 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2548.719727, idle connection 242546.000000, request 304398.647308
03/09/2026 04:17:03.144 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6818
03/09/2026 04:17:03.144 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:03.144 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6818 (602.1482944488525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:03.145 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)
03/09/2026 04:17:03.240 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:03.240 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239250.000000, request 304398.621321
03/09/2026 04:17:03.279 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3380
03/09/2026 04:17:03.279 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:03.280 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdbd1c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:03.280 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:03.280 7ff46ced7360 [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=1065290795, session_epoch=7499, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.280 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7515 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7499, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.280 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.643799, idle connection 113559.000000, request 304999.944448
03/09/2026 04:17:03.281 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.178223, idle connection 113558.000000, request 304999.489069
03/09/2026 04:17:03.309 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:03.309 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 477638.000000, request 304398.703575
03/09/2026 04:17:03.311 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3721.183594, idle connection 243719.000000, request 304399.193764
03/09/2026 04:17:03.312 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7202
03/09/2026 04:17:03.312 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:03.312 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7202 (601.4735698699951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1397803103, topics=[])
03/09/2026 04:17:03.312 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1397803103 with 0 response partitions (1 implied)
03/09/2026 04:17:03.408 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4553
03/09/2026 04:17:03.408 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:03.409 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda2a90> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:03.409 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:03.409 7ff46ced7680 [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=1109539399, session_epoch=7308, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.409 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7325 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7308, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.409 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298195.266357, idle connection 414876.000000, request 304999.939680
03/09/2026 04:17:03.410 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.770752, idle connection 414875.000000, request 304999.453068
03/09/2026 04:17:03.506 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298797.833008, idle connection 237785.000000, request 304398.956537
03/09/2026 04:17:03.507 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6824
03/09/2026 04:17:03.507 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:03.507 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6824 (601.639986038208 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426809941, topics=[])
03/09/2026 04:17:03.507 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426809941 with 0 response partitions (1 implied)
03/09/2026 04:17:03.551 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 348.380371, idle connection 240345.000000, request 304398.957491
03/09/2026 04:17:03.551 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6818
03/09/2026 04:17:03.552 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:03.552 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6818 (601.5737056732178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=671034879, topics=[])
03/09/2026 04:17:03.552 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 671034879 with 0 response partitions (1 implied)
03/09/2026 04:17:03.707 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 550
03/09/2026 04:17:03.708 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/09/2026 04:17:03.708 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c618910> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/09/2026 04:17:03.708 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:03.708 7ff46c425a40 [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=969738151, session_epoch=6807, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.708 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6830 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=969738151, session_epoch=6807, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.708 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298192.911133, idle connection 174416.000000, request 304999.930620
03/09/2026 04:17:03.709 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298192.478271, idle connection 174416.000000, request 304999.509573
03/09/2026 04:17:03.746 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
03/09/2026 04:17:03.746 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/09/2026 04:17:03.746 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c618370> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/09/2026 04:17:03.747 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:03.747 7ff46c425f40 [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=553538520, session_epoch=6805, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.747 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6819 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=553538520, session_epoch=6805, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.747 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1945.323730, idle connection 241943.000000, request 304999.923468
03/09/2026 04:17:03.747 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1944.851562, idle connection 241942.000000, request 304999.459982
03/09/2026 04:17:03.842 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:03.842 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 238648.000000, request 303796.594620
03/09/2026 04:17:03.842 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3
03/09/2026 04:17:03.843 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:03.843 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 3 (1204.697847366333 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-7', is_internal=False, partitions=[(error_code=0, partition=0, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=5, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=10, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=20, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=15, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=25, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=26, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=9, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=11, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=4, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=16, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=17, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=3, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=24, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=23, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=13, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=28, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=18, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=22, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=8, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=2, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=12, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=29, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=19, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=14, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=1, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=6, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=7, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=21, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=27, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[])])])
03/09/2026 04:17:03.844 7ff46c425b80 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:03.882 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298796.732666, idle connection 112957.000000, request 304398.033381
03/09/2026 04:17:03.883 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7515
03/09/2026 04:17:03.883 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:03.883 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7515 (602.6873588562012 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[])
03/09/2026 04:17:03.883 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 0 response partitions (1 implied)
03/09/2026 04:17:03.910 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:03.911 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 477037.000000, request 303797.351122
03/09/2026 04:17:03.911 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6992
03/09/2026 04:17:03.911 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:03.913 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6992 (1204.6058177947998 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-24', is_internal=False, partitions=[(error_code=0, partition=0, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=5, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=10, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=20, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=15, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=25, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=26, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=9, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=11, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=16, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=4, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=17, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=3, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=24, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=23, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=28, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=13, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=18, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=22, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=8, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=2, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=12, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=29, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=19, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=14, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=1, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=6, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=7, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=27, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=21, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[])])])
03/09/2026 04:17:03.914 7ff46c425e00 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:03.914 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:03.914 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:03.914 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c618b80> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:03.914 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:03.915 7ff46ced7860 [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=1397803103, session_epoch=7189, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.915 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7203 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7189, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:03.915 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3117.474121, idle connection 243115.000000, request 304999.951363
03/09/2026 04:17:03.915 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3117.082275, idle connection 243115.000000, request 304999.566078
03/09/2026 04:17:04.011 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297593.838379, idle connection 414274.000000, request 304398.506880
03/09/2026 04:17:04.011 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7325
03/09/2026 04:17:04.011 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:04.011 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7325 (602.2815704345703 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[])
03/09/2026 04:17:04.012 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 0 response partitions (1 implied)
03/09/2026 04:17:04.109 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:04.109 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:04.109 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda20a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:04.109 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:04.109 7ff46c425cc0 [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=426809941, session_epoch=6808, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.109 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6825 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6808, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.109 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.845703, idle connection 237182.000000, request 304999.927759
03/09/2026 04:17:04.110 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.181885, idle connection 237181.000000, request 304999.274492
03/09/2026 04:17:04.153 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:04.153 7ff46b090c20 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-4'], allow_auto_topic_creation=True) to node 3
03/09/2026 04:17:04.153 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-4'], allow_auto_topic_creation=True)
03/09/2026 04:17:04.154 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-4'], allow_auto_topic_creation=True)
03/09/2026 04:17:04.154 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239742.000000, request 304999.970675
03/09/2026 04:17:04.309 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297591.960693, idle connection 173815.000000, request 304398.982286
03/09/2026 04:17:04.310 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6830
03/09/2026 04:17:04.310 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:04.310 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6830 (601.5725135803223 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:04.310 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:04.348 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1344.285645, idle connection 241342.000000, request 304398.882151
03/09/2026 04:17:04.348 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6819
03/09/2026 04:17:04.348 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:04.349 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6819 (601.6466617584229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:04.349 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)
03/09/2026 04:17:04.445 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 441
03/09/2026 04:17:04.445 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
03/09/2026 04:17:04.445 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c618d00> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
03/09/2026 04:17:04.446 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:04.446 7ff46c425b80 [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=1008506252, session_epoch=6828, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.446 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6843 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008506252, session_epoch=6828, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.446 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.609375, idle connection 238044.000000, request 304999.949694
03/09/2026 04:17:04.446 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.133545, idle connection 238044.000000, request 304999.477148
03/09/2026 04:17:04.483 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3380
03/09/2026 04:17:04.484 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:04.484 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be3baf0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:04.484 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:04.484 7ff46ced7360 [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=1065290795, session_epoch=7500, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.484 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7516 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7500, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.484 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.476318, idle connection 112355.000000, request 304999.943018
03/09/2026 04:17:04.485 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.969482, idle connection 112354.000000, request 304999.441862
03/09/2026 04:17:04.514 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1478
03/09/2026 04:17:04.515 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:04.515 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdbdca0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:04.515 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:04.515 7ff46c425e00 [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=1226254613, session_epoch=6976, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.515 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6993 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6976, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.515 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.506104, idle connection 476432.000000, request 304999.948978
03/09/2026 04:17:04.516 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.045898, idle connection 476432.000000, request 304999.497414
03/09/2026 04:17:04.516 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 2515.868164, idle connection 242514.000000, request 304398.352385
03/09/2026 04:17:04.517 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7203
03/09/2026 04:17:04.517 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:04.517 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7203 (602.0228862762451 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1397803103, topics=[])
03/09/2026 04:17:04.517 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1397803103 with 0 response partitions (1 implied)
03/09/2026 04:17:04.613 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4553
03/09/2026 04:17:04.613 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:04.613 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be29340> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:04.613 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:04.613 7ff46ced7680 [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=1109539399, session_epoch=7309, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.613 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7326 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7309, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.614 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296990.840088, idle connection 413671.000000, request 304999.936819
03/09/2026 04:17:04.614 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296990.298096, idle connection 413671.000000, request 304999.408484
03/09/2026 04:17:04.711 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297593.528564, idle connection 236581.000000, request 304398.616552
03/09/2026 04:17:04.711 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6825
03/09/2026 04:17:04.711 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:04.712 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6825 (602.2200584411621 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426809941, topics=[])
03/09/2026 04:17:04.713 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426809941 with 0 response partitions (1 implied)
03/09/2026 04:17:04.755 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:04.756 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239140.000000, request 304397.977114
03/09/2026 04:17:04.756 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7
03/09/2026 04:17:04.756 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:04.757 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7 (603.5215854644775 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-4', is_internal=False, partitions=[(error_code=0, partition=0, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=5, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=10, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=20, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=15, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=25, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=26, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=9, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=11, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=4, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=16, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=17, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=3, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=24, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=23, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=13, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=28, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=18, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=22, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=8, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=2, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=12, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=29, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=19, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=14, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=1, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=6, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=7, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=21, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=27, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[])])])
03/09/2026 04:17:04.759 7ff46b090c20 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:04.913 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 550
03/09/2026 04:17:04.913 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/09/2026 04:17:04.913 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdc25b0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/09/2026 04:17:04.913 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:04.913 7ff46c425a40 [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=969738151, session_epoch=6808, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.913 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6831 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=969738151, session_epoch=6808, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.914 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296987.577393, idle connection 173211.000000, request 304999.935389
03/09/2026 04:17:04.914 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296987.095215, idle connection 173210.000000, request 304999.462366
03/09/2026 04:17:04.949 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
03/09/2026 04:17:04.949 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/09/2026 04:17:04.949 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c6189d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/09/2026 04:17:04.949 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:04.950 7ff46c425f40 [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=553538520, session_epoch=6806, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.950 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6820 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=553538520, session_epoch=6806, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:04.950 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 742.471436, idle connection 240740.000000, request 304999.949455
03/09/2026 04:17:04.950 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 742.024170, idle connection 240739.000000, request 304999.508619
03/09/2026 04:17:05.048 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298796.406982, idle connection 237442.000000, request 304397.746563
03/09/2026 04:17:05.048 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6843
03/09/2026 04:17:05.049 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.049 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6843 (602.7944087982178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:05.049 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:05.086 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297592.900635, idle connection 111753.000000, request 304398.368597
03/09/2026 04:17:05.086 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7516
03/09/2026 04:17:05.086 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.086 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7516 (602.1895408630371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[])
03/09/2026 04:17:05.087 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 0 response partitions (1 implied)
03/09/2026 04:17:05.116 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298797.524414, idle connection 475831.000000, request 304398.968935
03/09/2026 04:17:05.116 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6993
03/09/2026 04:17:05.117 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.117 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6993 (601.5751361846924 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1226254613, topics=[])
03/09/2026 04:17:05.117 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1226254613 with 0 response partitions (1 implied)
03/09/2026 04:17:05.117 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:05.117 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:05.117 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bfea730> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:05.118 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:05.118 7ff46ced7860 [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=1397803103, session_epoch=7190, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.118 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7204 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7190, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.118 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1914.492920, idle connection 241912.000000, request 304999.955654
03/09/2026 04:17:05.118 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1914.032471, idle connection 241912.000000, request 304999.488354
03/09/2026 04:17:05.215 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296389.147461, idle connection 413070.000000, request 304398.247242
03/09/2026 04:17:05.216 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7326
03/09/2026 04:17:05.216 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.216 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7326 (602.3859977722168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[])
03/09/2026 04:17:05.216 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 0 response partitions (1 implied)
03/09/2026 04:17:05.315 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:05.315 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:05.315 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be8d8e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:05.315 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:05.315 7ff46c425cc0 [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=426809941, session_epoch=6809, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.316 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6826 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6809, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.316 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296988.533447, idle connection 235976.000000, request 304999.947548
03/09/2026 04:17:05.316 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296988.082520, idle connection 235975.000000, request 304999.504089
03/09/2026 04:17:05.361 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:05.361 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:05.361 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bde3220> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:05.361 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:05.361 7ff46b090c20 [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=671034879, session_epoch=6802, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.361 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6819 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6802, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.361 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.630127, idle connection 238535.000000, request 304999.954462
03/09/2026 04:17:05.362 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.209961, idle connection 238534.000000, request 304999.542475
03/09/2026 04:17:05.515 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296386.468018, idle connection 172610.000000, request 304398.825645
03/09/2026 04:17:05.515 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6831
03/09/2026 04:17:05.515 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.515 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6831 (601.8180847167969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:05.516 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:05.551 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141.502197, idle connection 240139.000000, request 304398.978949
03/09/2026 04:17:05.551 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6820
03/09/2026 04:17:05.551 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.551 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6820 (601.6659736633301 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:05.552 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)
03/09/2026 04:17:05.649 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 441
03/09/2026 04:17:05.650 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
03/09/2026 04:17:05.650 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda2640> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
03/09/2026 04:17:05.650 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:05.650 7ff46c425b80 [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=1008506252, session_epoch=6829, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.650 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6844 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008506252, session_epoch=6829, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.651 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.015869, idle connection 236840.000000, request 304999.925137
03/09/2026 04:17:05.651 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.284180, idle connection 236839.000000, request 304999.207973
03/09/2026 04:17:05.687 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3380
03/09/2026 04:17:05.687 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:05.687 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdc57f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:05.687 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:05.688 7ff46ced7360 [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=1065290795, session_epoch=7501, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.688 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7517 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7501, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.689 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296990.049072, idle connection 111150.000000, request 304999.934196
03/09/2026 04:17:05.689 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296989.458008, idle connection 111150.000000, request 304999.349594
03/09/2026 04:17:05.718 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1478
03/09/2026 04:17:05.718 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:05.718 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda28b0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:05.718 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:05.718 7ff46c425e00 [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=1226254613, session_epoch=6977, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.718 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6994 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6977, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.719 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298195.075195, idle connection 475229.000000, request 304999.943733
03/09/2026 04:17:05.719 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 1313.468018, idle connection 241311.000000, request 304398.932934
03/09/2026 04:17:05.719 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.352539, idle connection 475228.000000, request 304999.230385
03/09/2026 04:17:05.720 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7204
03/09/2026 04:17:05.720 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.720 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7204 (601.9299030303955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1397803103, topics=[])
03/09/2026 04:17:05.720 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1397803103 with 0 response partitions (1 implied)
03/09/2026 04:17:05.817 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4553
03/09/2026 04:17:05.817 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:05.817 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdbdbb0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:05.817 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:05.817 7ff46ced7680 [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=1109539399, session_epoch=7310, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.817 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7327 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7310, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:05.817 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295787.079346, idle connection 412467.000000, request 304999.946594
03/09/2026 04:17:05.818 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295786.669678, idle connection 412467.000000, request 304999.545574
03/09/2026 04:17:05.917 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296387.483154, idle connection 235375.000000, request 304398.897886
03/09/2026 04:17:05.917 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6826
03/09/2026 04:17:05.917 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.917 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6826 (601.6979217529297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426809941, topics=[])
03/09/2026 04:17:05.918 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426809941 with 0 response partitions (1 implied)
03/09/2026 04:17:05.962 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298796.679443, idle connection 237934.000000, request 304399.003029
03/09/2026 04:17:05.963 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6819
03/09/2026 04:17:05.963 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:05.963 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6819 (601.6755104064941 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=671034879, topics=[])
03/09/2026 04:17:05.963 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 671034879 with 0 response partitions (1 implied)
03/09/2026 04:17:06.116 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 550
03/09/2026 04:17:06.117 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/09/2026 04:17:06.117 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c5faaf0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/09/2026 04:17:06.117 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:06.117 7ff46c425a40 [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=969738151, session_epoch=6809, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.117 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6832 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=969738151, session_epoch=6809, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.117 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295783.881592, idle connection 172007.000000, request 304999.925137
03/09/2026 04:17:06.118 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295783.402344, idle connection 172007.000000, request 304999.462128
03/09/2026 04:17:06.152 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:06.152 7ff46c425f40 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-17'], allow_auto_topic_creation=True) to node 1
03/09/2026 04:17:06.153 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-17'], allow_auto_topic_creation=True)
03/09/2026 04:17:06.153 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6821 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-17'], allow_auto_topic_creation=True)
03/09/2026 04:17:06.153 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239537.000000, request 304999.972820
03/09/2026 04:17:06.253 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297591.745605, idle connection 236237.000000, request 304397.645712
03/09/2026 04:17:06.254 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6844
03/09/2026 04:17:06.255 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.255 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6844 (604.5527458190918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:06.256 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:06.291 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296387.939697, idle connection 110548.000000, request 304397.822142
03/09/2026 04:17:06.291 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7517
03/09/2026 04:17:06.292 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.292 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7517 (602.9844284057617 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[])
03/09/2026 04:17:06.292 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 0 response partitions (1 implied)
03/09/2026 04:17:06.320 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:06.320 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:06.321 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be3baf0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:06.321 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:06.321 7ff46ced7860 [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=1397803103, session_epoch=7191, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.321 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7205 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7191, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.321 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 711.352539, idle connection 240709.000000, request 304999.937773
03/09/2026 04:17:06.321 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297592.412842, idle connection 474626.000000, request 304397.288799
03/09/2026 04:17:06.322 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 710.777832, idle connection 240709.000000, request 304999.371052
03/09/2026 04:17:06.322 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6994
03/09/2026 04:17:06.322 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.322 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6994 (603.4870147705078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1226254613, topics=[])
03/09/2026 04:17:06.322 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1226254613 with 0 response partitions (1 implied)
03/09/2026 04:17:06.418 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295186.214111, idle connection 411867.000000, request 304399.082661
03/09/2026 04:17:06.419 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7327
03/09/2026 04:17:06.419 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.419 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7327 (601.4304161071777 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=4555, last_stable_offset=4555, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11\xc9\x00\x00\x02\x17\x00\x00\x00\x00\x02\xb0\xcf\xd6\xb7\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\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
03/09/2026 04:17:06.419 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 1 response partitions (0 implied)
03/09/2026 04:17:06.419 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 4553
03/09/2026 04:17:06.419 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4553 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0)
03/09/2026 04:17:06.420 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 4555 (leader epoch 0)
03/09/2026 04:17:06.519 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:06.519 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:06.520 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdbd700> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:06.520 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:06.520 7ff46c425cc0 [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=426809941, session_epoch=6810, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.520 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6827 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6810, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.520 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295784.296631, idle connection 234772.000000, request 304999.940157
03/09/2026 04:17:06.521 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4555
03/09/2026 04:17:06.521 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:06.521 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be90850> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:06.521 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:06.521 7ff46ced7680 [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=1109539399, session_epoch=7311, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4555, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:06.521 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7311, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4555, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:06.521 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295083.182617, idle connection 411764.000000, request 304999.953270
03/09/2026 04:17:06.522 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295782.603027, idle connection 234770.000000, request 304998.257637
03/09/2026 04:17:06.522 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295082.436523, idle connection 411763.000000, request 304999.212980
03/09/2026 04:17:06.565 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:06.565 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:06.565 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda2940> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:06.565 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:06.565 7ff46b090c20 [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=671034879, session_epoch=6803, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.565 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6820 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6803, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.566 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.457275, idle connection 237330.000000, request 304999.922514
03/09/2026 04:17:06.566 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298192.823486, idle connection 237330.000000, request 304999.300003
03/09/2026 04:17:06.719 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295182.673096, idle connection 171406.000000, request 304398.722649
03/09/2026 04:17:06.719 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6832
03/09/2026 04:17:06.719 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.719 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6832 (602.1089553833008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:06.720 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:06.757 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:06.757 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 238932.000000, request 304395.516157
03/09/2026 04:17:06.758 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6821
03/09/2026 04:17:06.758 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:06.758 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6821 (605.4208278656006 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-17', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=5, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=10, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=20, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=15, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=25, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=26, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=9, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=11, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=4, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=16, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=17, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=3, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=24, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=23, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=13, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=28, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=18, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=22, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=8, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=2, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=12, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=29, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=19, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=14, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=1, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=6, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=7, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=21, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=27, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[])])])
03/09/2026 04:17:06.760 7ff46c425f40 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:06.856 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 441
03/09/2026 04:17:06.857 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
03/09/2026 04:17:06.857 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c6185e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
03/09/2026 04:17:06.857 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:06.857 7ff46c425b80 [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=1008506252, session_epoch=6830, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.857 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6845 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008506252, session_epoch=6830, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.858 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296986.964355, idle connection 235633.000000, request 304999.948502
03/09/2026 04:17:06.858 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296986.544922, idle connection 235632.000000, request 304999.536276
03/09/2026 04:17:06.892 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3380
03/09/2026 04:17:06.892 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:06.893 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be819d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:06.893 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:06.893 7ff46ced7360 [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=1065290795, session_epoch=7502, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.893 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7518 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7502, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.893 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295785.778320, idle connection 109946.000000, request 304999.936342
03/09/2026 04:17:06.893 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295785.301025, idle connection 109945.000000, request 304999.466181
03/09/2026 04:17:06.894 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7518
03/09/2026 04:17:06.894 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.894 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7518 (0.9930133819580078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=3382, last_stable_offset=3382, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\r4\x00\x00\x02\x19\x00\x00\x00\x00\x02j\x1bP\x0b\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\xe4\x03\x00\x00\x00\xa6\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
03/09/2026 04:17:06.894 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 1 response partitions (0 implied)
03/09/2026 04:17:06.894 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 549 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 3380
03/09/2026 04:17:06.894 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3380 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0)
03/09/2026 04:17:06.895 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 3382 (leader epoch 0)
03/09/2026 04:17:06.929 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1478
03/09/2026 04:17:06.929 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:06.929 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdbd130> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:06.929 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:06.929 7ff46c425e00 [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=1226254613, session_epoch=6978, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.930 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6995 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6978, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:06.930 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296983.877197, idle connection 474018.000000, request 304999.946594
03/09/2026 04:17:06.930 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 102.310547, idle connection 240100.000000, request 304390.902042
03/09/2026 04:17:06.930 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296983.288086, idle connection 474017.000000, request 304999.366522
03/09/2026 04:17:06.931 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7205
03/09/2026 04:17:06.931 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:06.931 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 7205 (609.811544418335 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1397803103, topics=[])
03/09/2026 04:17:06.931 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1397803103 with 0 response partitions (1 implied)
03/09/2026 04:17:06.996 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3382
03/09/2026 04:17:06.996 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:06.996 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c335580> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:06.996 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:06.996 7ff46ced7360 [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=1065290795, session_epoch=7503, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3382, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:06.997 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7519 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7503, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3382, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:06.997 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295681.947754, idle connection 109842.000000, request 304999.944448
03/09/2026 04:17:06.997 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295681.506104, idle connection 109842.000000, request 304999.510765
03/09/2026 04:17:07.123 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295181.736816, idle connection 234169.000000, request 304397.380590
03/09/2026 04:17:07.123 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6827
03/09/2026 04:17:07.123 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.123 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6827 (603.3415794372559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426809941, topics=[])
03/09/2026 04:17:07.123 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426809941 with 0 response partitions (1 implied)
03/09/2026 04:17:07.124 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294480.766357, idle connection 411161.000000, request 304397.540092
03/09/2026 04:17:07.124 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7328
03/09/2026 04:17:07.124 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.130 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7328 (602.7829647064209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[])
03/09/2026 04:17:07.130 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 0 response partitions (1 implied)
03/09/2026 04:17:07.167 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297592.177490, idle connection 236729.000000, request 304398.648500
03/09/2026 04:17:07.167 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6820
03/09/2026 04:17:07.167 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.168 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6820 (601.9012928009033 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=671034879, topics=[])
03/09/2026 04:17:07.168 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 671034879 with 0 response partitions (1 implied)
03/09/2026 04:17:07.322 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 550
03/09/2026 04:17:07.322 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/09/2026 04:17:07.322 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46c625f70> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/09/2026 04:17:07.322 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:07.322 7ff46c425a40 [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=969738151, session_epoch=6810, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.322 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6833 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=969738151, session_epoch=6810, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.323 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294578.512695, idle connection 170802.000000, request 304999.918461
03/09/2026 04:17:07.323 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294577.764404, idle connection 170801.000000, request 304999.183655
03/09/2026 04:17:07.360 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
03/09/2026 04:17:07.361 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/09/2026 04:17:07.361 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46cefb9d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/09/2026 04:17:07.361 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:07.361 7ff46c425f40 [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=553538520, session_epoch=6807, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.361 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=553538520, session_epoch=6807, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.361 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.513672, idle connection 238328.000000, request 304999.911547
03/09/2026 04:17:07.362 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299397.875000, idle connection 238328.000000, request 304999.285221
03/09/2026 04:17:07.460 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296384.908447, idle connection 235030.000000, request 304397.888660
03/09/2026 04:17:07.460 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6845
03/09/2026 04:17:07.460 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.460 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6845 (602.7898788452148 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:07.461 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:07.531 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:07.532 7ff46ced7860 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v7(topics=['-uve-topic-29'], allow_auto_topic_creation=True) to node 1
03/09/2026 04:17:07.532 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v7(topics=['-uve-topic-29'], allow_auto_topic_creation=True)
03/09/2026 04:17:07.532 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 2 (timeout_ms 305000): MetadataRequest_v7(topics=['-uve-topic-29'], allow_auto_topic_creation=True)
03/09/2026 04:17:07.532 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 239498.000000, request 304999.965191
03/09/2026 04:17:07.533 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296381.102783, idle connection 473415.000000, request 304397.180557
03/09/2026 04:17:07.533 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6995
03/09/2026 04:17:07.533 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.533 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6995 (603.6114692687988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1226254613, topics=[])
03/09/2026 04:17:07.533 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1226254613 with 0 response partitions (1 implied)
03/09/2026 04:17:07.598 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295080.790527, idle connection 109241.000000, request 304398.786068
03/09/2026 04:17:07.598 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7519
03/09/2026 04:17:07.598 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.599 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7519 (601.7911434173584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[])
03/09/2026 04:17:07.599 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 0 response partitions (1 implied)
03/09/2026 04:17:07.726 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:07.726 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:07.726 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda27f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:07.726 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:07.727 7ff46c425cc0 [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=426809941, session_epoch=6811, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.727 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6828 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6811, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.727 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294577.401367, idle connection 233565.000000, request 304999.913692
03/09/2026 04:17:07.728 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294576.781250, idle connection 233564.000000, request 304999.317169
03/09/2026 04:17:07.735 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4555
03/09/2026 04:17:07.735 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:07.735 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bddb610> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:07.735 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:07.735 7ff46ced7680 [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=1109539399, session_epoch=7312, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.736 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7312, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.736 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293868.711670, idle connection 410549.000000, request 304999.947309
03/09/2026 04:17:07.736 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293868.283936, idle connection 410549.000000, request 304999.527454
03/09/2026 04:17:07.769 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:07.769 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:07.769 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bddb0a0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:07.769 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:07.769 7ff46b090c20 [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=671034879, session_epoch=6804, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.769 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6821 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6804, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:07.769 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296989.631592, idle connection 236127.000000, request 304999.944925
03/09/2026 04:17:07.770 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296989.214355, idle connection 236126.000000, request 304999.536514
03/09/2026 04:17:07.927 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293973.855957, idle connection 170197.000000, request 304395.263433
03/09/2026 04:17:07.928 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6833
03/09/2026 04:17:07.928 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.928 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6833 (605.4763793945312 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:07.928 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:07.963 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298797.008057, idle connection 237727.000000, request 304398.406982
03/09/2026 04:17:07.964 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6822
03/09/2026 04:17:07.964 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:07.964 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6822 (602.5705337524414 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:07.964 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)
03/09/2026 04:17:08.062 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 441
03/09/2026 04:17:08.062 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
03/09/2026 04:17:08.062 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdac5e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
03/09/2026 04:17:08.062 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:08.062 7ff46c425b80 [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=1008506252, session_epoch=6831, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.063 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6846 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008506252, session_epoch=6831, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.063 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295781.721680, idle connection 234427.000000, request 304999.940872
03/09/2026 04:17:08.063 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295781.214111, idle connection 234427.000000, request 304999.441147
03/09/2026 04:17:08.135 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Skipping fetch for partition %s because connection to leader node is not ready yet
03/09/2026 04:17:08.136 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 305000.000000, idle connection 238895.000000, request 304396.674633
03/09/2026 04:17:08.136 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2
03/09/2026 04:17:08.136 7ff46ced7860 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v7
03/09/2026 04:17:08.137 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2 (604.933500289917 ms): MetadataResponse_v7(throttle_time_ms=0, brokers=[(node_id=2, host='10.0.0.249', port=9092, rack=None), (node_id=3, host='10.0.0.23', port=9092, rack=None), (node_id=1, host='10.0.0.22', port=9092, rack=None)], cluster_id='foZLQWq6TqqHzl4IYzi-BA', controller_id=3, topics=[(error_code=0, topic='-uve-topic-29', is_internal=False, partitions=[(error_code=0, partition=0, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=5, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=10, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=20, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=15, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=25, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=26, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=9, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=11, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=4, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=16, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=17, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=3, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=24, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=23, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=13, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=28, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=18, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=22, leader=3, leader_epoch=0, replicas=[3, 1, 2], isr=[3, 1, 2], offline_replicas=[]), (error_code=0, partition=8, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=2, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=12, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=29, leader=1, leader_epoch=0, replicas=[1, 2, 3], isr=[1, 2, 3], offline_replicas=[]), (error_code=0, partition=19, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=14, leader=1, leader_epoch=0, replicas=[1, 3, 2], isr=[1, 3, 2], offline_replicas=[]), (error_code=0, partition=1, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=6, leader=2, leader_epoch=0, replicas=[2, 1, 3], isr=[2, 1, 3], offline_replicas=[]), (error_code=0, partition=7, leader=3, leader_epoch=0, replicas=[3, 2, 1], isr=[3, 2, 1], offline_replicas=[]), (error_code=0, partition=21, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[]), (error_code=0, partition=27, leader=2, leader_epoch=0, replicas=[2, 3, 1], isr=[2, 3, 1], offline_replicas=[])])])
03/09/2026 04:17:08.138 7ff46ced7860 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 3, topics: 1, groups: 0)
03/09/2026 04:17:08.139 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1478
03/09/2026 04:17:08.139 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:08.139 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdacc70> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:08.139 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:08.142 7ff46c425e00 [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=1226254613, session_epoch=6979, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.142 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6996 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6979, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.142 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295771.457764, idle connection 472805.000000, request 304999.944448
03/09/2026 04:17:08.143 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295771.056396, idle connection 472805.000000, request 304999.551058
03/09/2026 04:17:08.200 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3382
03/09/2026 04:17:08.200 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:08.201 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bff1a30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:08.201 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:08.201 7ff46ced7360 [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=1065290795, session_epoch=7504, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.201 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7520 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7504, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.201 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294477.727295, idle connection 108638.000000, request 304999.945402
03/09/2026 04:17:08.201 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 294477.309814, idle connection 108637.000000, request 304999.536037
03/09/2026 04:17:08.328 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293976.093506, idle connection 232963.000000, request 304398.623466
03/09/2026 04:17:08.329 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6828
03/09/2026 04:17:08.329 7ff46c425cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:08.329 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6828 (601.9206047058105 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426809941, topics=[])
03/09/2026 04:17:08.329 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426809941 with 0 response partitions (1 implied)
03/09/2026 04:17:08.337 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293267.701172, idle connection 409948.000000, request 304398.938656
03/09/2026 04:17:08.337 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7329
03/09/2026 04:17:08.337 7ff46ced7680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:08.337 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7329 (601.5286445617676 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1109539399, topics=[])
03/09/2026 04:17:08.337 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1109539399 with 0 response partitions (1 implied)
03/09/2026 04:17:08.371 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296388.492432, idle connection 235525.000000, request 304398.806572
03/09/2026 04:17:08.371 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6821
03/09/2026 04:17:08.371 7ff46b090c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:08.371 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6821 (601.759672164917 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=671034879, topics=[])
03/09/2026 04:17:08.371 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 671034879 with 0 response partitions (1 implied)
03/09/2026 04:17:08.530 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 550
03/09/2026 04:17:08.530 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/09/2026 04:17:08.530 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bddbe20> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/09/2026 04:17:08.530 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:08.530 7ff46c425a40 [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=969738151, session_epoch=6811, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.530 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6834 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=969738151, session_epoch=6811, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.531 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293370.530029, idle connection 169594.000000, request 304999.932051
03/09/2026 04:17:08.531 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293370.088379, idle connection 169593.000000, request 304999.497652
03/09/2026 04:17:08.565 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
03/09/2026 04:17:08.565 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/09/2026 04:17:08.565 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be39e50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/09/2026 04:17:08.565 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:08.566 7ff46c425f40 [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=553538520, session_epoch=6808, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.566 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6823 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=553538520, session_epoch=6808, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.566 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298194.009277, idle connection 237124.000000, request 304999.944687
03/09/2026 04:17:08.566 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.556396, idle connection 237123.000000, request 304999.500275
03/09/2026 04:17:08.664 7ff46c425b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295180.282471, idle connection 233826.000000, request 304398.503304
03/09/2026 04:17:08.665 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6846
03/09/2026 04:17:08.665 7ff46c425b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:08.665 7ff46c425b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6846 (602.0190715789795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008506252, topics=[])
03/09/2026 04:17:08.665 7ff46c425b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1008506252 with 0 response partitions (1 implied)
03/09/2026 04:17:08.739 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4319
03/09/2026 04:17:08.739 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/09/2026 04:17:08.739 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bda2640> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/09/2026 04:17:08.739 7ff46ced7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:08.739 7ff46ced7860 [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=1397803103, session_epoch=7192, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.739 7ff46ced7860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 7206 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1397803103, session_epoch=7192, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.740 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.788818, idle connection 238290.000000, request 304999.953985
03/09/2026 04:17:08.740 7ff46ced7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 299398.376709, idle connection 238290.000000, request 304999.548435
03/09/2026 04:17:08.743 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295170.549072, idle connection 472204.000000, request 304399.039507
03/09/2026 04:17:08.743 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6996
03/09/2026 04:17:08.743 7ff46c425e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:08.744 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6996 (601.4528274536133 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1226254613, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=1480, last_stable_offset=1480, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x05\xc6\x00\x00\x02\x00\x00\x00\x00\x00\x02\x16\xff\xde\x1e\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\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
03/09/2026 04:17:08.744 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1226254613 with 1 response partitions (0 implied)
03/09/2026 04:17:08.744 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 524 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 1478
03/09/2026 04:17:08.744 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 1478 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0)
03/09/2026 04:17:08.744 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 1480 (leader epoch 0)
03/09/2026 04:17:08.802 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293876.783936, idle connection 108037.000000, request 304399.003506
03/09/2026 04:17:08.802 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7520
03/09/2026 04:17:08.802 7ff46ced7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:08.803 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7520 (601.5594005584717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065290795, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=3384, last_stable_offset=3384, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\r6\x00\x00\x02+\x00\x00\x00\x00\x02\x85\xde\x7fU\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\x80\x04\x00\x00\x00\xc2\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
03/09/2026 04:17:08.803 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1065290795 with 1 response partitions (0 implied)
03/09/2026 04:17:08.803 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 567 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 3382
03/09/2026 04:17:08.803 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3382 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0)
03/09/2026 04:17:08.803 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 3384 (leader epoch 0)
03/09/2026 04:17:08.846 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1480
03/09/2026 04:17:08.846 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/09/2026 04:17:08.846 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46a9a0f70> for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/09/2026 04:17:08.846 7ff46c425e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:08.846 7ff46c425e00 [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=1226254613, session_epoch=6980, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=1480, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:08.846 7ff46c425e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6997 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1226254613, session_epoch=6980, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=1480, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:08.847 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295067.109375, idle connection 472101.000000, request 304999.840975
03/09/2026 04:17:08.847 7ff46c425e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295066.514404, idle connection 472100.000000, request 304999.257565
03/09/2026 04:17:08.905 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3384
03/09/2026 04:17:08.905 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
03/09/2026 04:17:08.905 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bdc2fd0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
03/09/2026 04:17:08.905 7ff46ced7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:08.906 7ff46ced7360 [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=1065290795, session_epoch=7505, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3384, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:08.906 7ff46ced7360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7521 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065290795, session_epoch=7505, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3384, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/09/2026 04:17:08.906 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293772.780762, idle connection 107933.000000, request 304999.934673
03/09/2026 04:17:08.907 7ff46ced7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293772.222900, idle connection 107932.000000, request 304999.383926
03/09/2026 04:17:08.931 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 269
03/09/2026 04:17:08.931 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/09/2026 04:17:08.931 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be3baf0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/09/2026 04:17:08.932 7ff46c425cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/09/2026 04:17:08.932 7ff46c425cc0 [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=426809941, session_epoch=6812, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.932 7ff46c425cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6829 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426809941, session_epoch=6812, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.932 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293372.296875, idle connection 232360.000000, request 304999.927759
03/09/2026 04:17:08.932 7ff46c425cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 293371.851074, idle connection 232359.000000, request 304999.497652
03/09/2026 04:17:08.939 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4555
03/09/2026 04:17:08.939 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
03/09/2026 04:17:08.939 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46be3bc70> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
03/09/2026 04:17:08.939 7ff46ced7680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/09/2026 04:17:08.940 7ff46ced7680 [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=1109539399, session_epoch=7313, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.940 7ff46ced7680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1109539399, session_epoch=7313, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.940 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 292664.639404, idle connection 409345.000000, request 304999.948263
03/09/2026 04:17:08.940 7ff46ced7680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 292664.201904, idle connection 409345.000000, request 304999.518394
03/09/2026 04:17:08.973 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 310
03/09/2026 04:17:08.973 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
03/09/2026 04:17:08.973 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff46bfdf2b0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
03/09/2026 04:17:08.974 7ff46b090c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/09/2026 04:17:08.974 7ff46b090c20 [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=671034879, session_epoch=6805, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.974 7ff46b090c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=671034879, session_epoch=6805, topics=[], forgotten_topics_data=[])
03/09/2026 04:17:08.974 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295785.035889, idle connection 234922.000000, request 304999.925375
03/09/2026 04:17:08.975 7ff46b090c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 295784.274658, idle connection 234921.000000, request 304999.174595
03/09/2026 04:17:09.132 7ff46c425a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 292769.527344, idle connection 168993.000000, request 304398.927450
03/09/2026 04:17:09.132 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6834
03/09/2026 04:17:09.132 7ff46c425a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:09.132 7ff46c425a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6834 (601.618766784668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=969738151, topics=[])
03/09/2026 04:17:09.132 7ff46c425a40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 969738151 with 0 response partitions (1 implied)
03/09/2026 04:17:09.167 7ff46c425f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297593.078125, idle connection 236523.000000, request 304399.014235
03/09/2026 04:17:09.167 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6823
03/09/2026 04:17:09.167 7ff46c425f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/09/2026 04:17:09.167 7ff46c425f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6823 (601.6068458557129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=553538520, topics=[])
03/09/2026 04:17:09.168 7ff46c425f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 553538520 with 0 response partitions (1 implied)