05/18/2026 04:58:15.277 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 05/18/2026 04:58:15.278 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:15.279 7f4ab628bae0 [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=1954760156, session_epoch=9456, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7925, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:15.279 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 9472 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1954760156, session_epoch=9456, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7925, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:15.279 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99533.208252, idle connection 38502.000000, request 304999.913692 05/18/2026 04:58:15.280 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99532.391113, idle connection 38501.000000, request 304999.107361 05/18/2026 04:58:15.297 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99874.581787, idle connection 38459.000000, request 304396.980286 05/18/2026 04:58:15.297 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8488 05/18/2026 04:58:15.297 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:15.297 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8488 (603.7507057189941 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=877416671, topics=[]) 05/18/2026 04:58:15.298 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 877416671 with 0 response partitions (1 implied) 05/18/2026 04:58:15.298 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99877.169922, idle connection 38488.000000, request 304396.472216 05/18/2026 04:58:15.298 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8485 05/18/2026 04:58:15.298 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:15.298 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 8485 (603.9621829986572 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1693973415, topics=[]) 05/18/2026 04:58:15.299 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1693973415 with 0 response partitions (1 implied) 05/18/2026 04:58:15.664 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 802 05/18/2026 04:58:15.664 7f4ab628b400 [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/18/2026 04:58:15.664 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/18/2026 04:58:15.664 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:15.665 7f4ab628b400 [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=1305047724, session_epoch=8582, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.665 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8607 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1305047724, session_epoch=8582, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.665 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98698.761475, idle connection 337494.000000, request 304999.942780 05/18/2026 04:58:15.665 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98698.139893, idle connection 337494.000000, request 304999.330044 05/18/2026 04:58:15.677 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97334.249756, idle connection 513789.000000, request 304399.123669 05/18/2026 04:58:15.677 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8667 05/18/2026 04:58:15.677 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:15.677 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8667 (601.5133857727051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=771657231, topics=[]) 05/18/2026 04:58:15.677 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 771657231 with 0 response partitions (1 implied) 05/18/2026 04:58:15.781 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 7572 05/18/2026 04:58:15.781 7f4ab628bc20 [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/18/2026 04:58:15.781 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/18/2026 04:58:15.781 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 05/18/2026 04:58:15.782 7f4ab628bc20 [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=1017880638, session_epoch=9293, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.782 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Request 9307 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1017880638, session_epoch=9293, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.782 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96231.923584, idle connection 274982.000000, request 304999.922991 05/18/2026 04:58:15.783 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96230.962646, idle connection 274981.000000, request 304998.970747 05/18/2026 04:58:15.783 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5458 05/18/2026 04:58:15.783 7f4ab628b9a0 [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/18/2026 04:58:15.783 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/18/2026 04:58:15.783 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:15.784 7f4ab628b9a0 [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=1536176846, session_epoch=9080, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.784 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 9093 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1536176846, session_epoch=9080, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.784 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95284.254150, idle connection 34290.000000, request 304999.950171 05/18/2026 04:58:15.784 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95283.754639, idle connection 34289.000000, request 304999.456167 05/18/2026 04:58:15.881 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98931.176270, idle connection 37900.000000, request 304397.886753 05/18/2026 04:58:15.882 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9472 05/18/2026 04:58:15.882 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:15.882 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 9472 (602.9839515686035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1954760156, topics=[]) 05/18/2026 04:58:15.882 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1954760156 with 0 response partitions (1 implied) 05/18/2026 04:58:15.899 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 346 05/18/2026 04:58:15.900 7f4ab628b180 [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/18/2026 04:58:15.900 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/18/2026 04:58:15.900 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:15.900 7f4ab628b180 [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=877416671, session_epoch=8466, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.900 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8489 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=877416671, session_epoch=8466, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.900 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99271.052490, idle connection 37855.000000, request 304999.938488 05/18/2026 04:58:15.900 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 291 05/18/2026 04:58:15.901 7f4ab628b220 [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/18/2026 04:58:15.901 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/18/2026 04:58:15.901 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:15.901 7f4ab628b220 [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=1693973415, session_epoch=8470, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.901 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 8486 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1693973415, session_epoch=8470, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:15.902 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99273.489502, idle connection 37885.000000, request 304999.940872 05/18/2026 04:58:15.902 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99269.092529, idle connection 37854.000000, request 304997.988939 05/18/2026 04:58:15.903 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 99272.476074, idle connection 37884.000000, request 304998.934746 05/18/2026 04:58:16.267 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98096.369873, idle connection 336892.000000, request 304397.551298 05/18/2026 04:58:16.268 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8607 05/18/2026 04:58:16.268 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:16.268 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8607 (603.0442714691162 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1305047724, topics=[]) 05/18/2026 04:58:16.268 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1305047724 with 0 response partitions (1 implied) 05/18/2026 04:58:16.278 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 1188 05/18/2026 04:58:16.279 7f4ab59fc4a0 [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/18/2026 04:58:16.279 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/18/2026 04:58:16.279 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:16.279 7f4ab59fc4a0 [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=771657231, session_epoch=8642, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.279 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8668 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=771657231, session_epoch=8642, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.279 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96731.721191, idle connection 513187.000000, request 304999.948502 05/18/2026 04:58:16.280 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96731.290283, idle connection 513186.000000, request 304999.524355 05/18/2026 04:58:16.385 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95628.896484, idle connection 274379.000000, request 304396.894455 05/18/2026 04:58:16.386 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9307 05/18/2026 04:58:16.386 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:16.386 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Response 9307 (603.9190292358398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1017880638, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=7574, last_stable_offset=7574, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x1d\x94\x00\x00\x02\x11\x00\x00\x00\x00\x02\x148\x01\xf0\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\xdc\x03\x00\x00\x00\x9e\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 05/18/2026 04:58:16.386 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1017880638 with 1 response partitions (0 implied) 05/18/2026 04:58:16.386 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 541 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 7572 05/18/2026 04:58:16.386 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 7572 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 05/18/2026 04:58:16.387 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 7574 (leader epoch 0) 05/18/2026 04:58:16.387 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94681.162354, idle connection 33687.000000, request 304396.855354 05/18/2026 04:58:16.387 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9093 05/18/2026 04:58:16.387 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:16.387 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 9093 (603.579044342041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1536176846, topics=[]) 05/18/2026 04:58:16.388 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1536176846 with 0 response partitions (1 implied) 05/18/2026 04:58:16.483 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7925 05/18/2026 04:58:16.484 7f4ab628bae0 [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/18/2026 04:58:16.484 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 05/18/2026 04:58:16.484 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:16.484 7f4ab628bae0 [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=1954760156, session_epoch=9457, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.484 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 9473 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1954760156, session_epoch=9457, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.485 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98327.868408, idle connection 37296.000000, request 304999.921799 05/18/2026 04:58:16.486 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98326.937500, idle connection 37295.000000, request 304998.806238 05/18/2026 04:58:16.487 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 7574 05/18/2026 04:58:16.487 7f4ab628bc20 [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/18/2026 04:58:16.487 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/18/2026 04:58:16.488 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 05/18/2026 04:58:16.488 7f4ab628bc20 [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=1017880638, session_epoch=9294, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7574, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:16.488 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Request 9308 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1017880638, session_epoch=9294, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7574, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:16.488 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95525.871582, idle connection 274276.000000, request 304999.952793 05/18/2026 04:58:16.489 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95525.232178, idle connection 274275.000000, request 304999.317408 05/18/2026 04:58:16.504 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98667.424805, idle connection 37252.000000, request 304396.312237 05/18/2026 04:58:16.504 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8489 05/18/2026 04:58:16.504 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:16.504 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8489 (604.3434143066406 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=877416671, topics=[]) 05/18/2026 04:58:16.505 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 877416671 with 0 response partitions (1 implied) 05/18/2026 04:58:16.505 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98670.229492, idle connection 37282.000000, request 304396.687508 05/18/2026 04:58:16.505 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8486 05/18/2026 04:58:16.505 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:16.505 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 8486 (603.6896705627441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1693973415, topics=[]) 05/18/2026 04:58:16.505 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1693973415 with 0 response partitions (1 implied) 05/18/2026 04:58:16.869 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 802 05/18/2026 04:58:16.869 7f4ab628b400 [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/18/2026 04:58:16.869 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/18/2026 04:58:16.869 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:16.869 7f4ab628b400 [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=1305047724, session_epoch=8583, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.870 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8608 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1305047724, session_epoch=8583, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.870 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97493.786133, idle connection 336289.000000, request 304999.935389 05/18/2026 04:58:16.870 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97493.147461, idle connection 336289.000000, request 304999.293089 05/18/2026 04:58:16.880 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96130.612305, idle connection 512586.000000, request 304398.829699 05/18/2026 04:58:16.881 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8668 05/18/2026 04:58:16.881 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:16.881 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8668 (601.8304824829102 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=771657231, topics=[]) 05/18/2026 04:58:16.881 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 771657231 with 0 response partitions (1 implied) 05/18/2026 04:58:16.988 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5458 05/18/2026 04:58:16.989 7f4ab628b9a0 [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/18/2026 04:58:16.989 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/18/2026 04:58:16.989 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:16.989 7f4ab628b9a0 [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=1536176846, session_epoch=9081, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.990 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 9094 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1536176846, session_epoch=9081, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:16.990 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94078.389893, idle connection 33084.000000, request 304999.934435 05/18/2026 04:58:16.990 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94077.902588, idle connection 33083.000000, request 304999.454498 05/18/2026 04:58:17.087 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97725.184570, idle connection 36694.000000, request 304397.232533 05/18/2026 04:58:17.088 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9473 05/18/2026 04:58:17.088 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:17.088 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 9473 (603.9395332336426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1954760156, topics=[]) 05/18/2026 04:58:17.089 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1954760156 with 0 response partitions (1 implied) 05/18/2026 04:58:17.089 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94924.508057, idle connection 273674.000000, request 304398.587704 05/18/2026 04:58:17.090 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9308 05/18/2026 04:58:17.090 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:17.090 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Response 9308 (602.0689010620117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1017880638, topics=[]) 05/18/2026 04:58:17.090 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1017880638 with 0 response partitions (1 implied) 05/18/2026 04:58:17.106 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 346 05/18/2026 04:58:17.106 7f4ab628b180 [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/18/2026 04:58:17.107 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/18/2026 04:58:17.107 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:17.107 7f4ab628b180 [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=877416671, session_epoch=8467, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.107 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8490 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=877416671, session_epoch=8467, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.107 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98063.803467, idle connection 36648.000000, request 304999.930143 05/18/2026 04:58:17.108 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 291 05/18/2026 04:58:17.108 7f4ab628b220 [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/18/2026 04:58:17.108 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/18/2026 04:58:17.108 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:17.108 7f4ab628b220 [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=1693973415, session_epoch=8471, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.108 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 8487 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1693973415, session_epoch=8471, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.108 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98066.691650, idle connection 36678.000000, request 304999.956131 05/18/2026 04:58:17.109 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98062.356934, idle connection 36647.000000, request 304998.493433 05/18/2026 04:58:17.109 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 98065.873779, idle connection 36677.000000, request 304999.143124 05/18/2026 04:58:17.472 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96891.596680, idle connection 335687.000000, request 304397.746563 05/18/2026 04:58:17.473 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8608 05/18/2026 04:58:17.473 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:17.473 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8608 (602.9865741729736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1305047724, topics=[]) 05/18/2026 04:58:17.473 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1305047724 with 0 response partitions (1 implied) 05/18/2026 04:58:17.482 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 1188 05/18/2026 04:58:17.483 7f4ab59fc4a0 [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/18/2026 04:58:17.483 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/18/2026 04:58:17.483 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:17.483 7f4ab59fc4a0 [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=771657231, session_epoch=8643, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.483 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8669 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=771657231, session_epoch=8643, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.483 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95527.612793, idle connection 511983.000000, request 304999.935865 05/18/2026 04:58:17.484 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95527.110107, idle connection 511982.000000, request 304999.447584 05/18/2026 04:58:17.592 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93476.173584, idle connection 32482.000000, request 304397.717476 05/18/2026 04:58:17.593 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9094 05/18/2026 04:58:17.593 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:17.593 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 9094 (603.0223369598389 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1536176846, topics=[]) 05/18/2026 04:58:17.593 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1536176846 with 0 response partitions (1 implied) 05/18/2026 04:58:17.690 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7925 05/18/2026 04:58:17.690 7f4ab628bae0 [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/18/2026 04:58:17.690 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 05/18/2026 04:58:17.690 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:17.690 7f4ab628bae0 [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=1954760156, session_epoch=9458, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.691 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 9474 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1954760156, session_epoch=9458, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.691 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97121.654785, idle connection 36090.000000, request 304999.936819 05/18/2026 04:58:17.691 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 7574 05/18/2026 04:58:17.691 7f4ab628bc20 [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/18/2026 04:58:17.691 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/18/2026 04:58:17.691 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 05/18/2026 04:58:17.691 7f4ab628bc20 [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=1017880638, session_epoch=9295, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.691 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Request 9309 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1017880638, session_epoch=9295, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:17.692 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94322.294434, idle connection 273072.000000, request 304999.955893 05/18/2026 04:58:17.692 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97120.455566, idle connection 36089.000000, request 304998.749971 05/18/2026 04:58:17.692 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94321.556152, idle connection 273072.000000, request 304999.222517 05/18/2026 04:58:17.710 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97460.735107, idle connection 36045.000000, request 304396.860838 05/18/2026 04:58:17.711 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8490 05/18/2026 04:58:17.711 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:17.711 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8490 (603.8377285003662 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=877416671, topics=[]) 05/18/2026 04:58:17.711 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 877416671 with 0 response partitions (1 implied) 05/18/2026 04:58:17.712 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 97463.447021, idle connection 36075.000000, request 304396.712542 05/18/2026 04:58:17.712 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8487 05/18/2026 04:58:17.712 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:17.712 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 8487 (603.6686897277832 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1693973415, topics=[]) 05/18/2026 04:58:17.712 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1693973415 with 0 response partitions (1 implied) 05/18/2026 04:58:18.074 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 802 05/18/2026 04:58:18.074 7f4ab628b400 [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/18/2026 04:58:18.074 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/18/2026 04:58:18.074 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:18.074 7f4ab628b400 [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=1305047724, session_epoch=8584, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.075 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8609 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1305047724, session_epoch=8584, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.075 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96288.787109, idle connection 335084.000000, request 304999.914885 05/18/2026 04:58:18.075 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96288.191650, idle connection 335084.000000, request 304999.335051 05/18/2026 04:58:18.085 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94926.364990, idle connection 511381.000000, request 304398.687124 05/18/2026 04:58:18.085 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8669 05/18/2026 04:58:18.086 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.086 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8669 (602.4825572967529 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=771657231, topics=[]) 05/18/2026 04:58:18.086 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 771657231 with 0 response partitions (1 implied) 05/18/2026 04:58:18.193 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5458 05/18/2026 04:58:18.194 7f4ab628b9a0 [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/18/2026 04:58:18.194 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/18/2026 04:58:18.194 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:18.194 7f4ab628b9a0 [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=1536176846, session_epoch=9082, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.194 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 9095 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1536176846, session_epoch=9082, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.195 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 92873.606445, idle connection 31879.000000, request 304999.921560 05/18/2026 04:58:18.195 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 92873.035400, idle connection 31878.000000, request 304999.360323 05/18/2026 04:58:18.294 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96518.383545, idle connection 35487.000000, request 304396.657228 05/18/2026 04:58:18.295 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9474 05/18/2026 04:58:18.295 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.295 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 9474 (604.0606498718262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1954760156, topics=[]) 05/18/2026 04:58:18.295 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1954760156 with 0 response partitions (1 implied) 05/18/2026 04:58:18.295 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93718.465820, idle connection 272468.000000, request 304396.127224 05/18/2026 04:58:18.296 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9309 05/18/2026 04:58:18.296 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.296 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Response 9309 (604.3226718902588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1017880638, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=7576, last_stable_offset=7576, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x1d\x96\x00\x00\x02\x17\x00\x00\x00\x00\x02\x85\x83\x1e\xb7\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 05/18/2026 04:58:18.296 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1017880638 with 1 response partitions (0 implied) 05/18/2026 04:58:18.296 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 7574 05/18/2026 04:58:18.296 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 7574 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 05/18/2026 04:58:18.297 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 7576 (leader epoch 0) 05/18/2026 04:58:18.313 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 346 05/18/2026 04:58:18.313 7f4ab628b180 [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/18/2026 04:58:18.313 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/18/2026 04:58:18.314 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:18.314 7f4ab628b180 [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=877416671, session_epoch=8468, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.314 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8491 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=877416671, session_epoch=8468, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.314 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96857.288086, idle connection 35442.000000, request 304999.942780 05/18/2026 04:58:18.314 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 291 05/18/2026 04:58:18.314 7f4ab628b220 [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/18/2026 04:58:18.314 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/18/2026 04:58:18.314 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:18.314 7f4ab628b220 [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=1693973415, session_epoch=8472, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.315 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 8488 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1693973415, session_epoch=8472, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.315 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96860.213867, idle connection 35471.000000, request 304999.933243 05/18/2026 04:58:18.315 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96855.850586, idle connection 35440.000000, request 304998.512745 05/18/2026 04:58:18.316 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96859.302979, idle connection 35471.000000, request 304999.032497 05/18/2026 04:58:18.398 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 7576 05/18/2026 04:58:18.398 7f4ab628bc20 [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/18/2026 04:58:18.398 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/18/2026 04:58:18.399 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 05/18/2026 04:58:18.399 7f4ab628bc20 [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=1017880638, session_epoch=9296, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7576, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:18.402 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Request 9310 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1017880638, session_epoch=9296, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7576, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:18.404 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93609.789307, idle connection 272360.000000, request 304999.919176 05/18/2026 04:58:18.405 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93609.296631, idle connection 272359.000000, request 304999.439478 05/18/2026 04:58:18.676 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95687.378418, idle connection 334483.000000, request 304398.511887 05/18/2026 04:58:18.677 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8609 05/18/2026 04:58:18.677 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.677 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8609 (602.0777225494385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1305047724, topics=[]) 05/18/2026 04:58:18.677 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1305047724 with 0 response partitions (1 implied) 05/18/2026 04:58:18.689 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 1188 05/18/2026 04:58:18.689 7f4ab59fc4a0 [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/18/2026 04:58:18.690 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/18/2026 04:58:18.690 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:18.690 7f4ab59fc4a0 [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=771657231, session_epoch=8644, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.690 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8670 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=771657231, session_epoch=8644, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.690 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94320.631348, idle connection 510776.000000, request 304999.913931 05/18/2026 04:58:18.691 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94320.029541, idle connection 510775.000000, request 304999.330997 05/18/2026 04:58:18.797 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 92271.110107, idle connection 31277.000000, request 304397.425652 05/18/2026 04:58:18.797 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9095 05/18/2026 04:58:18.798 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.798 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 9095 (603.1711101531982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1536176846, topics=[]) 05/18/2026 04:58:18.798 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1536176846 with 0 response partitions (1 implied) 05/18/2026 04:58:18.897 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7925 05/18/2026 04:58:18.897 7f4ab628bae0 [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/18/2026 04:58:18.897 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 05/18/2026 04:58:18.897 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:18.897 7f4ab628bae0 [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=1954760156, session_epoch=9459, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.897 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 9475 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1954760156, session_epoch=9459, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:18.897 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95915.073242, idle connection 34884.000000, request 304999.944448 05/18/2026 04:58:18.898 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95914.604736, idle connection 34883.000000, request 304999.485970 05/18/2026 04:58:18.917 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96254.161133, idle connection 34839.000000, request 304396.821260 05/18/2026 04:58:18.917 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8491 05/18/2026 04:58:18.917 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.918 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8491 (603.7147045135498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=877416671, topics=[]) 05/18/2026 04:58:18.918 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 877416671 with 0 response partitions (1 implied) 05/18/2026 04:58:18.918 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 96257.125488, idle connection 34868.000000, request 304396.852732 05/18/2026 04:58:18.918 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8488 05/18/2026 04:58:18.918 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:18.918 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 8488 (603.5113334655762 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1693973415, topics=[]) 05/18/2026 04:58:18.918 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1693973415 with 0 response partitions (1 implied) 05/18/2026 04:58:19.007 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93006.542725, idle connection 271757.000000, request 304396.678448 05/18/2026 04:58:19.008 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9310 05/18/2026 04:58:19.008 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:19.008 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Response 9310 (603.8868427276611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1017880638, topics=[]) 05/18/2026 04:58:19.008 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1017880638 with 0 response partitions (1 implied) 05/18/2026 04:58:19.278 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 802 05/18/2026 04:58:19.278 7f4ab628b400 [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/18/2026 04:58:19.278 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/18/2026 04:58:19.278 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:19.279 7f4ab628b400 [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=1305047724, session_epoch=8585, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.279 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8610 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1305047724, session_epoch=8585, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.279 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95084.745605, idle connection 333880.000000, request 304999.928951 05/18/2026 04:58:19.280 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95084.096924, idle connection 333880.000000, request 304999.290466 05/18/2026 04:58:19.291 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93719.437744, idle connection 510174.000000, request 304398.725986 05/18/2026 04:58:19.292 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8670 05/18/2026 04:58:19.292 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:19.293 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8670 (602.3287773132324 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=771657231, topics=[]) 05/18/2026 04:58:19.293 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 771657231 with 0 response partitions (1 implied) 05/18/2026 04:58:19.399 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5458 05/18/2026 04:58:19.399 7f4ab628b9a0 [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/18/2026 04:58:19.399 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/18/2026 04:58:19.399 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:19.399 7f4ab628b9a0 [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=1536176846, session_epoch=9083, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.400 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 9096 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1536176846, session_epoch=9083, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.400 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91668.418213, idle connection 30674.000000, request 304999.935150 05/18/2026 04:58:19.400 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91667.928223, idle connection 30673.000000, request 304999.458075 05/18/2026 04:58:19.498 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95313.979004, idle connection 34282.000000, request 304398.849487 05/18/2026 04:58:19.499 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9475 05/18/2026 04:58:19.499 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:19.499 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 9475 (601.7446517944336 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1954760156, topics=[]) 05/18/2026 04:58:19.499 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1954760156 with 0 response partitions (1 implied) 05/18/2026 04:58:19.520 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 346 05/18/2026 04:58:19.520 7f4ab628b180 [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/18/2026 04:58:19.520 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/18/2026 04:58:19.520 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:19.520 7f4ab628b180 [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=877416671, session_epoch=8469, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.521 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8492 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=877416671, session_epoch=8469, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.521 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95650.450439, idle connection 34235.000000, request 304999.926329 05/18/2026 04:58:19.521 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 291 05/18/2026 04:58:19.521 7f4ab628b220 [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/18/2026 04:58:19.521 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/18/2026 04:58:19.521 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:19.521 7f4ab628b220 [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=1693973415, session_epoch=8473, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.521 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 8489 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1693973415, session_epoch=8473, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.521 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95653.552246, idle connection 34265.000000, request 304999.949217 05/18/2026 04:58:19.522 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95649.270752, idle connection 34234.000000, request 304998.762608 05/18/2026 04:58:19.522 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95652.852295, idle connection 34264.000000, request 304999.253988 05/18/2026 04:58:19.610 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 7576 05/18/2026 04:58:19.610 7f4ab628bc20 [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/18/2026 04:58:19.610 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/18/2026 04:58:19.610 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 05/18/2026 04:58:19.611 7f4ab628bc20 [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=1017880638, session_epoch=9297, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.611 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Request 9311 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1017880638, session_epoch=9297, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.611 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 92402.999268, idle connection 271153.000000, request 304999.939442 05/18/2026 04:58:19.611 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 92402.542480, idle connection 271152.000000, request 304999.486446 05/18/2026 04:58:19.881 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94482.485596, idle connection 333278.000000, request 304397.674322 05/18/2026 04:58:19.882 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8610 05/18/2026 04:58:19.882 7f4ab628b400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:19.882 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8610 (603.0116081237793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1305047724, topics=[]) 05/18/2026 04:58:19.882 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1305047724 with 0 response partitions (1 implied) 05/18/2026 04:58:19.894 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 1188 05/18/2026 04:58:19.895 7f4ab59fc4a0 [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/18/2026 04:58:19.895 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/18/2026 04:58:19.895 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:19.895 7f4ab59fc4a0 [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=771657231, session_epoch=8645, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.895 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8671 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=771657231, session_epoch=8645, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:19.895 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93115.805420, idle connection 509571.000000, request 304999.945641 05/18/2026 04:58:19.895 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93115.402832, idle connection 509570.000000, request 304999.552965 05/18/2026 04:58:20.002 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91066.369385, idle connection 30072.000000, request 304397.891760 05/18/2026 04:58:20.002 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9096 05/18/2026 04:58:20.002 7f4ab628b9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:20.002 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 9096 (602.6601791381836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1536176846, topics=[]) 05/18/2026 04:58:20.003 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1536176846 with 0 response partitions (1 implied) 05/18/2026 04:58:20.100 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7925 05/18/2026 04:58:20.100 7f4ab628bae0 [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/18/2026 04:58:20.100 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 05/18/2026 04:58:20.100 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 05/18/2026 04:58:20.100 7f4ab628bae0 [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=1954760156, session_epoch=9460, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:20.100 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 9476 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1954760156, session_epoch=9460, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:20.101 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94711.822021, idle connection 33680.000000, request 304999.946117 05/18/2026 04:58:20.101 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94711.373779, idle connection 33680.000000, request 304999.507427 05/18/2026 04:58:20.123 7f4ab628b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95048.157959, idle connection 33633.000000, request 304397.639751 05/18/2026 04:58:20.123 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8492 05/18/2026 04:58:20.124 7f4ab628b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:20.124 7f4ab628b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8492 (602.9446125030518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=877416671, topics=[]) 05/18/2026 04:58:20.124 7f4ab628b180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 877416671 with 0 response partitions (1 implied) 05/18/2026 04:58:20.124 7f4ab628b220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 95051.064209, idle connection 33662.000000, request 304397.464037 05/18/2026 04:58:20.124 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8489 05/18/2026 04:58:20.124 7f4ab628b220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:20.124 7f4ab628b220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 8489 (602.8337478637695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1693973415, topics=[]) 05/18/2026 04:58:20.124 7f4ab628b220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1693973415 with 0 response partitions (1 implied) 05/18/2026 04:58:20.212 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91801.484131, idle connection 270551.000000, request 304398.425579 05/18/2026 04:58:20.213 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9311 05/18/2026 04:58:20.213 7f4ab628bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:20.213 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Response 9311 (602.2021770477295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1017880638, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=7578, last_stable_offset=7578, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x1d\x98\x00\x00\x01\xd4\x00\x00\x00\x00\x026 \xe9O\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\xa2\x03\x00\x00\x00\xe4\x02ObjectXmppPeerInfo:cn-jenkins-de...')])]) 05/18/2026 04:58:20.213 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1017880638 with 1 response partitions (0 implied) 05/18/2026 04:58:20.213 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 480 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 7576 05/18/2026 04:58:20.213 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 7576 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 05/18/2026 04:58:20.214 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 7578 (leader epoch 0) 05/18/2026 04:58:20.315 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 7578 05/18/2026 04:58:20.315 7f4ab628bc20 [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/18/2026 04:58:20.315 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/18/2026 04:58:20.315 7f4ab628bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 05/18/2026 04:58:20.315 7f4ab628bc20 [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=1017880638, session_epoch=9298, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7578, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:20.315 7f4ab628bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.240', 9092)]>: Request 9312 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1017880638, session_epoch=9298, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7578, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/18/2026 04:58:20.316 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91698.168945, idle connection 270448.000000, request 304999.921560 05/18/2026 04:58:20.316 7f4ab628bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91697.593506, idle connection 270448.000000, request 304999.356270 05/18/2026 04:58:20.482 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 802 05/18/2026 04:58:20.483 7f4ab628b400 [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/18/2026 04:58:20.483 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/18/2026 04:58:20.483 7f4ab628b400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:20.483 7f4ab628b400 [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=1305047724, session_epoch=8586, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:20.483 7f4ab628b400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8611 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1305047724, session_epoch=8586, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:20.483 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93880.410400, idle connection 332676.000000, request 304999.944448 05/18/2026 04:58:20.484 7f4ab628b400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 93879.965088, idle connection 332676.000000, request 304999.507666 05/18/2026 04:58:20.496 7f4ab59fc4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 92514.924316, idle connection 508970.000000, request 304399.070263 05/18/2026 04:58:20.496 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8671 05/18/2026 04:58:20.496 7f4ab59fc4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:20.496 7f4ab59fc4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8671 (601.402997970581 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=771657231, topics=[]) 05/18/2026 04:58:20.497 7f4ab59fc4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 771657231 with 0 response partitions (1 implied) 05/18/2026 04:58:20.603 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5458 05/18/2026 04:58:20.603 7f4ab628b9a0 [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/18/2026 04:58:20.604 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/18/2026 04:58:20.604 7f4ab628b9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/18/2026 04:58:20.604 7f4ab628b9a0 [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=1536176846, session_epoch=9084, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:20.604 7f4ab628b9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 9097 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1536176846, session_epoch=9084, topics=[], forgotten_topics_data=[]) 05/18/2026 04:58:20.604 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90463.925537, idle connection 29469.000000, request 304999.938488 05/18/2026 04:58:20.605 7f4ab628b9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90463.378906, idle connection 29469.000000, request 304999.400854 05/18/2026 04:58:20.702 7f4ab628bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 94110.704590, idle connection 33079.000000, request 304398.826838 05/18/2026 04:58:20.702 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9476 05/18/2026 04:58:20.702 7f4ab628bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/18/2026 04:58:20.703 7f4ab628bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 9476 (601.9964218139648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1954760156, topics=[]) 05/18/2026 04:58:20.703 7f4ab628bae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1954760156 with 0 response partitions (1 implied)