11/20/2025 04:20:18.851 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 155433.736328, idle connection 271398.000000, request 304999.482155
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3656
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e218670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195533134, session_epoch=7634, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7657 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195533134, session_epoch=7634, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:18.919 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154835.905273, idle connection 394834.000000, request 304999.931097
11/20/2025 04:20:18.920 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154835.362793, idle connection 394833.000000, request 304999.397516
11/20/2025 04:20:19.021 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154562.493652, idle connection 267905.000000, request 304398.446798
11/20/2025 04:20:19.022 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7178
11/20/2025 04:20:19.022 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.022 7fef7ce84360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7178 (602.1246910095215 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=106984064, topics=[])
11/20/2025 04:20:19.022 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 106984064 with 0 response partitions (1 implied)
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 2716
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e55d5b0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=556615688, session_epoch=7551, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7569 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=556615688, session_epoch=7551, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.036 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 155824.744385, idle connection 333881.000000, request 304999.935389
11/20/2025 04:20:19.037 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 155824.267578, idle connection 333881.000000, request 304999.467134
11/20/2025 04:20:19.067 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154381.295898, idle connection 394379.000000, request 304398.001432
11/20/2025 04:20:19.067 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7927
11/20/2025 04:20:19.067 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.068 7fef7ce84860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7927 (602.7843952178955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1891270261, topics=[])
11/20/2025 04:20:19.068 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1891270261 with 0 response partitions (1 implied)
11/20/2025 04:20:19.092 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154991.772217, idle connection 94100.000000, request 304398.497581
11/20/2025 04:20:19.093 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7665
11/20/2025 04:20:19.093 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.093 7fef7ce84220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7665 (602.1101474761963 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=953146994, topics=[])
11/20/2025 04:20:19.093 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 953146994 with 0 response partitions (1 implied)
11/20/2025 04:20:19.111 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 155483.816162, idle connection 332890.000000, request 304391.417503
11/20/2025 04:20:19.112 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7192
11/20/2025 04:20:19.112 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.112 7fef7d6a6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7192 (609.1935634613037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1742563035, topics=[])
11/20/2025 04:20:19.112 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1742563035 with 0 response partitions (1 implied)
11/20/2025 04:20:19.222 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 155515.274414, idle connection 94380.000000, request 304398.844957
11/20/2025 04:20:19.223 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7152
11/20/2025 04:20:19.223 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.223 7fef7d7dccc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7152 (601.7613410949707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1471930004, topics=[])
11/20/2025 04:20:19.223 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1471930004 with 0 response partitions (1 implied)
11/20/2025 04:20:19.411 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 329
11/20/2025 04:20:19.412 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
11/20/2025 04:20:19.412 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e15a100> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
11/20/2025 04:20:19.412 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:19.412 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2010034234, session_epoch=7172, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.412 7fef7d6a6d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7192 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2010034234, session_epoch=7172, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.412 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154817.386963, idle connection 331576.000000, request 304999.949217
11/20/2025 04:20:19.413 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154220.957764, idle connection 91842.000000, request 304396.548033
11/20/2025 04:20:19.413 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154816.751221, idle connection 331575.000000, request 304999.320984
11/20/2025 04:20:19.413 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7222
11/20/2025 04:20:19.413 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.413 7fef7ce84720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7222 (604.1276454925537 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=416489492, topics=[])
11/20/2025 04:20:19.413 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 416489492 with 0 response partitions (1 implied)
11/20/2025 04:20:19.453 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154831.580811, idle connection 270795.000000, request 304397.322655
11/20/2025 04:20:19.454 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7178
11/20/2025 04:20:19.454 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.454 7fef7d6a6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7178 (603.2254695892334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1668670850, topics=[])
11/20/2025 04:20:19.454 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1668670850 with 0 response partitions (1 implied)
11/20/2025 04:20:19.521 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154234.822998, idle connection 394233.000000, request 304398.849726
11/20/2025 04:20:19.521 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7657
11/20/2025 04:20:19.521 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.521 7fef7ce84ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7657 (601.7060279846191 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=195533134, topics=[])
11/20/2025 04:20:19.521 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 195533134 with 0 response partitions (1 implied)
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 433
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1cd1f0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=106984064, session_epoch=7157, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7179 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=106984064, session_epoch=7157, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.623 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153960.330811, idle connection 267303.000000, request 304999.948740
11/20/2025 04:20:19.624 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153959.866455, idle connection 267302.000000, request 304999.491215
11/20/2025 04:20:19.637 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 155223.678467, idle connection 333280.000000, request 304398.874521
11/20/2025 04:20:19.638 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7569
11/20/2025 04:20:19.638 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:19.639 7fef7ce84d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7569 (602.2589206695557 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=556615688, topics=[])
11/20/2025 04:20:19.639 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 556615688 with 0 response partitions (1 implied)
11/20/2025 04:20:19.669 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 7007
11/20/2025 04:20:19.669 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
11/20/2025 04:20:19.669 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e19e7f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
11/20/2025 04:20:19.669 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/20/2025 04:20:19.670 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1891270261, session_epoch=7919, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.670 7fef7ce84860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7928 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1891270261, session_epoch=7919, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.670 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153778.246582, idle connection 393776.000000, request 304999.946356
11/20/2025 04:20:19.670 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153777.815430, idle connection 393776.000000, request 304999.524355
11/20/2025 04:20:19.694 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3863
11/20/2025 04:20:19.694 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
11/20/2025 04:20:19.694 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1cd5e0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
11/20/2025 04:20:19.694 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:19.694 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=953146994, session_epoch=7651, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.694 7fef7ce84220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7666 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=953146994, session_epoch=7651, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.695 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154389.256836, idle connection 93498.000000, request 304999.944925
11/20/2025 04:20:19.695 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154388.841553, idle connection 93497.000000, request 304999.539375
11/20/2025 04:20:19.713 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 335
11/20/2025 04:20:19.714 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
11/20/2025 04:20:19.714 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e218a00> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
11/20/2025 04:20:19.714 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:19.714 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1742563035, session_epoch=7175, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.714 7fef7d6a6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7193 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1742563035, session_epoch=7175, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.714 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154880.838867, idle connection 332287.000000, request 304999.933481
11/20/2025 04:20:19.715 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154880.393066, idle connection 332286.000000, request 304999.501467
11/20/2025 04:20:19.825 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 136
11/20/2025 04:20:19.825 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
11/20/2025 04:20:19.825 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e151fa0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/20/2025 04:20:19.825 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/20/2025 04:20:19.826 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1471930004, session_epoch=7130, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.826 7fef7d7dccc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7153 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1471930004, session_epoch=7130, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:19.826 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154911.570068, idle connection 93777.000000, request 304999.926329
11/20/2025 04:20:19.826 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154911.127197, idle connection 93776.000000, request 304999.495745
11/20/2025 04:20:20.014 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 754
11/20/2025 04:20:20.014 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
11/20/2025 04:20:20.014 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1e1ca0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
11/20/2025 04:20:20.014 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:20.015 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=416489492, session_epoch=7200, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.015 7fef7ce84720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7223 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=416489492, session_epoch=7200, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.015 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153618.637695, idle connection 91240.000000, request 304999.932051
11/20/2025 04:20:20.015 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154214.420898, idle connection 330973.000000, request 304396.985292
11/20/2025 04:20:20.016 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153617.867188, idle connection 91239.000000, request 304999.173164
11/20/2025 04:20:20.016 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7192
11/20/2025 04:20:20.016 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.016 7fef7d6a6d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7192 (603.9295196533203 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2010034234, topics=[])
11/20/2025 04:20:20.016 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2010034234 with 0 response partitions (1 implied)
11/20/2025 04:20:20.055 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 230
11/20/2025 04:20:20.055 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
11/20/2025 04:20:20.055 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e15aa60> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
11/20/2025 04:20:20.055 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/20/2025 04:20:20.055 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668670850, session_epoch=7153, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.055 7fef7d6a6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7179 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668670850, session_epoch=7153, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.056 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154229.320312, idle connection 270193.000000, request 304999.947309
11/20/2025 04:20:20.056 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154228.814697, idle connection 270193.000000, request 304999.449492
11/20/2025 04:20:20.122 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3656
11/20/2025 04:20:20.122 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
11/20/2025 04:20:20.122 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e177f70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
11/20/2025 04:20:20.122 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/20/2025 04:20:20.123 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195533134, session_epoch=7635, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.123 7fef7ce84ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7658 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195533134, session_epoch=7635, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.123 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153632.198730, idle connection 393630.000000, request 304999.922514
11/20/2025 04:20:20.124 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153631.429932, idle connection 393629.000000, request 304999.131441
11/20/2025 04:20:20.225 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153358.302979, idle connection 266701.000000, request 304397.919893
11/20/2025 04:20:20.226 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7179
11/20/2025 04:20:20.226 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.226 7fef7ce84360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7179 (602.6773452758789 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=106984064, topics=[])
11/20/2025 04:20:20.226 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 106984064 with 0 response partitions (1 implied)
11/20/2025 04:20:20.240 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 2716
11/20/2025 04:20:20.240 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
11/20/2025 04:20:20.240 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e177dc0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
11/20/2025 04:20:20.240 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:20.241 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=556615688, session_epoch=7552, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.241 7fef7ce84d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7570 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=556615688, session_epoch=7552, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.241 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154620.092773, idle connection 332677.000000, request 304999.920607
11/20/2025 04:20:20.242 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154619.479736, idle connection 332676.000000, request 304999.319077
11/20/2025 04:20:20.271 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153177.086182, idle connection 393175.000000, request 304398.786783
11/20/2025 04:20:20.272 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7928
11/20/2025 04:20:20.272 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.272 7fef7ce84860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7928 (601.9620895385742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1891270261, topics=[])
11/20/2025 04:20:20.272 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1891270261 with 0 response partitions (1 implied)
11/20/2025 04:20:20.296 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153787.611816, idle connection 92896.000000, request 304398.300886
11/20/2025 04:20:20.297 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7666
11/20/2025 04:20:20.297 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.297 7fef7ce84220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7666 (602.2739410400391 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=953146994, topics=[])
11/20/2025 04:20:20.297 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 953146994 with 0 response partitions (1 implied)
11/20/2025 04:20:20.316 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154279.619141, idle connection 331686.000000, request 304398.712873
11/20/2025 04:20:20.316 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7193
11/20/2025 04:20:20.316 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.316 7fef7d6a6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7193 (602.0128726959229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1742563035, topics=[])
11/20/2025 04:20:20.316 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1742563035 with 0 response partitions (1 implied)
11/20/2025 04:20:20.427 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154310.573730, idle connection 93176.000000, request 304398.933649
11/20/2025 04:20:20.427 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7153
11/20/2025 04:20:20.427 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.428 7fef7d7dccc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7153 (601.6361713409424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1471930004, topics=[])
11/20/2025 04:20:20.428 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1471930004 with 0 response partitions (1 implied)
11/20/2025 04:20:20.618 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 329
11/20/2025 04:20:20.618 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
11/20/2025 04:20:20.618 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1714c0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
11/20/2025 04:20:20.618 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:20.618 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2010034234, session_epoch=7173, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.619 7fef7d6a6d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7193 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2010034234, session_epoch=7173, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.619 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153610.936035, idle connection 330370.000000, request 304999.939680
11/20/2025 04:20:20.619 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153014.496094, idle connection 90636.000000, request 304395.802498
11/20/2025 04:20:20.619 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153610.256592, idle connection 330369.000000, request 304999.270916
11/20/2025 04:20:20.620 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7223
11/20/2025 04:20:20.620 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.620 7fef7ce84720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7223 (605.0546169281006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=416489492, topics=[])
11/20/2025 04:20:20.620 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 416489492 with 0 response partitions (1 implied)
11/20/2025 04:20:20.657 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153628.168701, idle connection 269592.000000, request 304398.793221
11/20/2025 04:20:20.657 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7179
11/20/2025 04:20:20.657 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.658 7fef7d6a6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7179 (601.9718647003174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1668670850, topics=[])
11/20/2025 04:20:20.658 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1668670850 with 0 response partitions (1 implied)
11/20/2025 04:20:20.725 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153030.769287, idle connection 393028.000000, request 304398.499727
11/20/2025 04:20:20.725 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7658
11/20/2025 04:20:20.725 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.725 7fef7ce84ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7658 (602.1523475646973 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=195533134, topics=[])
11/20/2025 04:20:20.726 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 195533134 with 0 response partitions (1 implied)
11/20/2025 04:20:20.827 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 433
11/20/2025 04:20:20.827 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
11/20/2025 04:20:20.828 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e15a100> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
11/20/2025 04:20:20.828 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:20.828 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=106984064, session_epoch=7158, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.828 7fef7ce84360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7180 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=106984064, session_epoch=7158, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.828 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152755.487793, idle connection 266098.000000, request 304999.931097
11/20/2025 04:20:20.829 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152754.937500, idle connection 266097.000000, request 304999.389648
11/20/2025 04:20:20.842 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 154018.749512, idle connection 332075.000000, request 304398.578405
11/20/2025 04:20:20.843 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7570
11/20/2025 04:20:20.843 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:20.843 7fef7ce84d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7570 (602.1296977996826 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=556615688, topics=[])
11/20/2025 04:20:20.843 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 556615688 with 0 response partitions (1 implied)
11/20/2025 04:20:20.873 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 7007
11/20/2025 04:20:20.873 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
11/20/2025 04:20:20.873 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e177340> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
11/20/2025 04:20:20.873 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/20/2025 04:20:20.874 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1891270261, session_epoch=7920, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.874 7fef7ce84860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7929 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1891270261, session_epoch=7920, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.874 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152574.159912, idle connection 392572.000000, request 304999.937773
11/20/2025 04:20:20.875 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152573.610352, idle connection 392571.000000, request 304999.397278
11/20/2025 04:20:20.898 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3863
11/20/2025 04:20:20.898 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
11/20/2025 04:20:20.899 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e20bfa0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
11/20/2025 04:20:20.899 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:20.899 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=953146994, session_epoch=7652, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.899 7fef7ce84220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7667 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=953146994, session_epoch=7652, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.899 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153184.665283, idle connection 92293.000000, request 304999.946117
11/20/2025 04:20:20.900 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153184.180420, idle connection 92293.000000, request 304999.466896
11/20/2025 04:20:20.917 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 335
11/20/2025 04:20:20.917 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
11/20/2025 04:20:20.918 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1516d0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
11/20/2025 04:20:20.918 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:20.918 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1742563035, session_epoch=7176, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.918 7fef7d6a6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7194 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1742563035, session_epoch=7176, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:20.918 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153677.066650, idle connection 331083.000000, request 304999.947309
11/20/2025 04:20:20.919 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153676.639893, idle connection 331083.000000, request 304999.524117
11/20/2025 04:20:21.028 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 136
11/20/2025 04:20:21.029 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
11/20/2025 04:20:21.029 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e15ae80> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/20/2025 04:20:21.029 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/20/2025 04:20:21.029 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1471930004, session_epoch=7131, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.029 7fef7d7dccc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7154 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1471930004, session_epoch=7131, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.029 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153708.139160, idle connection 92573.000000, request 304999.912024
11/20/2025 04:20:21.030 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153707.473633, idle connection 92573.000000, request 304999.258041
11/20/2025 04:20:21.221 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 754
11/20/2025 04:20:21.221 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
11/20/2025 04:20:21.221 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1f9550> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
11/20/2025 04:20:21.221 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:21.221 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=416489492, session_epoch=7201, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.221 7fef7ce84720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7224 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=416489492, session_epoch=7201, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.222 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152411.991455, idle connection 90034.000000, request 304999.942303
11/20/2025 04:20:21.222 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153007.850098, idle connection 329767.000000, request 304396.862507
11/20/2025 04:20:21.222 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152411.295654, idle connection 90033.000000, request 304999.256611
11/20/2025 04:20:21.223 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7193
11/20/2025 04:20:21.223 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.223 7fef7d6a6d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7193 (604.0832996368408 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2010034234, topics=[])
11/20/2025 04:20:21.223 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2010034234 with 0 response partitions (1 implied)
11/20/2025 04:20:21.260 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 230
11/20/2025 04:20:21.260 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
11/20/2025 04:20:21.260 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1f96a0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
11/20/2025 04:20:21.260 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/20/2025 04:20:21.261 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668670850, session_epoch=7154, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.261 7fef7d6a6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 7180 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1668670850, session_epoch=7154, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.261 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153023.591553, idle connection 268988.000000, request 304999.917507
11/20/2025 04:20:21.262 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153022.960449, idle connection 268987.000000, request 304999.296904
11/20/2025 04:20:21.327 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3656
11/20/2025 04:20:21.327 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
11/20/2025 04:20:21.327 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e207250> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
11/20/2025 04:20:21.328 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/20/2025 04:20:21.328 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195533134, session_epoch=7636, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.328 7fef7ce84ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7659 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195533134, session_epoch=7636, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.328 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152427.230225, idle connection 392425.000000, request 304999.924898
11/20/2025 04:20:21.329 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152426.706543, idle connection 392424.000000, request 304999.414206
11/20/2025 04:20:21.430 7fef7ce84360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152153.614990, idle connection 265496.000000, request 304398.059368
11/20/2025 04:20:21.431 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7180
11/20/2025 04:20:21.431 7fef7ce84360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.431 7fef7ce84360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7180 (602.5550365447998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=106984064, topics=[])
11/20/2025 04:20:21.431 7fef7ce84360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 106984064 with 0 response partitions (1 implied)
11/20/2025 04:20:21.444 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 2716
11/20/2025 04:20:21.445 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
11/20/2025 04:20:21.445 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e15afd0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
11/20/2025 04:20:21.445 7fef7ce84d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:21.445 7fef7ce84d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=556615688, session_epoch=7553, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.445 7fef7ce84d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7571 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=556615688, session_epoch=7553, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.445 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153415.769043, idle connection 331472.000000, request 304999.932289
11/20/2025 04:20:21.446 7fef7ce84d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153414.968262, idle connection 331471.000000, request 304999.146461
11/20/2025 04:20:21.476 7fef7ce84860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 151972.358154, idle connection 391970.000000, request 304398.138523
11/20/2025 04:20:21.476 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7929
11/20/2025 04:20:21.476 7fef7ce84860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.476 7fef7ce84860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7929 (602.4396419525146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1891270261, topics=[])
11/20/2025 04:20:21.477 7fef7ce84860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1891270261 with 0 response partitions (1 implied)
11/20/2025 04:20:21.501 7fef7ce84220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152582.901123, idle connection 91692.000000, request 304398.175955
11/20/2025 04:20:21.501 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7667
11/20/2025 04:20:21.502 7fef7ce84220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.502 7fef7ce84220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7667 (602.5600433349609 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=953146994, topics=[])
11/20/2025 04:20:21.502 7fef7ce84220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 953146994 with 0 response partitions (1 implied)
11/20/2025 04:20:21.519 7fef7d6a6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153075.916504, idle connection 330482.000000, request 304398.796320
11/20/2025 04:20:21.520 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7194
11/20/2025 04:20:21.520 7fef7d6a6e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.520 7fef7d6a6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7194 (601.8674373626709 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1742563035, topics=[])
11/20/2025 04:20:21.520 7fef7d6a6e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1742563035 with 0 response partitions (1 implied)
11/20/2025 04:20:21.631 7fef7d7dccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 153106.863281, idle connection 91972.000000, request 304398.641109
11/20/2025 04:20:21.631 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7154
11/20/2025 04:20:21.631 7fef7d7dccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.631 7fef7d7dccc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7154 (601.9928455352783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1471930004, topics=[])
11/20/2025 04:20:21.632 7fef7d7dccc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1471930004 with 0 response partitions (1 implied)
11/20/2025 04:20:21.824 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 329
11/20/2025 04:20:21.824 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
11/20/2025 04:20:21.824 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fef7e1f9c40> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
11/20/2025 04:20:21.824 7fef7d6a6d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/20/2025 04:20:21.824 7fef7d6a6d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2010034234, session_epoch=7174, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.825 7fef7d6a6d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Request 7194 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2010034234, session_epoch=7174, topics=[], forgotten_topics_data=[])
11/20/2025 04:20:21.825 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152404.916748, idle connection 329164.000000, request 304999.884605
11/20/2025 04:20:21.825 7fef7ce84720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 151808.449463, idle connection 89430.000000, request 304396.409512
11/20/2025 04:20:21.825 7fef7d6a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152404.205078, idle connection 329163.000000, request 304999.240637
11/20/2025 04:20:21.826 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7224
11/20/2025 04:20:21.826 7fef7ce84720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.826 7fef7ce84720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.50:9092 <connected> [IPv4 ('10.0.0.50', 9092)]>: Response 7224 (604.3269634246826 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=416489492, topics=[])
11/20/2025 04:20:21.826 7fef7ce84720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 416489492 with 0 response partitions (1 implied)
11/20/2025 04:20:21.863 7fef7d6a6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 152422.227295, idle connection 268386.000000, request 304398.555756
11/20/2025 04:20:21.863 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7180
11/20/2025 04:20:21.863 7fef7d6a6f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.863 7fef7d6a6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 7180 (602.0004749298096 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1668670850, topics=[])
11/20/2025 04:20:21.863 7fef7d6a6f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1668670850 with 0 response partitions (1 implied)
11/20/2025 04:20:21.929 7fef7ce84ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 151826.084229, idle connection 391824.000000, request 304398.783684
11/20/2025 04:20:21.930 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7659
11/20/2025 04:20:21.930 7fef7ce84ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/20/2025 04:20:21.930 7fef7ce84ae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7659 (601.7653942108154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=195533134, topics=[])
11/20/2025 04:20:21.930 7fef7ce84ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 195533134 with 0 response partitions (1 implied)