05/22/2025 02:06:53.194 7f6ff8d43630 [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=498161571, session_epoch=446, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.195 7f6ff8d43630 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 449 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=498161571, session_epoch=446, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.195 7f6ff8d43630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62147.474365, idle connection 1335.000000, request 304999.932528
05/22/2025 02:06:53.195 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19
05/22/2025 02:06:53.195 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
05/22/2025 02:06:53.195 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff71f29e8> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
05/22/2025 02:06:53.195 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.195 7f6ff91076d8 [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=1984374821, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.195 7f6ff91076d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1984374821, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.196 7f6ff91076d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62597.173340, idle connection 1377.000000, request 304999.957323
05/22/2025 02:06:53.196 7f6ff8d43630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62146.297852, idle connection 1333.000000, request 304998.765469
05/22/2025 02:06:53.196 7f6ff91076d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62596.492676, idle connection 1377.000000, request 304999.280453
05/22/2025 02:06:53.196 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
05/22/2025 02:06:53.196 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
05/22/2025 02:06:53.197 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff71f2d68> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
05/22/2025 02:06:53.197 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.197 7f6ffa53dac8 [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=1320440397, session_epoch=446, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.197 7f6ffa53dac8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 449 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1320440397, session_epoch=446, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.197 7f6ffa53dac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62201.263672, idle connection 1304.000000, request 304999.959946
05/22/2025 02:06:53.197 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 127
05/22/2025 02:06:53.197 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
05/22/2025 02:06:53.197 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cf51d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
05/22/2025 02:06:53.197 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.197 7f6ff8d43438 [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=867624517, session_epoch=473, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.198 7f6ff8d43438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 476 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867624517, session_epoch=473, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.198 7f6ff8d43438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62524.108154, idle connection 1319.000000, request 304999.959469
05/22/2025 02:06:53.198 7f6ffa53dac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62200.211426, idle connection 1303.000000, request 304998.909712
05/22/2025 02:06:53.198 7f6ff8d43438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62523.524902, idle connection 1318.000000, request 304999.379158
05/22/2025 02:06:53.264 7f6ff9067f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62319.185791, idle connection 1415.000000, request 304398.042440
05/22/2025 02:06:53.264 7f6ff9067f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 461
05/22/2025 02:06:53.264 7f6ff9067f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.264 7f6ff9067f60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 461 (602.506160736084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1930143028, topics=[])
05/22/2025 02:06:53.264 7f6ff9067f60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1930143028 with 0 response partitions (1 implied)
05/22/2025 02:06:53.265 7f6ff90ea4e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63223.819580, idle connection 1441.000000, request 304397.786140
05/22/2025 02:06:53.265 7f6ff90ea4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 464
05/22/2025 02:06:53.265 7f6ff90ea4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.265 7f6ff90ea4e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 464 (602.5605201721191 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=884375702, topics=[])
05/22/2025 02:06:53.265 7f6ff90ea4e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 884375702 with 0 response partitions (1 implied)
05/22/2025 02:06:53.292 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122
05/22/2025 02:06:53.292 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
05/22/2025 02:06:53.292 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff7146828> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
05/22/2025 02:06:53.292 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.292 7f6ff56caa20 [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=820021122, session_epoch=479, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.293 7f6ff56caa20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 482 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=820021122, session_epoch=479, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.293 7f6ff56caa20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62721.952393, idle connection 1524.000000, request 304999.939919
05/22/2025 02:06:53.293 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 313
05/22/2025 02:06:53.293 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
05/22/2025 02:06:53.293 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6ccf320> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
05/22/2025 02:06:53.293 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.293 7f6ff897d588 [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=828377855, session_epoch=486, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.293 7f6ff897d588 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 489 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828377855, session_epoch=486, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.293 7f6ff897d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63468.198730, idle connection 1628.000000, request 304999.958515
05/22/2025 02:06:53.294 7f6ff56caa20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62720.808838, idle connection 1523.000000, request 304998.803616
05/22/2025 02:06:53.294 7f6ff897d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63467.454102, idle connection 1627.000000, request 304999.216557
05/22/2025 02:06:53.313 7f6ff8920cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63034.343262, idle connection 1488.000000, request 304399.005890
05/22/2025 02:06:53.313 7f6ff8920cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 476
05/22/2025 02:06:53.313 7f6ff8920cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.313 7f6ff8920cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 476 (601.6931533813477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=757892903, topics=[])
05/22/2025 02:06:53.314 7f6ff8920cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 757892903 with 0 response partitions (1 implied)
05/22/2025 02:06:53.317 7f6ff88b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63319.312256, idle connection 1583.000000, request 304397.883654
05/22/2025 02:06:53.317 7f6ff88b8eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 481
05/22/2025 02:06:53.317 7f6ff88b8eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.317 7f6ff88b8eb8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 481 (602.5698184967041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1197823429, topics=[])
05/22/2025 02:06:53.317 7f6ff88b8eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1197823429 with 0 response partitions (1 implied)
05/22/2025 02:06:53.319 7f6ff8c7a438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62910.050781, idle connection 1341.000000, request 304399.306774
05/22/2025 02:06:53.320 7f6ff8c7a438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456
05/22/2025 02:06:53.320 7f6ff8c7a438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.320 7f6ff8c7a438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 456 (601.0379791259766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=986624794, topics=[])
05/22/2025 02:06:53.320 7f6ff8c7a438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 986624794 with 0 response partitions (1 implied)
05/22/2025 02:06:53.360 7f6ff8963eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62976.154297, idle connection 1412.000000, request 304398.798943
05/22/2025 02:06:53.361 7f6ff8963eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 463
05/22/2025 02:06:53.361 7f6ff8963eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.361 7f6ff8963eb8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 463 (601.7429828643799 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=67482812, topics=[])
05/22/2025 02:06:53.361 7f6ff8963eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 67482812 with 0 response partitions (1 implied)
05/22/2025 02:06:53.367 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 55
05/22/2025 02:06:53.368 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
05/22/2025 02:06:53.368 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cf56a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
05/22/2025 02:06:53.368 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.368 7f6ff90ddb70 [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=1394155307, session_epoch=458, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.368 7f6ff90ddb70 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 461 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394155307, session_epoch=458, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.368 7f6ff90ddb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62257.302734, idle connection 1498.000000, request 304999.948978
05/22/2025 02:06:53.368 7f6ff90ddb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62256.875732, idle connection 1498.000000, request 304999.525547
05/22/2025 02:06:53.375 7f6ff88b50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62790.323486, idle connection 1506.000000, request 304398.549318
05/22/2025 02:06:53.376 7f6ff88b50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 471
05/22/2025 02:06:53.376 7f6ff88b50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.376 7f6ff88b50f0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 471 (601.9272804260254 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1751949969, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\x84\x00\x00\x01\xeb\x00\x00\x00\x00\x02I\xc2|\xfa\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xb6\x03\x00\x00\x00\xf8\x02ObjectGeneratorInfo:cn-jenkins-d...')])])
05/22/2025 02:06:53.376 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1751949969 with 1 response partitions (0 implied)
05/22/2025 02:06:53.376 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 503 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 132
05/22/2025 02:06:53.376 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 132 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0)
05/22/2025 02:06:53.377 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 134 (leader epoch 0)
05/22/2025 02:06:53.378 7f6ff90cf048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62740.393555, idle connection 1114.000000, request 304398.703814
05/22/2025 02:06:53.379 7f6ff90cf048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 666
05/22/2025 02:06:53.379 7f6ff90cf048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.379 7f6ff90cf048 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 666 (601.6435623168945 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=244628027, topics=[])
05/22/2025 02:06:53.379 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 244628027 with 0 response partitions (1 implied)
05/22/2025 02:06:53.381 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 12
05/22/2025 02:06:53.382 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
05/22/2025 02:06:53.382 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d588> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
05/22/2025 02:06:53.382 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.382 7f6ff90ddcc0 [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=292220102, session_epoch=451, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.382 7f6ff90ddcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 454 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=292220102, session_epoch=451, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.382 7f6ff90ddcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62877.040283, idle connection 1224.000000, request 304999.954224
05/22/2025 02:06:53.382 7f6ff90ddcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62876.666016, idle connection 1224.000000, request 304999.582291
05/22/2025 02:06:53.417 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 27
05/22/2025 02:06:53.417 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
05/22/2025 02:06:53.417 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6b14860> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
05/22/2025 02:06:53.417 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.417 7f6ff8c44438 [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=1652851454, session_epoch=453, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.417 7f6ff8c44438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1652851454, session_epoch=453, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.417 7f6ff8c44438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62306.149170, idle connection 1312.000000, request 304999.942541
05/22/2025 02:06:53.418 7f6ff8c44438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62305.735352, idle connection 1312.000000, request 304999.535561
05/22/2025 02:06:53.418 7f6ff90cf6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62046.291748, idle connection 1142.000000, request 304398.360729
05/22/2025 02:06:53.418 7f6ff90cf6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456
05/22/2025 02:06:53.418 7f6ff90cf6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.419 7f6ff90cf6d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 456 (602.0698547363281 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=421764578, topics=[])
05/22/2025 02:06:53.419 7f6ff90cf6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 421764578 with 0 response partitions (1 implied)
05/22/2025 02:06:53.420 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2
05/22/2025 02:06:53.420 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
05/22/2025 02:06:53.420 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d390> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
05/22/2025 02:06:53.420 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.420 7f6ff8d43240 [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=1433727324, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.420 7f6ff8d43240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 450 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1433727324, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.420 7f6ff8d43240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62199.780029, idle connection 1124.000000, request 304999.957800
05/22/2025 02:06:53.421 7f6ff8d43240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62199.382324, idle connection 1124.000000, request 304999.562263
05/22/2025 02:06:53.422 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
05/22/2025 02:06:53.422 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
05/22/2025 02:06:53.422 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6b14208> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
05/22/2025 02:06:53.422 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.422 7f6ff8d3fd68 [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=1022119500, session_epoch=446, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.422 7f6ff8d3fd68 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 449 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1022119500, session_epoch=446, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.423 7f6ff8d3fd68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62200.929688, idle connection 1322.000000, request 304999.959469
05/22/2025 02:06:53.423 7f6ff8d3fd68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62200.612793, idle connection 1322.000000, request 304999.644756
05/22/2025 02:06:53.471 7f6ff8563240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62248.377930, idle connection 1493.000000, request 304398.035765
05/22/2025 02:06:53.472 7f6ff8563240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 477
05/22/2025 02:06:53.472 7f6ff8563240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.472 7f6ff8563240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 477 (602.6384830474854 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1212029852, topics=[])
05/22/2025 02:06:53.472 7f6ff8563240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1212029852 with 0 response partitions (1 implied)
05/22/2025 02:06:53.477 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 134
05/22/2025 02:06:53.477 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
05/22/2025 02:06:53.477 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cf5390> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
05/22/2025 02:06:53.477 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.477 7f6ff88b50f0 [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=1751949969, session_epoch=469, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=134, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/22/2025 02:06:53.478 7f6ff88b50f0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 472 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1751949969, session_epoch=469, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=134, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/22/2025 02:06:53.478 7f6ff88b50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62687.899414, idle connection 1404.000000, request 304999.945164
05/22/2025 02:06:53.478 7f6ff88b50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62687.479980, idle connection 1404.000000, request 304999.530315
05/22/2025 02:06:53.524 7f6ff918a198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62631.750488, idle connection 1423.000000, request 304398.991346
05/22/2025 02:06:53.524 7f6ff918a198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 470
05/22/2025 02:06:53.524 7f6ff918a198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.524 7f6ff918a198 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 470 (601.5188694000244 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1093382742, topics=[])
05/22/2025 02:06:53.524 7f6ff918a198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1093382742 with 0 response partitions (1 implied)
05/22/2025 02:06:53.531 7f6ff8526d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62470.746094, idle connection 1455.000000, request 304399.188995
05/22/2025 02:06:53.531 7f6ff8526d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 482
05/22/2025 02:06:53.531 7f6ff8526d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.532 7f6ff8526d68 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 482 (601.3178825378418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1304324850, topics=[])
05/22/2025 02:06:53.532 7f6ff8526d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1304324850 with 0 response partitions (1 implied)
05/22/2025 02:06:53.673 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 46
05/22/2025 02:06:53.674 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
05/22/2025 02:06:53.674 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff719b160> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
05/22/2025 02:06:53.674 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.674 7f6ff8999240 [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=1648521419, session_epoch=455, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.674 7f6ff8999240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1648521419, session_epoch=455, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.674 7f6ff8999240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61763.630371, idle connection 1041.000000, request 304999.933243
05/22/2025 02:06:53.675 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5
05/22/2025 02:06:53.675 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
05/22/2025 02:06:53.675 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d2b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
05/22/2025 02:06:53.675 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.675 7f6ff909c240 [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=1917713502, session_epoch=448, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.675 7f6ff909c240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 451 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1917713502, session_epoch=448, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.675 7f6ff909c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62151.773438, idle connection 955.000000, request 304999.955654
05/22/2025 02:06:53.675 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 24
05/22/2025 02:06:53.675 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
05/22/2025 02:06:53.675 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6d7ce48> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
05/22/2025 02:06:53.675 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.676 7f6ff8c67390 [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=947019289, session_epoch=451, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.676 7f6ff8c67390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 454 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=947019289, session_epoch=451, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.676 7f6ff8c67390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62365.429932, idle connection 1105.000000, request 304999.945164
05/22/2025 02:06:53.676 7f6ff8999240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61761.695312, idle connection 1039.000000, request 304998.008251
05/22/2025 02:06:53.676 7f6ff90a8390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62799.963135, idle connection 1170.000000, request 304399.081230
05/22/2025 02:06:53.677 7f6ff909c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62150.142334, idle connection 954.000000, request 304998.328209
05/22/2025 02:06:53.677 7f6ff8c67390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62364.212402, idle connection 1104.000000, request 304998.730898
05/22/2025 02:06:53.677 7f6ff90a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 488
05/22/2025 02:06:53.677 7f6ff90a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.678 7f6ff90a8390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 488 (602.0092964172363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1102405260, topics=[])
05/22/2025 02:06:53.678 7f6ff90a8390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1102405260 with 0 response partitions (1 implied)
05/22/2025 02:06:53.690 7f6ff906ba20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62641.444580, idle connection 924.000000, request 304398.215532
05/22/2025 02:06:53.690 7f6ff906ba20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454
05/22/2025 02:06:53.690 7f6ff906ba20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.690 7f6ff906ba20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 454 (602.2932529449463 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2115849236, topics=[])
05/22/2025 02:06:53.690 7f6ff906ba20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2115849236 with 0 response partitions (1 implied)
05/22/2025 02:06:53.690 7f6ff906c390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61618.802734, idle connection 906.000000, request 304398.053169
05/22/2025 02:06:53.691 7f6ff906c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455
05/22/2025 02:06:53.691 7f6ff906c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.691 7f6ff906c390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 455 (602.2799015045166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1076439384, topics=[])
05/22/2025 02:06:53.691 7f6ff906c390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1076439384 with 0 response partitions (1 implied)
05/22/2025 02:06:53.739 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 30
05/22/2025 02:06:53.739 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
05/22/2025 02:06:53.739 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6d80908> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
05/22/2025 02:06:53.740 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.740 7f6ff90e58d0 [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=516824156, session_epoch=456, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.740 7f6ff90e58d0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=516824156, session_epoch=456, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.740 7f6ff90e58d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62693.176270, idle connection 916.000000, request 304999.936104
05/22/2025 02:06:53.740 7f6ff90e58d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62692.694092, idle connection 916.000000, request 304999.462366
05/22/2025 02:06:53.797 7f6ff8d43630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61545.541260, idle connection 733.000000, request 304397.997618
05/22/2025 02:06:53.797 7f6ff8d43630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 449
05/22/2025 02:06:53.797 7f6ff8d43630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.797 7f6ff8d43630 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 449 (602.6105880737305 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=498161571, topics=[])
05/22/2025 02:06:53.797 7f6ff8d43630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 498161571 with 0 response partitions (1 implied)
05/22/2025 02:06:53.798 7f6ff91076d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61994.995605, idle connection 775.000000, request 304397.779226
05/22/2025 02:06:53.798 7f6ff91076d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455
05/22/2025 02:06:53.798 7f6ff91076d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.798 7f6ff91076d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 455 (602.586030960083 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1984374821, topics=[])
05/22/2025 02:06:53.798 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1984374821 with 0 response partitions (1 implied)
05/22/2025 02:06:53.799 7f6ffa53dac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61599.658447, idle connection 702.000000, request 304398.354769
05/22/2025 02:06:53.799 7f6ffa53dac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 449
05/22/2025 02:06:53.799 7f6ffa53dac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.799 7f6ffa53dac8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 449 (602.0092964172363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1320440397, topics=[])
05/22/2025 02:06:53.799 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1320440397 with 0 response partitions (1 implied)
05/22/2025 02:06:53.799 7f6ff8d43438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61922.521973, idle connection 717.000000, request 304398.373365
05/22/2025 02:06:53.799 7f6ff8d43438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 476
05/22/2025 02:06:53.800 7f6ff8d43438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.800 7f6ff8d43438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 476 (601.9992828369141 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=867624517, topics=[])
05/22/2025 02:06:53.800 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 867624517 with 0 response partitions (1 implied)
05/22/2025 02:06:53.865 7f6ff9067f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 50
05/22/2025 02:06:53.865 7f6ff9067f60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
05/22/2025 02:06:53.865 7f6ff9067f60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d518> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
05/22/2025 02:06:53.865 7f6ff9067f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.865 7f6ff9067f60 [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=1930143028, session_epoch=459, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.865 7f6ff9067f60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 462 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1930143028, session_epoch=459, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.865 7f6ff9067f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61717.286133, idle connection 813.000000, request 304999.941826
05/22/2025 02:06:53.866 7f6ff90ea4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 54
05/22/2025 02:06:53.866 7f6ff90ea4e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
05/22/2025 02:06:53.866 7f6ff90ea4e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff713be10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
05/22/2025 02:06:53.866 7f6ff90ea4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.866 7f6ff90ea4e0 [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=884375702, session_epoch=462, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.866 7f6ff90ea4e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 465 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=884375702, session_epoch=462, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.866 7f6ff90ea4e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62622.209229, idle connection 839.000000, request 304999.956131
05/22/2025 02:06:53.867 7f6ff9067f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61716.154297, idle connection 811.000000, request 304998.817205
05/22/2025 02:06:53.867 7f6ff90ea4e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62621.487061, idle connection 838.000000, request 304999.237537
05/22/2025 02:06:53.895 7f6ff56caa20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62120.084473, idle connection 922.000000, request 304398.077965
05/22/2025 02:06:53.895 7f6ff56caa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 482
05/22/2025 02:06:53.895 7f6ff56caa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.895 7f6ff56caa20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 482 (602.564811706543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=820021122, topics=[])
05/22/2025 02:06:53.895 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 820021122 with 0 response partitions (1 implied)
05/22/2025 02:06:53.896 7f6ff897d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62865.831787, idle connection 1026.000000, request 304397.586346
05/22/2025 02:06:53.896 7f6ff897d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 489
05/22/2025 02:06:53.896 7f6ff897d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.896 7f6ff897d588 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 489 (602.9021739959717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=828377855, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=315, last_stable_offset=315, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x019\x00\x00\x01\xfb\x00\x00\x00\x00\x02\x8fw\xb4\x88\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xc6\x03\x00\x00\x00\x88\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
05/22/2025 02:06:53.896 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 828377855 with 1 response partitions (0 implied)
05/22/2025 02:06:53.897 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 519 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 313
05/22/2025 02:06:53.897 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 313 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0)
05/22/2025 02:06:53.897 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 315 (leader epoch 0)
05/22/2025 02:06:53.914 7f6ff8920cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 169
05/22/2025 02:06:53.914 7f6ff8920cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
05/22/2025 02:06:53.914 7f6ff8920cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff730ee10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
05/22/2025 02:06:53.914 7f6ff8920cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.914 7f6ff8920cc0 [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=757892903, session_epoch=474, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.914 7f6ff8920cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 477 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=757892903, session_epoch=474, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.915 7f6ff8920cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62432.413086, idle connection 886.000000, request 304999.932051
05/22/2025 02:06:53.915 7f6ff8920cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62432.010010, idle connection 885.000000, request 304999.535322
05/22/2025 02:06:53.918 7f6ff88b8eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 218
05/22/2025 02:06:53.918 7f6ff88b8eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
05/22/2025 02:06:53.918 7f6ff88b8eb8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff90e4780> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
05/22/2025 02:06:53.918 7f6ff88b8eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.918 7f6ff88b8eb8 [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=1197823429, session_epoch=479, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.919 7f6ff88b8eb8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 482 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1197823429, session_epoch=479, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.919 7f6ff88b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62717.402832, idle connection 981.000000, request 304999.952316
05/22/2025 02:06:53.919 7f6ff88b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62717.023926, idle connection 981.000000, request 304999.577284
05/22/2025 02:06:53.921 7f6ff8c7a438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 30
05/22/2025 02:06:53.921 7f6ff8c7a438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
05/22/2025 02:06:53.921 7f6ff8c7a438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff71a8a90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
05/22/2025 02:06:53.921 7f6ff8c7a438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.921 7f6ff8c7a438 [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=986624794, session_epoch=454, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.921 7f6ff8c7a438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=986624794, session_epoch=454, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.921 7f6ff8c7a438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62308.187744, idle connection 739.000000, request 304999.955416
05/22/2025 02:06:53.922 7f6ff8c7a438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62307.825928, idle connection 738.000000, request 304999.566555
05/22/2025 02:06:53.962 7f6ff8963eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 81
05/22/2025 02:06:53.962 7f6ff8963eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
05/22/2025 02:06:53.962 7f6ff8963eb8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff71f2e48> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
05/22/2025 02:06:53.962 7f6ff8963eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.962 7f6ff8963eb8 [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=67482812, session_epoch=461, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.962 7f6ff8963eb8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 464 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=67482812, session_epoch=461, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.963 7f6ff8963eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62374.072021, idle connection 810.000000, request 304999.907017
05/22/2025 02:06:53.963 7f6ff8963eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62373.413086, idle connection 809.000000, request 304999.258280
05/22/2025 02:06:53.969 7f6ff90ddb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61656.312500, idle connection 897.000000, request 304398.951769
05/22/2025 02:06:53.969 7f6ff90ddb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 461
05/22/2025 02:06:53.970 7f6ff90ddb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.970 7f6ff90ddb70 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 461 (601.7322540283203 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394155307, topics=[])
05/22/2025 02:06:53.970 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394155307 with 0 response partitions (1 implied)
05/22/2025 02:06:53.979 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2366
05/22/2025 02:06:53.979 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
05/22/2025 02:06:53.979 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff732f588> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
05/22/2025 02:06:53.980 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.980 7f6ff90cf048 [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=244628027, session_epoch=664, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.980 7f6ff90cf048 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 667 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=244628027, session_epoch=664, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:53.980 7f6ff90cf048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62138.844971, idle connection 512.000000, request 304999.946356
05/22/2025 02:06:53.980 7f6ff90cf048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62138.449463, idle connection 512.000000, request 304999.556065
05/22/2025 02:06:53.983 7f6ff90ddcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62276.332031, idle connection 624.000000, request 304399.247885
05/22/2025 02:06:53.983 7f6ff90ddcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454
05/22/2025 02:06:53.983 7f6ff90ddcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:53.983 7f6ff90ddcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 454 (601.1073589324951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=292220102, topics=[])
05/22/2025 02:06:53.983 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 292220102 with 0 response partitions (1 implied)
05/22/2025 02:06:53.998 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 315
05/22/2025 02:06:53.998 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
05/22/2025 02:06:53.998 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff785b898> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
05/22/2025 02:06:53.998 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:53.998 7f6ff897d588 [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=828377855, session_epoch=487, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=315, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/22/2025 02:06:53.999 7f6ff897d588 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 490 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828377855, session_epoch=487, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=315, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/22/2025 02:06:53.999 7f6ff897d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62762.721680, idle connection 923.000000, request 304999.942780
05/22/2025 02:06:53.999 7f6ff897d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62762.282471, idle connection 922.000000, request 304999.508858
05/22/2025 02:06:54.019 7f6ff8c44438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61704.988770, idle connection 711.000000, request 304398.782492
05/22/2025 02:06:54.019 7f6ff8c44438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456
05/22/2025 02:06:54.019 7f6ff8c44438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.019 7f6ff8c44438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 456 (601.7742156982422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1652851454, topics=[])
05/22/2025 02:06:54.019 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1652851454 with 0 response partitions (1 implied)
05/22/2025 02:06:54.019 7f6ff90cf6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 24
05/22/2025 02:06:54.020 7f6ff90cf6d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
05/22/2025 02:06:54.020 7f6ff90cf6d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6b14748> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
05/22/2025 02:06:54.020 7f6ff90cf6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.020 7f6ff90cf6d8 [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=421764578, session_epoch=454, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.020 7f6ff90cf6d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=421764578, session_epoch=454, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.020 7f6ff90cf6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61444.095459, idle connection 540.000000, request 304999.915361
05/22/2025 02:06:54.021 7f6ff90cf6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61443.481445, idle connection 540.000000, request 304999.311209
05/22/2025 02:06:54.021 7f6ff8d43240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61599.021484, idle connection 523.000000, request 304399.201155
05/22/2025 02:06:54.021 7f6ff8d43240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 450
05/22/2025 02:06:54.021 7f6ff8d43240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.022 7f6ff8d43240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 450 (601.1631488800049 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1433727324, topics=[])
05/22/2025 02:06:54.022 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1433727324 with 0 response partitions (1 implied)
05/22/2025 02:06:54.023 7f6ff8d3fd68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61600.315186, idle connection 721.000000, request 304399.344444
05/22/2025 02:06:54.023 7f6ff8d3fd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 449
05/22/2025 02:06:54.023 7f6ff8d3fd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.024 7f6ff8d3fd68 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 449 (601.0055541992188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1022119500, topics=[])
05/22/2025 02:06:54.024 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1022119500 with 0 response partitions (1 implied)
05/22/2025 02:06:54.073 7f6ff8563240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 123
05/22/2025 02:06:54.073 7f6ff8563240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
05/22/2025 02:06:54.073 7f6ff8563240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6b4fa90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
05/22/2025 02:06:54.073 7f6ff8563240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.073 7f6ff8563240 [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=1212029852, session_epoch=475, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.073 7f6ff8563240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 478 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1212029852, session_epoch=475, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.073 7f6ff8563240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61646.312988, idle connection 890.000000, request 304999.943256
05/22/2025 02:06:54.074 7f6ff8563240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61645.843750, idle connection 890.000000, request 304999.480486
05/22/2025 02:06:54.080 7f6ff88b50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62085.772217, idle connection 802.000000, request 304397.820234
05/22/2025 02:06:54.080 7f6ff88b50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 472
05/22/2025 02:06:54.080 7f6ff88b50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.080 7f6ff88b50f0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 472 (602.6241779327393 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1751949969, topics=[])
05/22/2025 02:06:54.080 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1751949969 with 0 response partitions (1 implied)
05/22/2025 02:06:54.125 7f6ff918a198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 66
05/22/2025 02:06:54.125 7f6ff918a198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
05/22/2025 02:06:54.125 7f6ff918a198 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d080> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
05/22/2025 02:06:54.125 7f6ff918a198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.125 7f6ff918a198 [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=1093382742, session_epoch=468, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.125 7f6ff918a198 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 471 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1093382742, session_epoch=468, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.126 7f6ff918a198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62029.965576, idle connection 821.000000, request 304999.940872
05/22/2025 02:06:54.126 7f6ff918a198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62029.497314, idle connection 820.000000, request 304999.477625
05/22/2025 02:06:54.132 7f6ff8526d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 180
05/22/2025 02:06:54.132 7f6ff8526d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
05/22/2025 02:06:54.132 7f6ff8526d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0dbe0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
05/22/2025 02:06:54.132 7f6ff8526d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.133 7f6ff8526d68 [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=1304324850, session_epoch=480, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.133 7f6ff8526d68 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 483 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1304324850, session_epoch=480, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.133 7f6ff8526d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61868.964111, idle connection 853.000000, request 304999.944448
05/22/2025 02:06:54.133 7f6ff8526d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61868.570801, idle connection 853.000000, request 304999.556780
05/22/2025 02:06:54.278 7f6ff8999240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61160.355225, idle connection 438.000000, request 304396.660328
05/22/2025 02:06:54.278 7f6ff8999240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458
05/22/2025 02:06:54.278 7f6ff8999240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.278 7f6ff8999240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 458 (603.8687229156494 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1648521419, topics=[])
05/22/2025 02:06:54.278 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1648521419 with 0 response partitions (1 implied)
05/22/2025 02:06:54.278 7f6ff90a8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 184
05/22/2025 02:06:54.279 7f6ff90a8390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
05/22/2025 02:06:54.279 7f6ff90a8390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff8987390> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
05/22/2025 02:06:54.279 7f6ff90a8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.279 7f6ff90a8390 [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=1102405260, session_epoch=486, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.279 7f6ff90a8390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 489 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1102405260, session_epoch=486, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.279 7f6ff90a8390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62197.343750, idle connection 567.000000, request 304999.949455
05/22/2025 02:06:54.279 7f6ff909c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61547.614990, idle connection 351.000000, request 304395.784140
05/22/2025 02:06:54.279 7f6ff8c67390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61761.836670, idle connection 502.000000, request 304396.354914
05/22/2025 02:06:54.280 7f6ff909c240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 451
05/22/2025 02:06:54.280 7f6ff909c240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.280 7f6ff909c240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 451 (604.7415733337402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1917713502, topics=[])
05/22/2025 02:06:54.280 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1917713502 with 0 response partitions (1 implied)
05/22/2025 02:06:54.280 7f6ff8c67390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454
05/22/2025 02:06:54.280 7f6ff8c67390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.280 7f6ff8c67390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 454 (604.5186519622803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=947019289, topics=[])
05/22/2025 02:06:54.280 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 947019289 with 0 response partitions (1 implied)
05/22/2025 02:06:54.281 7f6ff90a8390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62195.580078, idle connection 566.000000, request 304998.189926
05/22/2025 02:06:54.291 7f6ff906ba20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15
05/22/2025 02:06:54.291 7f6ff906ba20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
05/22/2025 02:06:54.291 7f6ff906ba20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d470> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
05/22/2025 02:06:54.291 7f6ff906ba20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.291 7f6ff906ba20 [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=2115849236, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.291 7f6ff906ba20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2115849236, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.291 7f6ff906ba20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62039.877930, idle connection 322.000000, request 304999.952555
05/22/2025 02:06:54.291 7f6ff906c390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 14
05/22/2025 02:06:54.291 7f6ff906c390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
05/22/2025 02:06:54.291 7f6ff906c390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff8915978> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
05/22/2025 02:06:54.292 7f6ff906c390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.292 7f6ff906c390 [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=1076439384, session_epoch=453, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.292 7f6ff906c390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1076439384, session_epoch=453, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.292 7f6ff906c390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61017.435059, idle connection 304.000000, request 304999.958277
05/22/2025 02:06:54.292 7f6ff906ba20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62038.857178, idle connection 321.000000, request 304998.935699
05/22/2025 02:06:54.292 7f6ff906c390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61016.830322, idle connection 304.000000, request 304999.355793
05/22/2025 02:06:54.341 7f6ff90e58d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62092.130127, idle connection 315.000000, request 304398.894072
05/22/2025 02:06:54.341 7f6ff90e58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 459
05/22/2025 02:06:54.341 7f6ff90e58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.342 7f6ff90e58d0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 459 (601.6206741333008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=516824156, topics=[])
05/22/2025 02:06:54.342 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 516824156 with 0 response partitions (1 implied)
05/22/2025 02:06:54.398 7f6ff8d43630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
05/22/2025 02:06:54.398 7f6ff8d43630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
05/22/2025 02:06:54.398 7f6ff8d43630 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6d63f98> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
05/22/2025 02:06:54.398 7f6ff8d43630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.398 7f6ff8d43630 [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=498161571, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.398 7f6ff8d43630 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 450 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=498161571, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.398 7f6ff8d43630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60943.728271, idle connection 131.000000, request 304999.942064
05/22/2025 02:06:54.399 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19
05/22/2025 02:06:54.399 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
05/22/2025 02:06:54.399 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6d63550> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
05/22/2025 02:06:54.399 7f6ff91076d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.399 7f6ff91076d8 [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=1984374821, session_epoch=453, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.399 7f6ff91076d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1984374821, session_epoch=453, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.400 7f6ff91076d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61393.156738, idle connection 173.000000, request 304999.950409
05/22/2025 02:06:54.400 7f6ff8d43630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60942.242188, idle connection 129.000000, request 304998.460770
05/22/2025 02:06:54.400 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
05/22/2025 02:06:54.400 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
05/22/2025 02:06:54.400 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d940> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
05/22/2025 02:06:54.400 7f6ffa53dac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.400 7f6ffa53dac8 [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=1320440397, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.401 7f6ffa53dac8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 450 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1320440397, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.401 7f6ffa53dac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60997.514160, idle connection 100.000000, request 304999.959230
05/22/2025 02:06:54.401 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 127
05/22/2025 02:06:54.401 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
05/22/2025 02:06:54.401 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0da20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
05/22/2025 02:06:54.401 7f6ff8d43438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.401 7f6ff8d43438 [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=867624517, session_epoch=474, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.401 7f6ff8d43438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 477 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867624517, session_epoch=474, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.401 7f6ff8d43438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61320.482422, idle connection 115.000000, request 304999.960661
05/22/2025 02:06:54.402 7f6ff91076d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61391.036621, idle connection 171.000000, request 304997.834682
05/22/2025 02:06:54.402 7f6ffa53dac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60996.176025, idle connection 98.000000, request 304998.623371
05/22/2025 02:06:54.402 7f6ff8d43438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61319.510254, idle connection 114.000000, request 304998.991251
05/22/2025 02:06:54.467 7f6ff9067f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61115.360107, idle connection 211.000000, request 304398.017645
05/22/2025 02:06:54.468 7f6ff9067f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 462
05/22/2025 02:06:54.468 7f6ff9067f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.468 7f6ff9067f60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 462 (602.5381088256836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1930143028, topics=[])
05/22/2025 02:06:54.468 7f6ff9067f60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1930143028 with 0 response partitions (1 implied)
05/22/2025 02:06:54.468 7f6ff90ea4e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62020.068359, idle connection 237.000000, request 304397.816181
05/22/2025 02:06:54.469 7f6ff90ea4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 465
05/22/2025 02:06:54.469 7f6ff90ea4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.469 7f6ff90ea4e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 465 (602.5087833404541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=884375702, topics=[])
05/22/2025 02:06:54.469 7f6ff90ea4e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 884375702 with 0 response partitions (1 implied)
05/22/2025 02:06:54.496 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122
05/22/2025 02:06:54.496 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
05/22/2025 02:06:54.496 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6d63630> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
05/22/2025 02:06:54.496 7f6ff56caa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.496 7f6ff56caa20 [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=820021122, session_epoch=480, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.496 7f6ff56caa20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 483 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=820021122, session_epoch=480, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.496 7f6ff56caa20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61518.135498, idle connection 320.000000, request 304999.945641
05/22/2025 02:06:54.497 7f6ff56caa20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61517.655762, idle connection 320.000000, request 304999.470472
05/22/2025 02:06:54.516 7f6ff8920cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61831.514648, idle connection 285.000000, request 304399.036884
05/22/2025 02:06:54.516 7f6ff8920cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 477
05/22/2025 02:06:54.516 7f6ff8920cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.516 7f6ff8920cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 477 (601.4213562011719 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=757892903, topics=[])
05/22/2025 02:06:54.516 7f6ff8920cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 757892903 with 0 response partitions (1 implied)
05/22/2025 02:06:54.521 7f6ff88b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62115.427246, idle connection 379.000000, request 304397.975445
05/22/2025 02:06:54.521 7f6ff88b8eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 482
05/22/2025 02:06:54.521 7f6ff88b8eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.521 7f6ff88b8eb8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 482 (602.4744510650635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1197823429, topics=[])
05/22/2025 02:06:54.521 7f6ff88b8eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1197823429 with 0 response partitions (1 implied)
05/22/2025 02:06:54.522 7f6ff8c7a438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61707.419189, idle connection 138.000000, request 304399.186850
05/22/2025 02:06:54.522 7f6ff8c7a438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457
05/22/2025 02:06:54.522 7f6ff8c7a438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.522 7f6ff8c7a438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 457 (601.13525390625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=986624794, topics=[])
05/22/2025 02:06:54.523 7f6ff8c7a438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 986624794 with 0 response partitions (1 implied)
05/22/2025 02:06:54.564 7f6ff8963eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61772.752441, idle connection 209.000000, request 304398.598433
05/22/2025 02:06:54.564 7f6ff8963eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 464
05/22/2025 02:06:54.564 7f6ff8963eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.564 7f6ff8963eb8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 464 (601.8500328063965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=67482812, topics=[])
05/22/2025 02:06:54.564 7f6ff8963eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 67482812 with 0 response partitions (1 implied)
05/22/2025 02:06:54.570 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 55
05/22/2025 02:06:54.570 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
05/22/2025 02:06:54.570 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cb19e8> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
05/22/2025 02:06:54.570 7f6ff90ddb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.571 7f6ff90ddb70 [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=1394155307, session_epoch=459, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.571 7f6ff90ddb70 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 462 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394155307, session_epoch=459, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.571 7f6ff90ddb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61054.501465, idle connection 295.000000, request 304999.937773
05/22/2025 02:06:54.571 7f6ff90ddb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61054.051758, idle connection 295.000000, request 304999.496460
05/22/2025 02:06:54.592 7f6ff90cf048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61527.226318, idle connection 0.000000, request 304388.329268
05/22/2025 02:06:54.592 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 12
05/22/2025 02:06:54.592 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
05/22/2025 02:06:54.592 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cb1da0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
05/22/2025 02:06:54.592 7f6ff90ddcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.592 7f6ff90ddcc0 [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=292220102, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.592 7f6ff90ddcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=292220102, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.592 7f6ff90ddcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61666.787109, idle connection 14.000000, request 304999.953508
05/22/2025 02:06:54.593 7f6ff90cf048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 667
05/22/2025 02:06:54.593 7f6ff90cf048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.593 7f6ff90cf048 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 667 (612.8394603729248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=244628027, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2367, last_stable_offset=2367, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\t>\x00\x00\x01\x04\x00\x00\x00\x00\x02<%\xbe\r\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
05/22/2025 02:06:54.593 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 244628027 with 1 response partitions (0 implied)
05/22/2025 02:06:54.593 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2366
05/22/2025 02:06:54.593 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2366 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
05/22/2025 02:06:54.594 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 2367 (leader epoch 0)
05/22/2025 02:06:54.595 7f6ff90ddcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61664.327148, idle connection 12.000000, request 304997.494936
05/22/2025 02:06:54.600 7f6ff897d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62161.820068, idle connection 322.000000, request 304399.043798
05/22/2025 02:06:54.600 7f6ff897d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 490
05/22/2025 02:06:54.600 7f6ff897d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.600 7f6ff897d588 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 490 (601.3882160186768 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=828377855, topics=[])
05/22/2025 02:06:54.600 7f6ff897d588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 828377855 with 0 response partitions (1 implied)
05/22/2025 02:06:54.620 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 27
05/22/2025 02:06:54.620 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
05/22/2025 02:06:54.620 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cb12e8> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
05/22/2025 02:06:54.620 7f6ff8c44438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.620 7f6ff8c44438 [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=1652851454, session_epoch=454, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.620 7f6ff8c44438 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1652851454, session_epoch=454, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.620 7f6ff8c44438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61103.282959, idle connection 110.000000, request 304999.944925
05/22/2025 02:06:54.621 7f6ff8c44438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61102.856445, idle connection 109.000000, request 304999.524593
05/22/2025 02:06:54.621 7f6ff90cf6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60843.128906, idle connection 0.000000, request 304398.959875
05/22/2025 02:06:54.621 7f6ff90cf6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457
05/22/2025 02:06:54.622 7f6ff90cf6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.622 7f6ff90cf6d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 457 (601.3898849487305 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=421764578, topics=[])
05/22/2025 02:06:54.622 7f6ff90cf6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 421764578 with 0 response partitions (1 implied)
05/22/2025 02:06:54.622 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2
05/22/2025 02:06:54.622 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
05/22/2025 02:06:54.622 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cb1d30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
05/22/2025 02:06:54.622 7f6ff8d43240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.622 7f6ff8d43240 [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=1433727324, session_epoch=448, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.622 7f6ff8d43240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 451 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1433727324, session_epoch=448, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.623 7f6ff8d43240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60997.730469, idle connection 0.000000, request 304999.958277
05/22/2025 02:06:54.623 7f6ff8d43240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60997.402832, idle connection 539398.000000, request 304999.631882
05/22/2025 02:06:54.624 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
05/22/2025 02:06:54.624 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
05/22/2025 02:06:54.624 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff857a6d8> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
05/22/2025 02:06:54.624 7f6ff8d3fd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.624 7f6ff8d3fd68 [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=1022119500, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.624 7f6ff8d3fd68 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 450 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1022119500, session_epoch=447, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.624 7f6ff8d3fd68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60999.105469, idle connection 120.000000, request 304999.959469
05/22/2025 02:06:54.625 7f6ff8d3fd68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60998.795898, idle connection 120.000000, request 304999.651194
05/22/2025 02:06:54.674 7f6ff8563240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61045.338379, idle connection 289.000000, request 304398.971319
05/22/2025 02:06:54.675 7f6ff8563240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 478
05/22/2025 02:06:54.675 7f6ff8563240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.675 7f6ff8563240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 478 (601.517915725708 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1212029852, topics=[])
05/22/2025 02:06:54.675 7f6ff8563240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1212029852 with 0 response partitions (1 implied)
05/22/2025 02:06:54.681 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 134
05/22/2025 02:06:54.681 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
05/22/2025 02:06:54.681 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6cb1c18> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
05/22/2025 02:06:54.681 7f6ff88b50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.681 7f6ff88b50f0 [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=1751949969, session_epoch=470, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.681 7f6ff88b50f0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 473 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1751949969, session_epoch=470, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.681 7f6ff88b50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61484.297607, idle connection 200.000000, request 304999.952316
05/22/2025 02:06:54.682 7f6ff88b50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61483.915283, idle connection 200.000000, request 304999.572515
05/22/2025 02:06:54.694 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2367
05/22/2025 02:06:54.694 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
05/22/2025 02:06:54.694 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff724fba8> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
05/22/2025 02:06:54.694 7f6ff90cf048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.694 7f6ff90cf048 [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=244628027, session_epoch=665, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2367, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/22/2025 02:06:54.695 7f6ff90cf048 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 668 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=244628027, session_epoch=665, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2367, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
05/22/2025 02:06:54.695 7f6ff90cf048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61423.902100, idle connection 539897.000000, request 304999.948263
05/22/2025 02:06:54.695 7f6ff90cf048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61423.548584, idle connection 539897.000000, request 304999.597788
05/22/2025 02:06:54.726 7f6ff918a198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61429.031250, idle connection 220.000000, request 304399.009228
05/22/2025 02:06:54.727 7f6ff918a198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 471
05/22/2025 02:06:54.727 7f6ff918a198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.727 7f6ff918a198 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 471 (601.4866828918457 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1093382742, topics=[])
05/22/2025 02:06:54.727 7f6ff918a198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1093382742 with 0 response partitions (1 implied)
05/22/2025 02:06:54.734 7f6ff8526d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61268.219727, idle connection 253.000000, request 304399.202824
05/22/2025 02:06:54.734 7f6ff8526d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 483
05/22/2025 02:06:54.734 7f6ff8526d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.734 7f6ff8526d68 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 483 (601.2039184570312 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1304324850, topics=[])
05/22/2025 02:06:54.734 7f6ff8526d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1304324850 with 0 response partitions (1 implied)
05/22/2025 02:06:54.879 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 46
05/22/2025 02:06:54.879 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
05/22/2025 02:06:54.879 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ffa560898> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
05/22/2025 02:06:54.879 7f6ff8999240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.879 7f6ff8999240 [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=1648521419, session_epoch=456, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.879 7f6ff8999240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1648521419, session_epoch=456, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.880 7f6ff8999240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60558.244385, idle connection 0.000000, request 304999.900341
05/22/2025 02:06:54.880 7f6ff8999240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60557.596924, idle connection 539397.000000, request 304999.265432
05/22/2025 02:06:54.881 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5
05/22/2025 02:06:54.881 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
05/22/2025 02:06:54.881 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d710> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
05/22/2025 02:06:54.881 7f6ff909c240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.881 7f6ff909c240 [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=1917713502, session_epoch=449, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.881 7f6ff909c240 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 452 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1917713502, session_epoch=449, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.881 7f6ff909c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60945.782471, idle connection 0.000000, request 304999.958038
05/22/2025 02:06:54.881 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 24
05/22/2025 02:06:54.881 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
05/22/2025 02:06:54.881 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6c0d2b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
05/22/2025 02:06:54.882 7f6ff8c67390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.882 7f6ff8c67390 [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=947019289, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.882 7f6ff8c67390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=947019289, session_epoch=452, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.882 7f6ff8c67390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61159.346924, idle connection 0.000000, request 304999.959946
05/22/2025 02:06:54.882 7f6ff90a8390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61594.307129, idle connection 0.000000, request 304396.916866
05/22/2025 02:06:54.882 7f6ff909c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60944.509277, idle connection 539397.000000, request 304998.685837
05/22/2025 02:06:54.883 7f6ff90a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 489
05/22/2025 02:06:54.883 7f6ff90a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.883 7f6ff90a8390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 489 (603.7342548370361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1102405260, topics=[])
05/22/2025 02:06:54.883 7f6ff90a8390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1102405260 with 0 response partitions (1 implied)
05/22/2025 02:06:54.883 7f6ff8c67390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61158.036133, idle connection 539396.000000, request 304998.650074
05/22/2025 02:06:54.893 7f6ff906ba20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61438.206543, idle connection 0.000000, request 304398.283958
05/22/2025 02:06:54.893 7f6ff906ba20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455
05/22/2025 02:06:54.893 7f6ff906ba20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.893 7f6ff906ba20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 455 (602.0829677581787 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2115849236, topics=[])
05/22/2025 02:06:54.893 7f6ff906ba20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2115849236 with 0 response partitions (1 implied)
05/22/2025 02:06:54.894 7f6ff906c390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60415.750488, idle connection 0.000000, request 304398.275137
05/22/2025 02:06:54.894 7f6ff906c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456
05/22/2025 02:06:54.894 7f6ff906c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
05/22/2025 02:06:54.894 7f6ff906c390 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 456 (602.0603179931641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1076439384, topics=[])
05/22/2025 02:06:54.894 7f6ff906c390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1076439384 with 0 response partitions (1 implied)
05/22/2025 02:06:54.942 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 30
05/22/2025 02:06:54.943 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
05/22/2025 02:06:54.943 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f6ff6d63358> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
05/22/2025 02:06:54.943 7f6ff90e58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
05/22/2025 02:06:54.943 7f6ff90e58d0 [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=516824156, session_epoch=457, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.943 7f6ff90e58d0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 460 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=516824156, session_epoch=457, topics=[], forgotten_topics_data=[])
05/22/2025 02:06:54.943 7f6ff90e58d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61489.999756, idle connection 0.000000, request 304999.943018
05/22/2025 02:06:54.944 7f6ff90e58d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61489.499268, idle connection 539397.000000, request 304999.448299