04/20/2026 16:31:29.118 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 16:31:29.119 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 16:31:29.119 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.119 7fd1abb48e00 [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=2141696147, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.119 7fd1abb48e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2141696147, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.119 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207156.246094, idle connection 146392.000000, request 304999.956131 04/20/2026 16:31:29.120 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207729.777588, idle connection 146593.000000, request 304998.330355 04/20/2026 16:31:29.120 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207155.382568, idle connection 146391.000000, request 304999.099255 04/20/2026 16:31:29.134 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207153.137695, idle connection 146257.000000, request 304398.958206 04/20/2026 16:31:29.135 7fd1abb40360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 343 04/20/2026 16:31:29.135 7fd1abb40360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.135 7fd1abb40360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 343 (601.5746593475342 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=663764101, topics=[]) 04/20/2026 16:31:29.135 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 663764101 with 0 response partitions (1 implied) 04/20/2026 16:31:29.194 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 45 04/20/2026 16:31:29.194 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 16:31:29.194 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 16:31:29.194 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.194 7fd1aa67f4a0 [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=1007649836, session_epoch=337, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.195 7fd1aa67f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1007649836, session_epoch=337, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.195 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207340.342285, idle connection 146500.000000, request 304999.943256 04/20/2026 16:31:29.195 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207238.480469, idle connection 146444.000000, request 304399.131060 04/20/2026 16:31:29.195 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207339.554688, idle connection 146499.000000, request 304999.164343 04/20/2026 16:31:29.196 7fd1abb407c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 343 04/20/2026 16:31:29.196 7fd1abb407c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.196 7fd1abb407c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 343 (601.6941070556641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=15040451, topics=[]) 04/20/2026 16:31:29.196 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 15040451 with 0 response partitions (1 implied) 04/20/2026 16:31:29.279 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207918.646240, idle connection 146450.000000, request 304398.468494 04/20/2026 16:31:29.279 7fd1aa67f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 356 04/20/2026 16:31:29.279 7fd1aa67f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.279 7fd1aa67f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 356 (602.0646095275879 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1499860736, topics=[]) 04/20/2026 16:31:29.279 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1499860736 with 0 response partitions (1 implied) 04/20/2026 16:31:29.283 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207443.133545, idle connection 146596.000000, request 304399.089098 04/20/2026 16:31:29.284 7fd1aa67f9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 373 04/20/2026 16:31:29.284 7fd1aa67f9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.284 7fd1aa67f9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 373 (601.5625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1345452472, topics=[]) 04/20/2026 16:31:29.284 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1345452472 with 0 response partitions (1 implied) 04/20/2026 16:31:29.379 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207231.108154, idle connection 146192.000000, request 304398.897171 04/20/2026 16:31:29.379 7fd1abb40ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 04/20/2026 16:31:29.380 7fd1abb40ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.380 7fd1abb40ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 328 (601.6180515289307 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=906603407, topics=[]) 04/20/2026 16:31:29.380 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 906603407 with 0 response partitions (1 implied) 04/20/2026 16:31:29.397 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207313.564209, idle connection 146198.000000, request 304399.155140 04/20/2026 16:31:29.397 7fd1abb40900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 04/20/2026 16:31:29.397 7fd1abb40900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.397 7fd1abb40900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 341 (601.2499332427979 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416039116, topics=[]) 04/20/2026 16:31:29.397 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416039116 with 0 response partitions (1 implied) 04/20/2026 16:31:29.411 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 31 04/20/2026 16:31:29.411 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 04/20/2026 16:31:29.411 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 04/20/2026 16:31:29.411 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.411 7fd1abb40d60 [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=2062876540, session_epoch=334, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.412 7fd1abb40d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 337 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062876540, session_epoch=334, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.412 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206971.482666, idle connection 146214.000000, request 304999.952316 04/20/2026 16:31:29.412 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206971.071533, idle connection 146214.000000, request 304999.547005 04/20/2026 16:31:29.414 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207155.384521, idle connection 146161.000000, request 304399.173021 04/20/2026 16:31:29.414 7fd1abb40180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 04/20/2026 16:31:29.414 7fd1abb40180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.414 7fd1abb40180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 340 (601.1569499969482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1332913744, topics=[]) 04/20/2026 16:31:29.415 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1332913744 with 0 response partitions (1 implied) 04/20/2026 16:31:29.419 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 234 04/20/2026 16:31:29.419 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 04/20/2026 16:31:29.419 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 04/20/2026 16:31:29.419 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.419 7fd1aa67fa40 [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=754292121, session_epoch=353, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.419 7fd1aa67fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=754292121, session_epoch=353, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.420 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207767.530762, idle connection 146411.000000, request 304999.953508 04/20/2026 16:31:29.420 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207767.143311, idle connection 146410.000000, request 304999.570370 04/20/2026 16:31:29.476 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 04/20/2026 16:31:29.476 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 04/20/2026 16:31:29.476 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 04/20/2026 16:31:29.476 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.476 7fd1abb40040 [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=368237388, session_epoch=326, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.476 7fd1abb40040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368237388, session_epoch=326, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.476 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206604.063965, idle connection 145896.000000, request 304999.954939 04/20/2026 16:31:29.477 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206603.716064, idle connection 145895.000000, request 304999.610901 04/20/2026 16:31:29.493 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207044.107178, idle connection 145989.000000, request 304398.363113 04/20/2026 16:31:29.493 7fd1a7f577c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:29.493 7fd1a7f577c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.493 7fd1a7f577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (602.0431518554688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1452532481, topics=[]) 04/20/2026 16:31:29.494 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1452532481 with 0 response partitions (1 implied) 04/20/2026 16:31:29.494 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207230.714111, idle connection 146036.000000, request 304398.367167 04/20/2026 16:31:29.494 7fd1abb48cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 04/20/2026 16:31:29.494 7fd1abb48cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.494 7fd1abb48cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 329 (601.9251346588135 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=237848852, topics=[]) 04/20/2026 16:31:29.495 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 237848852 with 0 response partitions (1 implied) 04/20/2026 16:31:29.495 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207395.875488, idle connection 146168.000000, request 304398.492813 04/20/2026 16:31:29.495 7fd1abb40cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 04/20/2026 16:31:29.495 7fd1abb40cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.495 7fd1abb40cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 338 (601.7873287200928 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=545954357, topics=[]) 04/20/2026 16:31:29.495 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 545954357 with 0 response partitions (1 implied) 04/20/2026 16:31:29.506 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207126.386475, idle connection 145963.000000, request 304399.098635 04/20/2026 16:31:29.507 7fd1a7f314a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:29.507 7fd1a7f314a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.507 7fd1a7f314a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (601.3922691345215 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1336779373, topics=[]) 04/20/2026 16:31:29.507 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1336779373 with 0 response partitions (1 implied) 04/20/2026 16:31:29.519 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 04/20/2026 16:31:29.519 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 04/20/2026 16:31:29.519 7fd1abb48720 [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)]) 04/20/2026 16:31:29.519 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.519 7fd1abb48720 [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=494524825, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.519 7fd1abb48720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=494524825, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.519 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206682.002197, idle connection 146020.000000, request 304999.948502 04/20/2026 16:31:29.520 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206681.575928, idle connection 146020.000000, request 304999.529362 04/20/2026 16:31:29.522 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78 04/20/2026 16:31:29.522 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 04/20/2026 16:31:29.522 7fd1aa67fd60 [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)]) 04/20/2026 16:31:29.522 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.522 7fd1aa67fd60 [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=193969926, session_epoch=344, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.522 7fd1aa67fd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 347 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=193969926, session_epoch=344, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.522 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207340.253906, idle connection 146268.000000, request 304999.956369 04/20/2026 16:31:29.522 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 188 04/20/2026 16:31:29.522 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 16:31:29.523 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 16:31:29.523 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.523 7fd1aa67fc20 [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=2125397961, session_epoch=355, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.523 7fd1aa67fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2125397961, session_epoch=355, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.523 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207111.343750, idle connection 146240.000000, request 304999.963284 04/20/2026 16:31:29.523 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207339.256104, idle connection 146267.000000, request 304998.962164 04/20/2026 16:31:29.523 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207110.718506, idle connection 146240.000000, request 304999.341011 04/20/2026 16:31:29.524 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207225.592285, idle connection 146032.000000, request 304395.867586 04/20/2026 16:31:29.524 7fd1abb40860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 04/20/2026 16:31:29.524 7fd1abb40860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.524 7fd1abb40860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 329 (604.5572757720947 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792742380, topics=[]) 04/20/2026 16:31:29.524 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 792742380 with 0 response partitions (1 implied) 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206809.665039, idle connection 145833.000000, request 304398.627043 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 493 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 493 (601.7138957977295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=250923993, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4191, last_stable_offset=4191, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10^\x00\x00\x01\x05\x00\x00\x00\x00\x02n0:&\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 250923993 with 1 response partitions (0 implied) 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4190 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4190 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 04/20/2026 16:31:29.525 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4191 (leader epoch 0) 04/20/2026 16:31:29.540 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207722.599854, idle connection 145962.000000, request 304398.984909 04/20/2026 16:31:29.541 7fd1a7f57400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:29.541 7fd1a7f57400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.541 7fd1a7f57400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.4490127563477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785707653, topics=[]) 04/20/2026 16:31:29.541 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785707653 with 0 response partitions (1 implied) 04/20/2026 16:31:29.575 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206850.759277, idle connection 146165.000000, request 304398.598909 04/20/2026 16:31:29.575 7fd1aa67f220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350 04/20/2026 16:31:29.575 7fd1aa67f220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.575 7fd1aa67f220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 350 (601.9446849822998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785660822, topics=[]) 04/20/2026 16:31:29.575 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785660822 with 0 response partitions (1 implied) 04/20/2026 16:31:29.583 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207283.970459, idle connection 146284.000000, request 304398.729801 04/20/2026 16:31:29.584 7fd1aa67fb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 348 04/20/2026 16:31:29.584 7fd1aa67fb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.584 7fd1aa67fb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 348 (601.8002033233643 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1236144512, topics=[]) 04/20/2026 16:31:29.584 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1236144512 with 0 response partitions (1 implied) 04/20/2026 16:31:29.606 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 100 04/20/2026 16:31:29.606 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 16:31:29.606 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 16:31:29.606 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.606 7fd1aa67f7c0 [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=336118288, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.607 7fd1aa67f7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=336118288, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.607 7fd1aa67f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208023.324463, idle connection 146203.000000, request 304999.948263 04/20/2026 16:31:29.607 7fd1aa67f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208022.916992, idle connection 146203.000000, request 304999.548197 04/20/2026 16:31:29.608 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 04/20/2026 16:31:29.609 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 04/20/2026 16:31:29.609 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 04/20/2026 16:31:29.609 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.609 7fd1a7f31cc0 [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=883504057, session_epoch=326, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.609 7fd1a7f31cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883504057, session_epoch=326, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.609 7fd1a7f31cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206672.749512, idle connection 145853.000000, request 304999.949932 04/20/2026 16:31:29.609 7fd1a7f31cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206672.443604, idle connection 145853.000000, request 304999.646425 04/20/2026 16:31:29.611 7fd1abb40f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207816.939941, idle connection 145997.000000, request 304398.992538 04/20/2026 16:31:29.611 7fd1abb40f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 04/20/2026 16:31:29.611 7fd1abb40f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.611 7fd1abb40f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 338 (601.3765335083008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1650778086, topics=[]) 04/20/2026 16:31:29.612 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1650778086 with 0 response partitions (1 implied) 04/20/2026 16:31:29.620 7fd1aa67fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207108.174316, idle connection 146223.000000, request 304398.201466 04/20/2026 16:31:29.620 7fd1aa67fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 371 04/20/2026 16:31:29.620 7fd1aa67fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.620 7fd1aa67fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 371 (602.1997928619385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=999676204, topics=[]) 04/20/2026 16:31:29.621 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 999676204 with 0 response partitions (1 implied) 04/20/2026 16:31:29.626 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4191 04/20/2026 16:31:29.626 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 04/20/2026 16:31:29.626 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch 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)]) 04/20/2026 16:31:29.626 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.626 7fd1a875be00 [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=250923993, session_epoch=491, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4191, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 16:31:29.626 7fd1a875be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 494 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=250923993, session_epoch=491, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4191, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 16:31:29.627 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206707.651855, idle connection 145731.000000, request 304999.951601 04/20/2026 16:31:29.627 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206707.241455, idle connection 145730.000000, request 304999.547720 04/20/2026 16:31:29.682 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 48 04/20/2026 16:31:29.683 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 04/20/2026 16:31:29.683 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 04/20/2026 16:31:29.683 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.683 7fd1abb40b80 [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=513729823, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.683 7fd1abb40b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=513729823, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.683 7fd1abb40b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207354.921631, idle connection 145974.000000, request 304999.947548 04/20/2026 16:31:29.684 7fd1abb40b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207354.422852, idle connection 145973.000000, request 304999.454737 04/20/2026 16:31:29.721 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207128.839111, idle connection 145992.000000, request 304397.387981 04/20/2026 16:31:29.721 7fd1aa67f400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350 04/20/2026 16:31:29.721 7fd1aa67f400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.721 7fd1aa67f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 350 (603.0941009521484 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1141748200, topics=[]) 04/20/2026 16:31:29.721 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1141748200 with 0 response partitions (1 implied) 04/20/2026 16:31:29.721 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206554.006592, idle connection 145790.000000, request 304397.719860 04/20/2026 16:31:29.722 7fd1abb48e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:29.722 7fd1abb48e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.722 7fd1abb48e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (602.8742790222168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2141696147, topics=[]) 04/20/2026 16:31:29.722 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2141696147 with 0 response partitions (1 implied) 04/20/2026 16:31:29.735 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 69 04/20/2026 16:31:29.736 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 04/20/2026 16:31:29.736 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 04/20/2026 16:31:29.736 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.736 7fd1abb40360 [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=663764101, session_epoch=341, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.736 7fd1abb40360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 344 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=663764101, session_epoch=341, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.736 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206551.416992, idle connection 145656.000000, request 304999.948025 04/20/2026 16:31:29.737 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206551.008301, idle connection 145655.000000, request 304999.546289 04/20/2026 16:31:29.796 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 04/20/2026 16:31:29.797 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 04/20/2026 16:31:29.797 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 04/20/2026 16:31:29.797 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.797 7fd1abb407c0 [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=15040451, session_epoch=341, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.797 7fd1abb407c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 344 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=15040451, session_epoch=341, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.797 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206636.391602, idle connection 145842.000000, request 304999.950171 04/20/2026 16:31:29.797 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206737.636963, idle connection 145897.000000, request 304397.247076 04/20/2026 16:31:29.798 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206635.816162, idle connection 145842.000000, request 304999.383211 04/20/2026 16:31:29.798 7fd1aa67f4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 04/20/2026 16:31:29.798 7fd1aa67f4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:29.798 7fd1aa67f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 340 (603.4610271453857 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1007649836, topics=[]) 04/20/2026 16:31:29.798 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1007649836 with 0 response partitions (1 implied) 04/20/2026 16:31:29.880 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 256 04/20/2026 16:31:29.880 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 04/20/2026 16:31:29.880 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 04/20/2026 16:31:29.881 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.881 7fd1aa67f5e0 [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=1499860736, session_epoch=354, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.881 7fd1aa67f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1499860736, session_epoch=354, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.881 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207316.223877, idle connection 145847.000000, request 304999.944925 04/20/2026 16:31:29.881 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207315.787109, idle connection 145847.000000, request 304999.517679 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 328 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.885 7fd1aa67f9a0 [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=1345452472, session_epoch=371, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 374 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1345452472, session_epoch=371, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206841.453369, idle connection 145994.000000, request 304999.957800 04/20/2026 16:31:29.885 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206841.118896, idle connection 145994.000000, request 304999.626398 04/20/2026 16:31:29.980 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 04/20/2026 16:31:29.980 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 16:31:29.980 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 16:31:29.981 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.981 7fd1abb40ae0 [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=906603407, session_epoch=326, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.981 7fd1abb40ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=906603407, session_epoch=326, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.981 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206629.137939, idle connection 145590.000000, request 304999.922276 04/20/2026 16:31:29.982 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206628.663574, idle connection 145590.000000, request 304999.461412 04/20/2026 16:31:29.997 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 47 04/20/2026 16:31:29.998 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 04/20/2026 16:31:29.998 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 04/20/2026 16:31:29.998 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:29.998 7fd1abb40900 [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=1416039116, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.998 7fd1abb40900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416039116, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:29.999 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206711.629395, idle connection 145596.000000, request 304999.928951 04/20/2026 16:31:29.999 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206711.051514, idle connection 145596.000000, request 304999.360085 04/20/2026 16:31:30.013 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206370.569092, idle connection 145614.000000, request 304399.030209 04/20/2026 16:31:30.013 7fd1abb40d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 337 04/20/2026 16:31:30.013 7fd1abb40d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.013 7fd1abb40d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 337 (601.7580032348633 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2062876540, topics=[]) 04/20/2026 16:31:30.014 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2062876540 with 0 response partitions (1 implied) 04/20/2026 16:31:30.015 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 48 04/20/2026 16:31:30.015 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 04/20/2026 16:31:30.015 7fd1abb40180 [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)]) 04/20/2026 16:31:30.015 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.015 7fd1abb40180 [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=1332913744, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.015 7fd1abb40180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1332913744, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.016 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206553.840820, idle connection 145559.000000, request 304999.932051 04/20/2026 16:31:30.016 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206553.403320, idle connection 145559.000000, request 304999.516249 04/20/2026 16:31:30.020 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207166.741943, idle connection 145810.000000, request 304399.164200 04/20/2026 16:31:30.021 7fd1aa67fa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 356 04/20/2026 16:31:30.021 7fd1aa67fa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.021 7fd1aa67fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 356 (601.262092590332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=754292121, topics=[]) 04/20/2026 16:31:30.021 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 754292121 with 0 response partitions (1 implied) 04/20/2026 16:31:30.077 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206003.234619, idle connection 145295.000000, request 304399.120569 04/20/2026 16:31:30.078 7fd1abb40040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 04/20/2026 16:31:30.078 7fd1abb40040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.078 7fd1abb40040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 329 (601.3648509979248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=368237388, topics=[]) 04/20/2026 16:31:30.078 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 368237388 with 0 response partitions (1 implied) 04/20/2026 16:31:30.094 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4 04/20/2026 16:31:30.094 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 04/20/2026 16:31:30.094 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 04/20/2026 16:31:30.094 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.094 7fd1a7f577c0 [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=1452532481, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.094 7fd1a7f577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1452532481, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.094 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206442.698975, idle connection 145387.000000, request 304999.952078 04/20/2026 16:31:30.095 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206442.319336, idle connection 145387.000000, request 304999.577522 04/20/2026 16:31:30.095 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 04/20/2026 16:31:30.095 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 04/20/2026 16:31:30.095 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 04/20/2026 16:31:30.095 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.095 7fd1abb48cc0 [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=237848852, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.095 7fd1abb48cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=237848852, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.095 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206629.389404, idle connection 145435.000000, request 304999.963284 04/20/2026 16:31:30.096 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 33 04/20/2026 16:31:30.096 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 04/20/2026 16:31:30.096 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 04/20/2026 16:31:30.096 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.096 7fd1abb40cc0 [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=545954357, session_epoch=336, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.096 7fd1abb40cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=545954357, session_epoch=336, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.096 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206794.397949, idle connection 145566.000000, request 304999.965191 04/20/2026 16:31:30.096 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206628.359619, idle connection 145434.000000, request 304998.935938 04/20/2026 16:31:30.097 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206793.867432, idle connection 145566.000000, request 304999.437809 04/20/2026 16:31:30.107 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 5 04/20/2026 16:31:30.108 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 04/20/2026 16:31:30.108 7fd1a7f314a0 [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)]) 04/20/2026 16:31:30.108 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.108 7fd1a7f314a0 [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=1336779373, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.108 7fd1a7f314a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1336779373, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.108 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206524.568359, idle connection 145361.000000, request 304999.953508 04/20/2026 16:31:30.108 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206524.243652, idle connection 145361.000000, request 304999.633074 04/20/2026 16:31:30.121 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206080.574951, idle connection 145419.000000, request 304398.526669 04/20/2026 16:31:30.121 7fd1abb48720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:30.121 7fd1abb48720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.121 7fd1abb48720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.8779277801514 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=494524825, topics=[]) 04/20/2026 16:31:30.121 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 494524825 with 0 response partitions (1 implied) 04/20/2026 16:31:30.124 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206738.633301, idle connection 145667.000000, request 304398.337603 04/20/2026 16:31:30.124 7fd1aa67fd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 347 04/20/2026 16:31:30.124 7fd1aa67fd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.124 7fd1aa67fd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 347 (602.0114421844482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=193969926, topics=[]) 04/20/2026 16:31:30.124 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 193969926 with 0 response partitions (1 implied) 04/20/2026 16:31:30.124 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206509.734863, idle connection 145639.000000, request 304398.356676 04/20/2026 16:31:30.125 7fd1aa67fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358 04/20/2026 16:31:30.125 7fd1aa67fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.125 7fd1aa67fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 358 (601.9208431243896 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2125397961, topics=[]) 04/20/2026 16:31:30.125 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2125397961 with 0 response partitions (1 implied) 04/20/2026 16:31:30.125 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 2 04/20/2026 16:31:30.125 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 04/20/2026 16:31:30.125 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 04/20/2026 16:31:30.125 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.125 7fd1abb40860 [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=792742380, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.125 7fd1abb40860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792742380, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.126 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206623.837402, idle connection 145431.000000, request 304999.963522 04/20/2026 16:31:30.126 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206623.512695, idle connection 145430.000000, request 304999.640703 04/20/2026 16:31:30.141 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 3 04/20/2026 16:31:30.141 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 04/20/2026 16:31:30.141 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 04/20/2026 16:31:30.141 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.142 7fd1a7f57400 [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=1785707653, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.142 7fd1a7f57400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1785707653, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.142 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207121.130615, idle connection 145361.000000, request 304999.956369 04/20/2026 16:31:30.142 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207120.778809, idle connection 145360.000000, request 304999.607801 04/20/2026 16:31:30.176 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 150 04/20/2026 16:31:30.176 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 04/20/2026 16:31:30.176 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 04/20/2026 16:31:30.176 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.176 7fd1aa67f220 [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=1785660822, session_epoch=348, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.176 7fd1aa67f220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1785660822, session_epoch=348, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.176 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206249.087158, idle connection 145563.000000, request 304999.955654 04/20/2026 16:31:30.177 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206248.751709, idle connection 145563.000000, request 304999.625683 04/20/2026 16:31:30.184 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 120 04/20/2026 16:31:30.184 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 16:31:30.184 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 04/20/2026 16:31:30.185 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.185 7fd1aa67fb80 [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=1236144512, session_epoch=346, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.185 7fd1aa67fb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1236144512, session_epoch=346, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.185 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206682.416504, idle connection 145682.000000, request 304999.960184 04/20/2026 16:31:30.185 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206682.090576, idle connection 145682.000000, request 304999.637365 04/20/2026 16:31:30.208 7fd1aa67f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207422.337402, idle connection 145602.000000, request 304398.959160 04/20/2026 16:31:30.208 7fd1aa67f7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 04/20/2026 16:31:30.208 7fd1aa67f7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.208 7fd1aa67f7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 341 (601.6795635223389 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=336118288, topics=[]) 04/20/2026 16:31:30.209 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 336118288 with 0 response partitions (1 implied) 04/20/2026 16:31:30.210 7fd1a7f31cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206072.125732, idle connection 145253.000000, request 304399.321079 04/20/2026 16:31:30.210 7fd1a7f31cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 04/20/2026 16:31:30.210 7fd1a7f31cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.210 7fd1a7f31cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 329 (601.1643409729004 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=883504057, topics=[]) 04/20/2026 16:31:30.210 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 883504057 with 0 response partitions (1 implied) 04/20/2026 16:31:30.212 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 34 04/20/2026 16:31:30.212 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 04/20/2026 16:31:30.212 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 04/20/2026 16:31:30.212 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.212 7fd1abb40f40 [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=1650778086, session_epoch=336, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.212 7fd1abb40f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1650778086, session_epoch=336, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.213 7fd1abb40f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207215.449951, idle connection 145395.000000, request 304999.946833 04/20/2026 16:31:30.213 7fd1abb40f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207214.959961, idle connection 145395.000000, request 304999.459505 04/20/2026 16:31:30.222 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 341 04/20/2026 16:31:30.222 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 04/20/2026 16:31:30.222 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 04/20/2026 16:31:30.222 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.222 7fd1aa67fcc0 [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=999676204, session_epoch=369, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.223 7fd1aa67fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 372 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=999676204, session_epoch=369, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.223 7fd1aa67fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206505.448242, idle connection 145621.000000, request 304999.936581 04/20/2026 16:31:30.223 7fd1aa67fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206504.906494, idle connection 145620.000000, request 304999.401569 04/20/2026 16:31:30.227 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206106.799316, idle connection 145130.000000, request 304399.099112 04/20/2026 16:31:30.228 7fd1a875be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 494 04/20/2026 16:31:30.228 7fd1a875be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.228 7fd1a875be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 494 (601.5233993530273 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=250923993, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4192, last_stable_offset=4192, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10_\x00\x00\x00\xfa\x00\x00\x00\x00\x02<\xafT\xf4\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\x8e\x03\x00\x00\x00\xd0\x02ObjectConfigNode:cn-jenkins-depl...')])]) 04/20/2026 16:31:30.228 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 250923993 with 1 response partitions (0 implied) 04/20/2026 16:31:30.228 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 262 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4191 04/20/2026 16:31:30.229 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4191 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 04/20/2026 16:31:30.229 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4192 (leader epoch 0) 04/20/2026 16:31:30.284 7fd1abb40b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206753.914795, idle connection 145373.000000, request 304398.940563 04/20/2026 16:31:30.285 7fd1abb40b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 04/20/2026 16:31:30.285 7fd1abb40b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.285 7fd1abb40b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 341 (601.6302108764648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=513729823, topics=[]) 04/20/2026 16:31:30.285 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 513729823 with 0 response partitions (1 implied) 04/20/2026 16:31:30.322 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 115 04/20/2026 16:31:30.322 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 16:31:30.322 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 16:31:30.322 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.322 7fd1aa67f400 [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=1141748200, session_epoch=348, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.322 7fd1aa67f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1141748200, session_epoch=348, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.322 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206527.028564, idle connection 145390.000000, request 304999.939919 04/20/2026 16:31:30.323 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206526.596680, idle connection 145390.000000, request 304999.516249 04/20/2026 16:31:30.323 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 5 04/20/2026 16:31:30.323 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 16:31:30.323 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 16:31:30.323 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.323 7fd1abb48e00 [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=2141696147, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.323 7fd1abb48e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2141696147, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.323 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205951.923096, idle connection 145188.000000, request 304999.962091 04/20/2026 16:31:30.324 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205951.438721, idle connection 145187.000000, request 304999.480724 04/20/2026 16:31:30.329 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4192 04/20/2026 16:31:30.329 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 04/20/2026 16:31:30.329 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch 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)]) 04/20/2026 16:31:30.330 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.330 7fd1a875be00 [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=250923993, session_epoch=492, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4192, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 16:31:30.330 7fd1a875be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 495 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=250923993, session_epoch=492, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4192, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 16:31:30.330 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206004.092529, idle connection 145027.000000, request 304999.932051 04/20/2026 16:31:30.331 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206003.647949, idle connection 145027.000000, request 304999.492884 04/20/2026 16:31:30.342 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205945.880127, idle connection 145050.000000, request 304394.408226 04/20/2026 16:31:30.342 7fd1abb40360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344 04/20/2026 16:31:30.342 7fd1abb40360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.342 7fd1abb40360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 344 (606.3120365142822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=663764101, topics=[]) 04/20/2026 16:31:30.343 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 663764101 with 0 response partitions (1 implied) 04/20/2026 16:31:30.399 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 45 04/20/2026 16:31:30.399 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 16:31:30.399 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 16:31:30.399 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.399 7fd1aa67f4a0 [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=1007649836, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.399 7fd1aa67f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1007649836, session_epoch=338, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.399 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206135.651123, idle connection 145295.000000, request 304999.942780 04/20/2026 16:31:30.400 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206033.892822, idle connection 145240.000000, request 304397.458076 04/20/2026 16:31:30.400 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206135.029785, idle connection 145295.000000, request 304999.331236 04/20/2026 16:31:30.400 7fd1abb407c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344 04/20/2026 16:31:30.400 7fd1abb407c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.400 7fd1abb407c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 344 (603.3775806427002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=15040451, topics=[]) 04/20/2026 16:31:30.401 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 15040451 with 0 response partitions (1 implied) 04/20/2026 16:31:30.482 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206715.242188, idle connection 145246.000000, request 304398.964643 04/20/2026 16:31:30.482 7fd1aa67f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357 04/20/2026 16:31:30.482 7fd1aa67f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.482 7fd1aa67f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 357 (601.6249656677246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1499860736, topics=[]) 04/20/2026 16:31:30.483 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1499860736 with 0 response partitions (1 implied) 04/20/2026 16:31:30.486 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206240.759033, idle connection 145394.000000, request 304399.259806 04/20/2026 16:31:30.486 7fd1aa67f9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 374 04/20/2026 16:31:30.486 7fd1aa67f9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.486 7fd1aa67f9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 374 (601.144552230835 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1345452472, topics=[]) 04/20/2026 16:31:30.486 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1345452472 with 0 response partitions (1 implied) 04/20/2026 16:31:30.582 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206028.066650, idle connection 144989.000000, request 304398.848295 04/20/2026 16:31:30.583 7fd1abb40ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 04/20/2026 16:31:30.583 7fd1abb40ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.583 7fd1abb40ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 329 (601.982593536377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=906603407, topics=[]) 04/20/2026 16:31:30.583 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 906603407 with 0 response partitions (1 implied) 04/20/2026 16:31:30.600 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206110.448730, idle connection 144995.000000, request 304398.746729 04/20/2026 16:31:30.600 7fd1abb40900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342 04/20/2026 16:31:30.600 7fd1abb40900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.600 7fd1abb40900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 342 (602.0088195800781 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416039116, topics=[]) 04/20/2026 16:31:30.601 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416039116 with 0 response partitions (1 implied) 04/20/2026 16:31:30.614 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 31 04/20/2026 16:31:30.614 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 04/20/2026 16:31:30.614 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 04/20/2026 16:31:30.615 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.615 7fd1abb40d60 [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=2062876540, session_epoch=335, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.615 7fd1abb40d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062876540, session_epoch=335, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.615 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205768.010498, idle connection 145011.000000, request 304999.927759 04/20/2026 16:31:30.616 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205767.456055, idle connection 145010.000000, request 304999.381065 04/20/2026 16:31:30.616 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205953.092041, idle connection 144959.000000, request 304399.204493 04/20/2026 16:31:30.617 7fd1abb40180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 04/20/2026 16:31:30.617 7fd1abb40180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.617 7fd1abb40180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 341 (601.1545658111572 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1332913744, topics=[]) 04/20/2026 16:31:30.617 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1332913744 with 0 response partitions (1 implied) 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 234 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.622 7fd1aa67fa40 [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=754292121, session_epoch=354, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=754292121, session_epoch=354, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206564.912598, idle connection 145208.000000, request 304999.958277 04/20/2026 16:31:30.622 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206564.564453, idle connection 145208.000000, request 304999.613047 04/20/2026 16:31:30.678 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 04/20/2026 16:31:30.678 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 04/20/2026 16:31:30.679 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 04/20/2026 16:31:30.679 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.679 7fd1abb40040 [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=368237388, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.679 7fd1abb40040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368237388, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.679 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205401.563232, idle connection 144693.000000, request 304999.949694 04/20/2026 16:31:30.679 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205401.165527, idle connection 144693.000000, request 304999.558449 04/20/2026 16:31:30.696 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205841.238770, idle connection 144786.000000, request 304398.490191 04/20/2026 16:31:30.696 7fd1a7f577c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:30.696 7fd1a7f577c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.696 7fd1a7f577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (601.994514465332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1452532481, topics=[]) 04/20/2026 16:31:30.696 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1452532481 with 0 response partitions (1 implied) 04/20/2026 16:31:30.697 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206027.845459, idle connection 144833.000000, request 304398.419142 04/20/2026 16:31:30.697 7fd1abb48cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:30.697 7fd1abb48cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.697 7fd1abb48cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.8767356872559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=237848852, topics=[]) 04/20/2026 16:31:30.697 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 237848852 with 0 response partitions (1 implied) 04/20/2026 16:31:30.698 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206193.020996, idle connection 144965.000000, request 304398.589373 04/20/2026 16:31:30.698 7fd1abb40cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 04/20/2026 16:31:30.698 7fd1abb40cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.698 7fd1abb40cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 339 (601.6747951507568 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=545954357, topics=[]) 04/20/2026 16:31:30.698 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 545954357 with 0 response partitions (1 implied) 04/20/2026 16:31:30.709 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205923.595459, idle connection 144760.000000, request 304398.981333 04/20/2026 16:31:30.709 7fd1a7f314a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 04/20/2026 16:31:30.709 7fd1a7f314a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.709 7fd1a7f314a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 332 (601.4130115509033 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1336779373, topics=[]) 04/20/2026 16:31:30.710 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1336779373 with 0 response partitions (1 implied) 04/20/2026 16:31:30.722 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 04/20/2026 16:31:30.722 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 04/20/2026 16:31:30.722 7fd1abb48720 [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)]) 04/20/2026 16:31:30.722 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.722 7fd1abb48720 [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=494524825, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.722 7fd1abb48720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=494524825, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.722 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205479.076172, idle connection 144817.000000, request 304999.951601 04/20/2026 16:31:30.723 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205478.698975, idle connection 144817.000000, request 304999.580145 04/20/2026 16:31:30.725 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78 04/20/2026 16:31:30.725 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 04/20/2026 16:31:30.725 7fd1aa67fd60 [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)]) 04/20/2026 16:31:30.725 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.725 7fd1aa67fd60 [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=193969926, session_epoch=345, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.725 7fd1aa67fd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 348 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=193969926, session_epoch=345, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.725 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206137.356445, idle connection 145065.000000, request 304999.957561 04/20/2026 16:31:30.725 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 188 04/20/2026 16:31:30.725 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 16:31:30.725 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 16:31:30.725 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.726 7fd1aa67fc20 [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=2125397961, session_epoch=356, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.726 7fd1aa67fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 359 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2125397961, session_epoch=356, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.726 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205908.473145, idle connection 145037.000000, request 304999.965906 04/20/2026 16:31:30.726 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206136.413086, idle connection 145065.000000, request 304999.018192 04/20/2026 16:31:30.726 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206023.137695, idle connection 144830.000000, request 304399.264812 04/20/2026 16:31:30.726 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205907.760498, idle connection 145037.000000, request 304999.255657 04/20/2026 16:31:30.727 7fd1abb40860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:30.727 7fd1abb40860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.727 7fd1abb40860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.3524532318115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792742380, topics=[]) 04/20/2026 16:31:30.727 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 792742380 with 0 response partitions (1 implied) 04/20/2026 16:31:30.743 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206520.385986, idle connection 144760.000000, request 304399.209499 04/20/2026 16:31:30.743 7fd1a7f57400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:30.743 7fd1a7f57400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.743 7fd1a7f57400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (601.2229919433594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785707653, topics=[]) 04/20/2026 16:31:30.743 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785707653 with 0 response partitions (1 implied) 04/20/2026 16:31:30.777 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205648.283691, idle connection 144963.000000, request 304399.148941 04/20/2026 16:31:30.777 7fd1aa67f220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 351 04/20/2026 16:31:30.778 7fd1aa67f220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.778 7fd1aa67f220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 351 (601.3164520263672 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785660822, topics=[]) 04/20/2026 16:31:30.778 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785660822 with 0 response partitions (1 implied) 04/20/2026 16:31:30.786 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206081.710938, idle connection 145082.000000, request 304399.245739 04/20/2026 16:31:30.786 7fd1aa67fb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 349 04/20/2026 16:31:30.786 7fd1aa67fb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.786 7fd1aa67fb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 349 (601.1898517608643 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1236144512, topics=[]) 04/20/2026 16:31:30.786 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1236144512 with 0 response partitions (1 implied) 04/20/2026 16:31:30.809 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 100 04/20/2026 16:31:30.809 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 16:31:30.809 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 16:31:30.809 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.809 7fd1aa67f7c0 [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=336118288, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.810 7fd1aa67f7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=336118288, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.810 7fd1aa67f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206820.429932, idle connection 145000.000000, request 304999.951601 04/20/2026 16:31:30.810 7fd1aa67f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206819.979736, idle connection 145000.000000, request 304999.507427 04/20/2026 16:31:30.810 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 04/20/2026 16:31:30.811 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 04/20/2026 16:31:30.811 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 04/20/2026 16:31:30.811 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.811 7fd1a7f31cc0 [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=883504057, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.811 7fd1a7f31cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=883504057, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.811 7fd1a7f31cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205470.699951, idle connection 144651.000000, request 304999.963522 04/20/2026 16:31:30.811 7fd1a7f31cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205470.411865, idle connection 144651.000000, request 304999.678135 04/20/2026 16:31:30.814 7fd1abb40f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206614.550293, idle connection 144795.000000, request 304399.052382 04/20/2026 16:31:30.814 7fd1abb40f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 04/20/2026 16:31:30.814 7fd1abb40f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.814 7fd1abb40f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 339 (601.3038158416748 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1650778086, topics=[]) 04/20/2026 16:31:30.814 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1650778086 with 0 response partitions (1 implied) 04/20/2026 16:31:30.824 7fd1aa67fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205904.219482, idle connection 145019.000000, request 304398.712158 04/20/2026 16:31:30.824 7fd1aa67fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 372 04/20/2026 16:31:30.824 7fd1aa67fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.824 7fd1aa67fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 372 (601.7510890960693 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=999676204, topics=[]) 04/20/2026 16:31:30.825 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 999676204 with 0 response partitions (1 implied) 04/20/2026 16:31:30.885 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 48 04/20/2026 16:31:30.885 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 04/20/2026 16:31:30.886 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 04/20/2026 16:31:30.886 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.886 7fd1abb40b80 [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=513729823, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.886 7fd1abb40b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=513729823, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.886 7fd1abb40b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206152.085693, idle connection 144771.000000, request 304999.947071 04/20/2026 16:31:30.886 7fd1abb40b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206151.681396, idle connection 144770.000000, request 304999.548435 04/20/2026 16:31:30.924 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205925.337402, idle connection 144789.000000, request 304398.248672 04/20/2026 16:31:30.924 7fd1aa67f400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 351 04/20/2026 16:31:30.924 7fd1aa67f400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.924 7fd1aa67f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 351 (602.2355556488037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1141748200, topics=[]) 04/20/2026 16:31:30.925 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1141748200 with 0 response partitions (1 implied) 04/20/2026 16:31:30.925 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205350.576416, idle connection 144586.000000, request 304398.616552 04/20/2026 16:31:30.925 7fd1abb48e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:30.925 7fd1abb48e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.925 7fd1abb48e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (601.7603874206543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2141696147, topics=[]) 04/20/2026 16:31:30.925 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2141696147 with 0 response partitions (1 implied) 04/20/2026 16:31:30.931 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205403.260010, idle connection 144426.000000, request 304399.096966 04/20/2026 16:31:30.931 7fd1a875be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 495 04/20/2026 16:31:30.931 7fd1a875be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:30.931 7fd1a875be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 495 (601.3095378875732 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=250923993, topics=[]) 04/20/2026 16:31:30.931 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 250923993 with 0 response partitions (1 implied) 04/20/2026 16:31:30.943 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 69 04/20/2026 16:31:30.943 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 04/20/2026 16:31:30.943 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 04/20/2026 16:31:30.943 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:30.943 7fd1abb40360 [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=663764101, session_epoch=342, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.943 7fd1abb40360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 345 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=663764101, session_epoch=342, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:30.943 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205344.096924, idle connection 144448.000000, request 304999.949694 04/20/2026 16:31:30.944 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205343.693359, idle connection 144448.000000, request 304999.552488 04/20/2026 16:31:31.001 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 04/20/2026 16:31:31.001 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 04/20/2026 16:31:31.001 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 04/20/2026 16:31:31.001 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.001 7fd1abb407c0 [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=15040451, session_epoch=342, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.002 7fd1abb407c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 345 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=15040451, session_epoch=342, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.002 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205431.882324, idle connection 144638.000000, request 304999.951124 04/20/2026 16:31:31.002 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205533.135010, idle connection 144693.000000, request 304397.435665 04/20/2026 16:31:31.002 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205431.316406, idle connection 144637.000000, request 304999.392271 04/20/2026 16:31:31.002 7fd1aa67f4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 04/20/2026 16:31:31.002 7fd1aa67f4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.003 7fd1aa67f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 341 (603.2445430755615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1007649836, topics=[]) 04/20/2026 16:31:31.003 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1007649836 with 0 response partitions (1 implied) 04/20/2026 16:31:31.084 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 256 04/20/2026 16:31:31.084 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 04/20/2026 16:31:31.084 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 04/20/2026 16:31:31.084 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.084 7fd1aa67f5e0 [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=1499860736, session_epoch=355, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.084 7fd1aa67f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1499860736, session_epoch=355, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.084 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206112.689941, idle connection 144644.000000, request 304999.949694 04/20/2026 16:31:31.085 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206112.250488, idle connection 144643.000000, request 304999.516964 04/20/2026 16:31:31.087 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 328 04/20/2026 16:31:31.087 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 04/20/2026 16:31:31.087 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 04/20/2026 16:31:31.087 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.087 7fd1aa67f9a0 [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=1345452472, session_epoch=372, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.087 7fd1aa67f9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 375 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1345452472, session_epoch=372, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.087 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205639.317139, idle connection 144792.000000, request 304999.956846 04/20/2026 16:31:31.088 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205638.973877, idle connection 144792.000000, request 304999.617100 04/20/2026 16:31:31.184 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 04/20/2026 16:31:31.184 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 16:31:31.184 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 16:31:31.184 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.184 7fd1abb40ae0 [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=906603407, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.184 7fd1abb40ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=906603407, session_epoch=327, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.184 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205425.778809, idle connection 144387.000000, request 304999.949455 04/20/2026 16:31:31.185 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205425.364014, idle connection 144386.000000, request 304999.541044 04/20/2026 16:31:31.201 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 47 04/20/2026 16:31:31.201 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 04/20/2026 16:31:31.202 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 04/20/2026 16:31:31.202 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.202 7fd1abb40900 [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=1416039116, session_epoch=340, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.202 7fd1abb40900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 343 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416039116, session_epoch=340, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.202 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205507.898193, idle connection 144393.000000, request 304999.922037 04/20/2026 16:31:31.203 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205507.291016, idle connection 144392.000000, request 304999.326468 04/20/2026 16:31:31.216 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205166.895020, idle connection 144410.000000, request 304398.815870 04/20/2026 16:31:31.217 7fd1abb40d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 04/20/2026 16:31:31.217 7fd1abb40d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.217 7fd1abb40d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 338 (601.6845703125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2062876540, topics=[]) 04/20/2026 16:31:31.217 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2062876540 with 0 response partitions (1 implied) 04/20/2026 16:31:31.217 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 48 04/20/2026 16:31:31.217 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 04/20/2026 16:31:31.217 7fd1abb40180 [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)]) 04/20/2026 16:31:31.217 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.217 7fd1abb40180 [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=1332913744, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.218 7fd1abb40180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1332913744, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.218 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205351.793213, idle connection 144357.000000, request 304999.958515 04/20/2026 16:31:31.218 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205351.402344, idle connection 144357.000000, request 304999.570370 04/20/2026 16:31:31.223 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205964.023926, idle connection 144607.000000, request 304399.068117 04/20/2026 16:31:31.223 7fd1aa67fa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357 04/20/2026 16:31:31.223 7fd1aa67fa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.224 7fd1aa67fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 357 (601.5000343322754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=754292121, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=236, last_stable_offset=236, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xea\x00\x00\x02\x11\x00\x00\x00\x00\x02\xd8\xa2\x8aV\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...')])]) 04/20/2026 16:31:31.224 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 754292121 with 1 response partitions (0 implied) 04/20/2026 16:31:31.224 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 541 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 234 04/20/2026 16:31:31.224 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 234 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 04/20/2026 16:31:31.224 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 236 (leader epoch 0) 04/20/2026 16:31:31.280 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204800.699463, idle connection 144092.000000, request 304399.080038 04/20/2026 16:31:31.280 7fd1abb40040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:31.280 7fd1abb40040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.280 7fd1abb40040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.4578342437744 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=368237388, topics=[]) 04/20/2026 16:31:31.281 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 368237388 with 0 response partitions (1 implied) 04/20/2026 16:31:31.297 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4 04/20/2026 16:31:31.297 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 04/20/2026 16:31:31.297 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 04/20/2026 16:31:31.297 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.297 7fd1a7f577c0 [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=1452532481, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.297 7fd1a7f577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1452532481, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.298 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205239.571533, idle connection 144184.000000, request 304999.943256 04/20/2026 16:31:31.298 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 04/20/2026 16:31:31.298 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 04/20/2026 16:31:31.298 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 04/20/2026 16:31:31.298 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.298 7fd1abb48cc0 [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=237848852, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.298 7fd1abb48cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=237848852, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.298 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205426.554688, idle connection 144232.000000, request 304999.960661 04/20/2026 16:31:31.299 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205238.435303, idle connection 144183.000000, request 304998.818159 04/20/2026 16:31:31.299 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 33 04/20/2026 16:31:31.299 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 04/20/2026 16:31:31.299 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 04/20/2026 16:31:31.299 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.299 7fd1abb40cc0 [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=545954357, session_epoch=337, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.299 7fd1abb40cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=545954357, session_epoch=337, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.299 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205591.122314, idle connection 144363.000000, request 304999.949455 04/20/2026 16:31:31.300 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205424.975586, idle connection 144230.000000, request 304998.385191 04/20/2026 16:31:31.300 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205590.338623, idle connection 144362.000000, request 304999.172688 04/20/2026 16:31:31.310 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 5 04/20/2026 16:31:31.310 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 04/20/2026 16:31:31.310 7fd1a7f314a0 [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)]) 04/20/2026 16:31:31.310 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.310 7fd1a7f314a0 [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=1336779373, session_epoch=330, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.311 7fd1a7f314a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1336779373, session_epoch=330, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.311 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205321.879150, idle connection 144159.000000, request 304999.940634 04/20/2026 16:31:31.311 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205321.365479, idle connection 144158.000000, request 304999.434233 04/20/2026 16:31:31.323 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204878.191162, idle connection 144216.000000, request 304399.064302 04/20/2026 16:31:31.324 7fd1abb48720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:31.324 7fd1abb48720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.324 7fd1abb48720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (601.569414138794 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=494524825, topics=[]) 04/20/2026 16:31:31.324 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 494524825 with 0 response partitions (1 implied) 04/20/2026 16:31:31.325 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 236 04/20/2026 16:31:31.325 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 04/20/2026 16:31:31.325 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch 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)]) 04/20/2026 16:31:31.325 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.325 7fd1aa67fa40 [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=754292121, session_epoch=355, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=236, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 16:31:31.325 7fd1aa67fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=754292121, session_epoch=355, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=236, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 16:31:31.326 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205861.531982, idle connection 144505.000000, request 304999.945641 04/20/2026 16:31:31.326 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205861.110107, idle connection 144504.000000, request 304999.527454 04/20/2026 16:31:31.327 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205535.691895, idle connection 144464.000000, request 304398.294449 04/20/2026 16:31:31.327 7fd1aa67fd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 348 04/20/2026 16:31:31.327 7fd1aa67fd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.327 7fd1aa67fd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 348 (602.0722389221191 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=193969926, topics=[]) 04/20/2026 16:31:31.327 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 193969926 with 0 response partitions (1 implied) 04/20/2026 16:31:31.327 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 2 04/20/2026 16:31:31.327 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 04/20/2026 16:31:31.328 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 04/20/2026 16:31:31.328 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.328 7fd1abb40860 [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=792742380, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.328 7fd1abb40860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792742380, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.328 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205421.324951, idle connection 144228.000000, request 304999.960423 04/20/2026 16:31:31.328 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205305.997803, idle connection 144435.000000, request 304397.490740 04/20/2026 16:31:31.329 7fd1aa67fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 359 04/20/2026 16:31:31.329 7fd1aa67fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.329 7fd1aa67fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 359 (603.6462783813477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2125397961, topics=[]) 04/20/2026 16:31:31.329 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2125397961 with 0 response partitions (1 implied) 04/20/2026 16:31:31.330 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205419.510742, idle connection 144226.000000, request 304998.148203 04/20/2026 16:31:31.343 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 3 04/20/2026 16:31:31.344 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 04/20/2026 16:31:31.344 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 04/20/2026 16:31:31.344 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.344 7fd1a7f57400 [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=1785707653, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.344 7fd1a7f57400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1785707653, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.344 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205918.762695, idle connection 144158.000000, request 304999.938250 04/20/2026 16:31:31.345 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205918.348145, idle connection 144158.000000, request 304999.529123 04/20/2026 16:31:31.378 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 150 04/20/2026 16:31:31.378 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 04/20/2026 16:31:31.378 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 04/20/2026 16:31:31.379 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.379 7fd1aa67f220 [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=1785660822, session_epoch=349, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.379 7fd1aa67f220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 352 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1785660822, session_epoch=349, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.379 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205046.577637, idle connection 144361.000000, request 304999.947071 04/20/2026 16:31:31.379 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205046.097656, idle connection 144360.000000, request 304999.474525 04/20/2026 16:31:31.387 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 120 04/20/2026 16:31:31.387 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 16:31:31.387 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 04/20/2026 16:31:31.387 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.387 7fd1aa67fb80 [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=1236144512, session_epoch=347, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.387 7fd1aa67fb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1236144512, session_epoch=347, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.388 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205479.761230, idle connection 144480.000000, request 304999.928474 04/20/2026 16:31:31.388 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205479.256348, idle connection 144479.000000, request 304999.436855 04/20/2026 16:31:31.411 7fd1aa67f7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206219.520264, idle connection 144399.000000, request 304399.038792 04/20/2026 16:31:31.411 7fd1aa67f7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342 04/20/2026 16:31:31.411 7fd1aa67f7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.411 7fd1aa67f7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 342 (601.5243530273438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=336118288, topics=[]) 04/20/2026 16:31:31.411 7fd1aa67f7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 336118288 with 0 response partitions (1 implied) 04/20/2026 16:31:31.412 7fd1a7f31cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204870.130127, idle connection 144051.000000, request 304399.389505 04/20/2026 16:31:31.412 7fd1a7f31cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:31.412 7fd1a7f31cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.412 7fd1a7f31cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.0541915893555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=883504057, topics=[]) 04/20/2026 16:31:31.412 7fd1a7f31cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 883504057 with 0 response partitions (1 implied) 04/20/2026 16:31:31.414 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 34 04/20/2026 16:31:31.414 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 04/20/2026 16:31:31.414 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 04/20/2026 16:31:31.415 7fd1abb40f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.415 7fd1abb40f40 [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=1650778086, session_epoch=337, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.415 7fd1abb40f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1650778086, session_epoch=337, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.415 7fd1abb40f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206013.082275, idle connection 144193.000000, request 304999.930382 04/20/2026 16:31:31.415 7fd1abb40f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206012.662354, idle connection 144193.000000, request 304999.518871 04/20/2026 16:31:31.425 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 341 04/20/2026 16:31:31.425 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 04/20/2026 16:31:31.425 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 04/20/2026 16:31:31.425 7fd1aa67fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.425 7fd1aa67fcc0 [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=999676204, session_epoch=370, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.426 7fd1aa67fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 373 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=999676204, session_epoch=370, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.426 7fd1aa67fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205302.375000, idle connection 144418.000000, request 304999.953032 04/20/2026 16:31:31.426 7fd1aa67fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205301.975830, idle connection 144417.000000, request 304999.559641 04/20/2026 16:31:31.487 7fd1abb40b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205551.099854, idle connection 144170.000000, request 304398.960352 04/20/2026 16:31:31.487 7fd1abb40b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342 04/20/2026 16:31:31.487 7fd1abb40b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.488 7fd1abb40b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 342 (601.5472412109375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=513729823, topics=[]) 04/20/2026 16:31:31.488 7fd1abb40b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 513729823 with 0 response partitions (1 implied) 04/20/2026 16:31:31.525 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 115 04/20/2026 16:31:31.525 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 16:31:31.525 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 16:31:31.525 7fd1aa67f400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.525 7fd1aa67f400 [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=1141748200, session_epoch=349, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.525 7fd1aa67f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 352 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1141748200, session_epoch=349, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.526 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205323.763672, idle connection 144187.000000, request 304999.948263 04/20/2026 16:31:31.526 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 5 04/20/2026 16:31:31.526 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 16:31:31.526 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 16:31:31.526 7fd1abb48e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.526 7fd1abb48e00 [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=2141696147, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.526 7fd1abb48e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2141696147, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.526 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204749.053955, idle connection 143985.000000, request 304999.948978 04/20/2026 16:31:31.527 7fd1aa67f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205322.526611, idle connection 144186.000000, request 304998.715878 04/20/2026 16:31:31.527 7fd1abb48e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204748.157715, idle connection 143984.000000, request 304999.058008 04/20/2026 16:31:31.532 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4192 04/20/2026 16:31:31.532 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 04/20/2026 16:31:31.532 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 04/20/2026 16:31:31.532 7fd1a875be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.532 7fd1a875be00 [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=250923993, session_epoch=493, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.533 7fd1a875be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 496 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=250923993, session_epoch=493, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.533 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204801.510498, idle connection 143825.000000, request 304999.938250 04/20/2026 16:31:31.533 7fd1a875be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204800.971436, idle connection 143824.000000, request 304999.406576 04/20/2026 16:31:31.544 7fd1abb40360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204743.138672, idle connection 143847.000000, request 304398.989916 04/20/2026 16:31:31.545 7fd1abb40360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345 04/20/2026 16:31:31.545 7fd1abb40360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.545 7fd1abb40360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 345 (601.5310287475586 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=663764101, topics=[]) 04/20/2026 16:31:31.545 7fd1abb40360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 663764101 with 0 response partitions (1 implied) 04/20/2026 16:31:31.603 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 45 04/20/2026 16:31:31.603 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 16:31:31.603 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 16:31:31.603 7fd1aa67f4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.604 7fd1aa67f4a0 [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=1007649836, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.604 7fd1aa67f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1007649836, session_epoch=339, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.604 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204931.172119, idle connection 144091.000000, request 304999.947309 04/20/2026 16:31:31.604 7fd1abb407c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204829.335205, idle connection 144035.000000, request 304397.404909 04/20/2026 16:31:31.605 7fd1aa67f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204930.434570, idle connection 144090.000000, request 304999.217987 04/20/2026 16:31:31.605 7fd1abb407c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345 04/20/2026 16:31:31.605 7fd1abb407c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.605 7fd1abb407c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 345 (603.3604145050049 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=15040451, topics=[]) 04/20/2026 16:31:31.605 7fd1abb407c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 15040451 with 0 response partitions (1 implied) 04/20/2026 16:31:31.685 7fd1aa67f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205511.762207, idle connection 144043.000000, request 304399.020195 04/20/2026 16:31:31.686 7fd1aa67f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358 04/20/2026 16:31:31.686 7fd1aa67f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.686 7fd1aa67f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 358 (601.548433303833 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1499860736, topics=[]) 04/20/2026 16:31:31.686 7fd1aa67f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1499860736 with 0 response partitions (1 implied) 04/20/2026 16:31:31.688 7fd1aa67f9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205038.556396, idle connection 144192.000000, request 304399.194717 04/20/2026 16:31:31.688 7fd1aa67f9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 375 04/20/2026 16:31:31.688 7fd1aa67f9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.688 7fd1aa67f9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 375 (601.1645793914795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1345452472, topics=[]) 04/20/2026 16:31:31.689 7fd1aa67f9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1345452472 with 0 response partitions (1 implied) 04/20/2026 16:31:31.785 7fd1abb40ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204824.868652, idle connection 143786.000000, request 304399.039507 04/20/2026 16:31:31.786 7fd1abb40ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 04/20/2026 16:31:31.786 7fd1abb40ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.786 7fd1abb40ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 330 (601.4571189880371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=906603407, topics=[]) 04/20/2026 16:31:31.786 7fd1abb40ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 906603407 with 0 response partitions (1 implied) 04/20/2026 16:31:31.804 7fd1abb40900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204906.644775, idle connection 143791.000000, request 304398.672342 04/20/2026 16:31:31.804 7fd1abb40900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 343 04/20/2026 16:31:31.804 7fd1abb40900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.804 7fd1abb40900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 343 (602.0758152008057 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416039116, topics=[]) 04/20/2026 16:31:31.804 7fd1abb40900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416039116 with 0 response partitions (1 implied) 04/20/2026 16:31:31.817 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 31 04/20/2026 16:31:31.818 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 04/20/2026 16:31:31.818 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 04/20/2026 16:31:31.818 7fd1abb40d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.818 7fd1abb40d60 [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=2062876540, session_epoch=336, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.818 7fd1abb40d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062876540, session_epoch=336, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.818 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204565.011230, idle connection 143808.000000, request 304999.943733 04/20/2026 16:31:31.818 7fd1abb40180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204751.031250, idle connection 143757.000000, request 304399.198055 04/20/2026 16:31:31.819 7fd1abb40d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204564.414551, idle connection 143807.000000, request 304999.356508 04/20/2026 16:31:31.819 7fd1abb40180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342 04/20/2026 16:31:31.819 7fd1abb40180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.819 7fd1abb40180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 342 (601.646900177002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1332913744, topics=[]) 04/20/2026 16:31:31.819 7fd1abb40180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1332913744 with 0 response partitions (1 implied) 04/20/2026 16:31:31.881 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 04/20/2026 16:31:31.881 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 04/20/2026 16:31:31.881 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 04/20/2026 16:31:31.881 7fd1abb40040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.881 7fd1abb40040 [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=368237388, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.881 7fd1abb40040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=368237388, session_epoch=328, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.882 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204198.968262, idle connection 143491.000000, request 304999.950647 04/20/2026 16:31:31.882 7fd1abb40040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204198.556885, idle connection 143490.000000, request 304999.545574 04/20/2026 16:31:31.900 7fd1a7f577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204636.732666, idle connection 143581.000000, request 304397.106886 04/20/2026 16:31:31.901 7fd1a7f577c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 04/20/2026 16:31:31.901 7fd1a7f577c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.901 7fd1a7f577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 332 (603.384256362915 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1452532481, topics=[]) 04/20/2026 16:31:31.901 7fd1a7f577c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1452532481 with 0 response partitions (1 implied) 04/20/2026 16:31:31.901 7fd1abb48cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204823.492188, idle connection 143629.000000, request 304396.899223 04/20/2026 16:31:31.901 7fd1abb40cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204989.113037, idle connection 143761.000000, request 304397.945881 04/20/2026 16:31:31.902 7fd1abb48cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:31.902 7fd1abb48cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.902 7fd1abb48cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (603.5261154174805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=237848852, topics=[]) 04/20/2026 16:31:31.902 7fd1abb48cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 237848852 with 0 response partitions (1 implied) 04/20/2026 16:31:31.902 7fd1abb40cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 04/20/2026 16:31:31.902 7fd1abb40cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.902 7fd1abb40cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 340 (602.9331684112549 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=545954357, topics=[]) 04/20/2026 16:31:31.902 7fd1abb40cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 545954357 with 0 response partitions (1 implied) 04/20/2026 16:31:31.913 7fd1a7f314a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204720.123535, idle connection 143557.000000, request 304398.188829 04/20/2026 16:31:31.913 7fd1a7f314a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333 04/20/2026 16:31:31.913 7fd1a7f314a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.913 7fd1a7f314a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 333 (602.2706031799316 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1336779373, topics=[]) 04/20/2026 16:31:31.913 7fd1a7f314a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1336779373 with 0 response partitions (1 implied) 04/20/2026 16:31:31.924 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 04/20/2026 16:31:31.925 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 04/20/2026 16:31:31.925 7fd1abb48720 [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)]) 04/20/2026 16:31:31.925 7fd1abb48720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.925 7fd1abb48720 [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=494524825, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.925 7fd1abb48720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=494524825, session_epoch=329, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.925 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204276.175781, idle connection 143614.000000, request 304999.937773 04/20/2026 16:31:31.926 7fd1abb48720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204275.683350, idle connection 143614.000000, request 304999.452829 04/20/2026 16:31:31.926 7fd1aa67fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205260.626709, idle connection 143904.000000, request 304399.042606 04/20/2026 16:31:31.927 7fd1aa67fa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358 04/20/2026 16:31:31.927 7fd1aa67fa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.927 7fd1aa67fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 358 (601.3751029968262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=754292121, topics=[]) 04/20/2026 16:31:31.927 7fd1aa67fa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 754292121 with 0 response partitions (1 implied) 04/20/2026 16:31:31.927 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78 04/20/2026 16:31:31.928 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 04/20/2026 16:31:31.928 7fd1aa67fd60 [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)]) 04/20/2026 16:31:31.928 7fd1aa67fd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.928 7fd1aa67fd60 [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=193969926, session_epoch=346, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.928 7fd1aa67fd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=193969926, session_epoch=346, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.928 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204934.246338, idle connection 143862.000000, request 304999.946117 04/20/2026 16:31:31.929 7fd1aa67fd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204933.808350, idle connection 143862.000000, request 304999.513626 04/20/2026 16:31:31.930 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 188 04/20/2026 16:31:31.930 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 16:31:31.930 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 16:31:31.930 7fd1aa67fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 16:31:31.930 7fd1aa67fc20 [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=2125397961, session_epoch=357, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.930 7fd1aa67fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 360 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2125397961, session_epoch=357, topics=[], forgotten_topics_data=[]) 04/20/2026 16:31:31.930 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204703.804443, idle connection 143833.000000, request 304999.959946 04/20/2026 16:31:31.931 7fd1abb40860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204818.755127, idle connection 143626.000000, request 304397.392035 04/20/2026 16:31:31.931 7fd1aa67fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204703.313721, idle connection 143832.000000, request 304999.469757 04/20/2026 16:31:31.931 7fd1abb40860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 04/20/2026 16:31:31.931 7fd1abb40860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.931 7fd1abb40860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 331 (603.391170501709 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792742380, topics=[]) 04/20/2026 16:31:31.932 7fd1abb40860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 792742380 with 0 response partitions (1 implied) 04/20/2026 16:31:31.945 7fd1a7f57400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205317.796387, idle connection 143557.000000, request 304398.972750 04/20/2026 16:31:31.945 7fd1a7f57400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 04/20/2026 16:31:31.946 7fd1a7f57400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.946 7fd1a7f57400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 332 (601.5620231628418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785707653, topics=[]) 04/20/2026 16:31:31.946 7fd1a7f57400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785707653 with 0 response partitions (1 implied) 04/20/2026 16:31:31.980 7fd1aa67f220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204445.567139, idle connection 143760.000000, request 304398.930073 04/20/2026 16:31:31.980 7fd1aa67f220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 352 04/20/2026 16:31:31.980 7fd1aa67f220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.981 7fd1aa67f220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 352 (601.7534732818604 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785660822, topics=[]) 04/20/2026 16:31:31.981 7fd1aa67f220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785660822 with 0 response partitions (1 implied) 04/20/2026 16:31:31.988 7fd1aa67fb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204878.830811, idle connection 143879.000000, request 304399.005175 04/20/2026 16:31:31.989 7fd1aa67fb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350 04/20/2026 16:31:31.989 7fd1aa67fb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 16:31:31.989 7fd1aa67fb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 350 (601.4466285705566 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1236144512, topics=[]) 04/20/2026 16:31:31.989 7fd1aa67fb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1236144512 with 0 response partitions (1 implied)