08/03/2026 05:36:26.087 7f6139fed360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 8983 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1955606321, session_epoch=8976, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.088 7f6139fed360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283721.886230, idle connection 222364.000000, request 304999.893427
08/03/2026 05:36:26.089 7f6139fed360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283721.159912, idle connection 222363.000000, request 304999.182463
08/03/2026 05:36:26.090 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 528
08/03/2026 05:36:26.091 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
08/03/2026 05:36:26.091 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84b400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
08/03/2026 05:36:26.091 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.091 7f6139fed860 [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=1422282621, session_epoch=9088, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.091 7f6139fed860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9106 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1422282621, session_epoch=9088, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.091 7f6139fed860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284931.471680, idle connection 161401.000000, request 304999.943256
08/03/2026 05:36:26.092 7f6139fed860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284930.962402, idle connection 161401.000000, request 304999.436855
08/03/2026 05:36:26.214 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1829
08/03/2026 05:36:26.214 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
08/03/2026 05:36:26.215 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a87f760> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
08/03/2026 05:36:26.215 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
08/03/2026 05:36:26.215 7f6139e5de00 [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=1198951596, session_epoch=9343, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.215 7f6139e5de00 [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 9357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1198951596, session_epoch=9343, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.215 7f6139e5de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278194.104492, idle connection 217450.000000, request 304999.935865
08/03/2026 05:36:26.216 7f6139e5de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278193.533447, idle connection 217450.000000, request 304999.375343
08/03/2026 05:36:26.219 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 1834
08/03/2026 05:36:26.219 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
08/03/2026 05:36:26.220 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a8a0be0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
08/03/2026 05:36:26.220 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.220 7f6139fed4a0 [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=46832021, session_epoch=9441, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.220 7f6139fed4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9470 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=46832021, session_epoch=9441, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.220 7f6139fed4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275282.395508, idle connection 151375.000000, request 304999.950886
08/03/2026 05:36:26.221 7f6139fed4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275281.781250, idle connection 151374.000000, request 304999.336958
08/03/2026 05:36:26.267 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 327
08/03/2026 05:36:26.267 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
08/03/2026 05:36:26.267 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84b9a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
08/03/2026 05:36:26.267 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.268 7f6139fed720 [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=1190168408, session_epoch=9066, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.268 7f6139fed720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9079 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1190168408, session_epoch=9066, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.268 7f6139fed720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288549.298584, idle connection 227241.000000, request 304999.918222
08/03/2026 05:36:26.269 7f6139fed720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288548.430664, idle connection 227240.000000, request 304999.066830
08/03/2026 05:36:26.293 7f6139fed040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276286.251221, idle connection 215133.000000, request 304398.314238
08/03/2026 05:36:26.294 7f6139fed040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9458
08/03/2026 05:36:26.294 7f6139fed040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:26.294 7f6139fed040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9458 (602.5688648223877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1689681842, topics=[])
08/03/2026 05:36:26.295 7f6139fed040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1689681842 with 0 response partitions (1 implied)
08/03/2026 05:36:26.491 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 297
08/03/2026 05:36:26.491 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
08/03/2026 05:36:26.491 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a87b430> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
08/03/2026 05:36:26.491 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
08/03/2026 05:36:26.491 7f6139fed400 [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=1799887468, session_epoch=9050, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.491 7f6139fed400 [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 9065 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799887468, session_epoch=9050, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.492 7f6139fed400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280087.259277, idle connection 156492.000000, request 304999.928951
08/03/2026 05:36:26.492 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 221
08/03/2026 05:36:26.492 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
08/03/2026 05:36:26.492 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a87bd30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
08/03/2026 05:36:26.492 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.492 7f6139fed900 [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=889415599, session_epoch=9040, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.493 7f6139fed900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9060 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=889415599, session_epoch=9040, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.493 7f6139fed900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283708.718506, idle connection 96233.000000, request 304999.934673
08/03/2026 05:36:26.494 7f6139fed400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280085.093506, idle connection 156490.000000, request 304997.768879
08/03/2026 05:36:26.494 7f6139fed900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283707.176514, idle connection 96231.000000, request 304998.401403
08/03/2026 05:36:26.553 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3546
08/03/2026 05:36:26.554 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
08/03/2026 05:36:26.554 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84a310> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
08/03/2026 05:36:26.554 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.554 7f6139fedb80 [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=428584867, session_epoch=9646, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.554 7f6139fedb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9659 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=428584867, session_epoch=9646, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.555 7f6139fedb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277665.376465, idle connection 453871.000000, request 304999.930382
08/03/2026 05:36:26.555 7f6139fedb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277664.765381, idle connection 453871.000000, request 304999.330044
08/03/2026 05:36:26.641 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 251
08/03/2026 05:36:26.641 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
08/03/2026 05:36:26.641 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a8a0040> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
08/03/2026 05:36:26.641 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.641 7f6139fedd60 [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=902085858, session_epoch=9052, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.642 7f6139fedd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9063 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=902085858, session_epoch=9052, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.642 7f6139fedd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282490.557617, idle connection 221324.000000, request 304999.934673
08/03/2026 05:36:26.642 7f6139fedd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282490.020752, idle connection 221324.000000, request 304999.409676
08/03/2026 05:36:26.643 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 310
08/03/2026 05:36:26.643 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
08/03/2026 05:36:26.643 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a7c33a0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
08/03/2026 05:36:26.643 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
08/03/2026 05:36:26.643 7f6139feda40 [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=1349326030, session_epoch=9063, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.643 7f6139feda40 [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 9073 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349326030, session_epoch=9063, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.643 7f6139feda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281280.869873, idle connection 219723.000000, request 304999.947309
08/03/2026 05:36:26.643 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6948
08/03/2026 05:36:26.644 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
08/03/2026 05:36:26.644 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a86e2b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
08/03/2026 05:36:26.644 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.644 7f6139fedea0 [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=643884079, session_epoch=10019, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.644 7f6139fedea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 10044 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=643884079, session_epoch=10019, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.644 7f6139fedea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277559.047363, idle connection 216327.000000, request 304999.959230
08/03/2026 05:36:26.645 7f6139feda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281279.594482, idle connection 219721.000000, request 304998.673916
08/03/2026 05:36:26.645 7f6139fedea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277558.261230, idle connection 216326.000000, request 304999.176264
08/03/2026 05:36:26.691 7f6139fed360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283119.203125, idle connection 221761.000000, request 304397.215605
08/03/2026 05:36:26.691 7f6139fed360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8983
08/03/2026 05:36:26.691 7f6139fed360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:26.692 7f6139fed360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 8983 (603.600263595581 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1955606321, topics=[])
08/03/2026 05:36:26.692 7f6139fed360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1955606321 with 0 response partitions (1 implied)
08/03/2026 05:36:26.693 7f6139fed860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284329.849854, idle connection 160799.000000, request 304398.319006
08/03/2026 05:36:26.693 7f6139fed860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9106
08/03/2026 05:36:26.693 7f6139fed860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:26.694 7f6139fed860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9106 (602.3359298706055 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1422282621, topics=[])
08/03/2026 05:36:26.694 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1422282621 with 0 response partitions (1 implied)
08/03/2026 05:36:26.818 7f6139e5de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277591.700195, idle connection 216848.000000, request 304397.530317
08/03/2026 05:36:26.818 7f6139e5de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9357
08/03/2026 05:36:26.818 7f6139e5de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:26.818 7f6139e5de00 [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 9357 (603.3284664154053 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1198951596, topics=[])
08/03/2026 05:36:26.819 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1198951596 with 0 response partitions (1 implied)
08/03/2026 05:36:26.821 7f6139fed4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274680.973877, idle connection 150773.000000, request 304398.528337
08/03/2026 05:36:26.822 7f6139fed4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9470
08/03/2026 05:36:26.822 7f6139fed4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:26.822 7f6139fed4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9470 (602.0417213439941 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=46832021, topics=[])
08/03/2026 05:36:26.822 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 46832021 with 0 response partitions (1 implied)
08/03/2026 05:36:26.870 7f6139fed720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287946.858887, idle connection 226639.000000, request 304397.483587
08/03/2026 05:36:26.871 7f6139fed720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9079
08/03/2026 05:36:26.871 7f6139fed720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:26.871 7f6139fed720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9079 (603.2650470733643 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1190168408, topics=[])
08/03/2026 05:36:26.871 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1190168408 with 0 response partitions (1 implied)
08/03/2026 05:36:26.896 7f6139fed040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 2015
08/03/2026 05:36:26.896 7f6139fed040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
08/03/2026 05:36:26.896 7f6139fed040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a80e280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
08/03/2026 05:36:26.897 7f6139fed040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:26.897 7f6139fed040 [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=1689681842, session_epoch=9442, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.897 7f6139fed040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1689681842, session_epoch=9442, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:26.897 7f6139fed040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275682.635010, idle connection 214529.000000, request 304999.922991
08/03/2026 05:36:26.898 7f6139fed040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275682.030273, idle connection 214528.000000, request 304999.328375
08/03/2026 05:36:27.095 7f6139fed400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279483.572754, idle connection 155888.000000, request 304396.240950
08/03/2026 05:36:27.096 7f6139fed400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9065
08/03/2026 05:36:27.096 7f6139fed400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.096 7f6139fed400 [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 9065 (604.4087409973145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1799887468, topics=[])
08/03/2026 05:36:27.096 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1799887468 with 0 response partitions (1 implied)
08/03/2026 05:36:27.096 7f6139fed900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283105.089111, idle connection 95629.000000, request 304396.313190
08/03/2026 05:36:27.097 7f6139fed900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9060
08/03/2026 05:36:27.097 7f6139fed900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.097 7f6139fed900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9060 (604.0217876434326 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=889415599, topics=[])
08/03/2026 05:36:27.097 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 889415599 with 0 response partitions (1 implied)
08/03/2026 05:36:27.156 7f6139fedb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277064.173340, idle connection 453270.000000, request 304398.729563
08/03/2026 05:36:27.156 7f6139fedb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9659
08/03/2026 05:36:27.156 7f6139fedb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.156 7f6139fedb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9659 (601.8400192260742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=428584867, topics=[])
08/03/2026 05:36:27.157 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 428584867 with 0 response partitions (1 implied)
08/03/2026 05:36:27.245 7f6139fedd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281887.706055, idle connection 220721.000000, request 304397.083759
08/03/2026 05:36:27.245 7f6139fedd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9063
08/03/2026 05:36:27.245 7f6139fedd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.245 7f6139fedd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9063 (603.5492420196533 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=902085858, topics=[])
08/03/2026 05:36:27.245 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 902085858 with 0 response partitions (1 implied)
08/03/2026 05:36:27.246 7f6139feda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280678.368652, idle connection 219120.000000, request 304397.447348
08/03/2026 05:36:27.246 7f6139fedea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276957.219482, idle connection 215725.000000, request 304398.133516
08/03/2026 05:36:27.246 7f6139feda40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9073
08/03/2026 05:36:27.246 7f6139feda40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.246 7f6139feda40 [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 9073 (603.08837890625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349326030, topics=[])
08/03/2026 05:36:27.246 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1349326030 with 0 response partitions (1 implied)
08/03/2026 05:36:27.247 7f6139fedea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10044
08/03/2026 05:36:27.247 7f6139fedea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.247 7f6139fedea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 10044 (602.7655601501465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=643884079, topics=[])
08/03/2026 05:36:27.247 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 643884079 with 0 response partitions (1 implied)
08/03/2026 05:36:27.293 7f6139fed360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/03/2026 05:36:27.293 7f6139fed360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
08/03/2026 05:36:27.293 7f6139fed360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a8360a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
08/03/2026 05:36:27.293 7f6139fed360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.293 7f6139fed360 [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=1955606321, session_epoch=8977, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.294 7f6139fed360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 8984 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1955606321, session_epoch=8977, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.294 7f6139fed360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282516.214111, idle connection 221158.000000, request 304999.925375
08/03/2026 05:36:27.294 7f6139fed360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282515.567383, idle connection 221157.000000, request 304999.290943
08/03/2026 05:36:27.295 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 528
08/03/2026 05:36:27.295 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
08/03/2026 05:36:27.295 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a87bee0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
08/03/2026 05:36:27.295 7f6139fed860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.295 7f6139fed860 [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=1422282621, session_epoch=9089, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.295 7f6139fed860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9107 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1422282621, session_epoch=9089, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.295 7f6139fed860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283727.306396, idle connection 160197.000000, request 304999.944448
08/03/2026 05:36:27.296 7f6139fed860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283726.780273, idle connection 160196.000000, request 304999.422312
08/03/2026 05:36:27.419 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1829
08/03/2026 05:36:27.420 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
08/03/2026 05:36:27.420 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a7c3880> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
08/03/2026 05:36:27.420 7f6139e5de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
08/03/2026 05:36:27.420 7f6139e5de00 [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=1198951596, session_epoch=9344, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.420 7f6139e5de00 [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 9358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1198951596, session_epoch=9344, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.420 7f6139e5de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276988.813965, idle connection 216245.000000, request 304999.932766
08/03/2026 05:36:27.421 7f6139e5de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276988.236328, idle connection 216244.000000, request 304999.368429
08/03/2026 05:36:27.424 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 1834
08/03/2026 05:36:27.424 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
08/03/2026 05:36:27.424 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a836fd0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
08/03/2026 05:36:27.424 7f6139fed4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.424 7f6139fed4a0 [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=46832021, session_epoch=9442, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.424 7f6139fed4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9471 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=46832021, session_epoch=9442, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.424 7f6139fed4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274078.090332, idle connection 150170.000000, request 304999.948502
08/03/2026 05:36:27.425 7f6139fed4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274077.674805, idle connection 150170.000000, request 304999.536991
08/03/2026 05:36:27.473 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 327
08/03/2026 05:36:27.473 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
08/03/2026 05:36:27.474 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a87f760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
08/03/2026 05:36:27.474 7f6139fed720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.474 7f6139fed720 [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=1190168408, session_epoch=9067, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.474 7f6139fed720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9080 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1190168408, session_epoch=9067, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.475 7f6139fed720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287342.736572, idle connection 226035.000000, request 304999.867201
08/03/2026 05:36:27.475 7f6139fed720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287341.893555, idle connection 226034.000000, request 304999.078512
08/03/2026 05:36:27.498 7f6139fed040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275081.275879, idle connection 213928.000000, request 304398.562431
08/03/2026 05:36:27.499 7f6139fed040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9459
08/03/2026 05:36:27.499 7f6139fed040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
08/03/2026 05:36:27.499 7f6139fed040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 9459 (602.3387908935547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1689681842, topics=[])
08/03/2026 05:36:27.500 7f6139fed040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1689681842 with 0 response partitions (1 implied)
08/03/2026 05:36:27.697 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 297
08/03/2026 05:36:27.698 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
08/03/2026 05:36:27.698 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84aa90> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
08/03/2026 05:36:27.698 7f6139fed400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
08/03/2026 05:36:27.698 7f6139fed400 [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=1799887468, session_epoch=9051, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.698 7f6139fed400 [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 9066 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799887468, session_epoch=9051, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.699 7f6139fed400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278880.314941, idle connection 155285.000000, request 304999.921322
08/03/2026 05:36:27.699 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 221
08/03/2026 05:36:27.699 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
08/03/2026 05:36:27.699 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84b6d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
08/03/2026 05:36:27.699 7f6139fed900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.699 7f6139fed900 [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=889415599, session_epoch=9041, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.700 7f6139fed900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9061 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=889415599, session_epoch=9041, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.700 7f6139fed900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282501.749512, idle connection 95026.000000, request 304999.950171
08/03/2026 05:36:27.701 7f6139fed400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278878.315430, idle connection 155283.000000, request 304997.938633
08/03/2026 05:36:27.701 7f6139fed900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282500.369385, idle connection 95024.000000, request 304998.401165
08/03/2026 05:36:27.759 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3546
08/03/2026 05:36:27.759 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
08/03/2026 05:36:27.759 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84af70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
08/03/2026 05:36:27.759 7f6139fedb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.759 7f6139fedb80 [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=428584867, session_epoch=9647, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.760 7f6139fedb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9660 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=428584867, session_epoch=9647, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.760 7f6139fedb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276460.277588, idle connection 452666.000000, request 304999.930143
08/03/2026 05:36:27.760 7f6139fedb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276459.703613, idle connection 452665.000000, request 304999.367237
08/03/2026 05:36:27.847 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 251
08/03/2026 05:36:27.847 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
08/03/2026 05:36:27.847 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84b280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
08/03/2026 05:36:27.847 7f6139fedd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.847 7f6139fedd60 [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=902085858, session_epoch=9053, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.847 7f6139fedd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 9064 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=902085858, session_epoch=9053, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.848 7f6139fedd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281284.755371, idle connection 220118.000000, request 304999.932051
08/03/2026 05:36:27.848 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 310
08/03/2026 05:36:27.848 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
08/03/2026 05:36:27.848 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84a400> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
08/03/2026 05:36:27.848 7f6139feda40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
08/03/2026 05:36:27.848 7f6139feda40 [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=1349326030, session_epoch=9064, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.848 7f6139feda40 [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 9074 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349326030, session_epoch=9064, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.849 7f6139feda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280075.492188, idle connection 218517.000000, request 304999.951124
08/03/2026 05:36:27.849 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6948
08/03/2026 05:36:27.849 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
08/03/2026 05:36:27.849 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f613a84a9a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
08/03/2026 05:36:27.849 7f6139fedea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/03/2026 05:36:27.849 7f6139fedea0 [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=643884079, session_epoch=10020, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.849 7f6139fedea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 10045 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=643884079, session_epoch=10020, topics=[], forgotten_topics_data=[])
08/03/2026 05:36:27.850 7f6139fedea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276353.429199, idle connection 215121.000000, request 304999.902964
08/03/2026 05:36:27.850 7f6139fedd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281282.128174, idle connection 220116.000000, request 304997.319221
08/03/2026 05:36:27.851 7f6139feda40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280073.473633, idle connection 218515.000000, request 304997.937202
08/03/2026 05:36:27.851 7f6139fedea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276352.058350, idle connection 215120.000000, request 304998.542786