10/13/2025 02:08:17.553 7f6550dd0720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 10/13/2025 02:08:17.554 7f6550dd0720 [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)]) 10/13/2025 02:08:17.554 7f6550dd0720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.554 7f6550dd0720 [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=1897201992, session_epoch=686, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.554 7f6550dd0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1897201992, session_epoch=686, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.554 7f6550dd0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83962.592041, idle connection 261293.000000, request 304999.950409 10/13/2025 02:08:17.555 7f6551bf3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83289.902588, idle connection 260656.000000, request 304395.897627 10/13/2025 02:08:17.555 7f6551bc8a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84280.697510, idle connection 261043.000000, request 304396.402359 10/13/2025 02:08:17.555 7f6550dd0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83961.820557, idle connection 261293.000000, request 304999.184847 10/13/2025 02:08:17.555 7f6551bf3400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 10/13/2025 02:08:17.555 7f6551bf3400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.555 7f6551bf3400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 681 (604.9928665161133 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=869820175, topics=[]) 10/13/2025 02:08:17.556 7f6551bf3400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 869820175 with 0 response partitions (1 implied) 10/13/2025 02:08:17.556 7f6551bc8a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 10/13/2025 02:08:17.556 7f6551bc8a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.556 7f6551bc8a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 720 (604.8235893249512 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=371133863, topics=[]) 10/13/2025 02:08:17.556 7f6551bc8a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 371133863 with 0 response partitions (1 implied) 10/13/2025 02:08:17.559 7f6550df0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84093.164795, idle connection 261549.000000, request 304398.585558 10/13/2025 02:08:17.559 7f6550df0720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 10/13/2025 02:08:17.559 7f6550df0720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.559 7f6550df0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 689 (601.7138957977295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=289826023, topics=[]) 10/13/2025 02:08:17.559 7f6550df0720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 289826023 with 0 response partitions (1 implied) 10/13/2025 02:08:17.560 7f6551bf3220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83349.224121, idle connection 260688.000000, request 304398.569584 10/13/2025 02:08:17.560 7f6551bf3220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 10/13/2025 02:08:17.560 7f6551bf3220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.560 7f6551bf3220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 681 (601.72438621521 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2079585631, topics=[]) 10/13/2025 02:08:17.560 7f6551bf3220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2079585631 with 0 response partitions (1 implied) 10/13/2025 02:08:17.567 7f6551bf3720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23 10/13/2025 02:08:17.567 7f6551bf3720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 10/13/2025 02:08:17.567 7f6551bf3720 [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)]) 10/13/2025 02:08:17.567 7f6551bf3720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.567 7f6551bf3720 [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=1146838253, session_epoch=683, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.567 7f6551bf3720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1146838253, session_epoch=683, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.567 7f6551bf3720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83955.552490, idle connection 261281.000000, request 304999.960899 10/13/2025 02:08:17.568 7f6551bf3720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83955.225098, idle connection 261281.000000, request 304999.636173 10/13/2025 02:08:17.592 7f6551bf3860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 36 10/13/2025 02:08:17.592 7f6551bf3860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/13/2025 02:08:17.592 7f6551bf3860 [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)]) 10/13/2025 02:08:17.592 7f6551bf3860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.592 7f6551bf3860 [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=1280330098, session_epoch=690, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.592 7f6551bf3860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1280330098, session_epoch=690, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.592 7f6551bf3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83937.154297, idle connection 260918.000000, request 304999.956131 10/13/2025 02:08:17.593 7f6551bf3e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83323.844482, idle connection 261694.000000, request 304397.758484 10/13/2025 02:08:17.593 7f6551bf3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83936.623291, idle connection 260917.000000, request 304999.430180 10/13/2025 02:08:17.593 7f6551bf3e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 10/13/2025 02:08:17.593 7f6551bf3e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.593 7f6551bf3e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 691 (602.9078960418701 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1326168501, topics=[]) 10/13/2025 02:08:17.593 7f6551bf3e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1326168501 with 0 response partitions (1 implied) 10/13/2025 02:08:17.641 7f6551bc8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83050.760742, idle connection 261276.000000, request 304399.020672 10/13/2025 02:08:17.641 7f6551bc8900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 708 10/13/2025 02:08:17.641 7f6551bc8900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.641 7f6551bc8900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 708 (601.463794708252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008357894, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=192, last_stable_offset=192, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xbe\x00\x00\x02\x17\x00\x00\x00\x00\x02\x17W\x14\xd9\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/13/2025 02:08:17.641 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1008357894 with 1 response partitions (0 implied) 10/13/2025 02:08:17.642 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 190 10/13/2025 02:08:17.642 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 190 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 10/13/2025 02:08:17.642 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 192 (leader epoch 0) 10/13/2025 02:08:17.717 7f6551bf3a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84409.822021, idle connection 260534.000000, request 304398.991823 10/13/2025 02:08:17.717 7f6551bf3a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 10/13/2025 02:08:17.717 7f6551bf3a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.717 7f6551bf3a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 688 (601.527214050293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=271319714, topics=[]) 10/13/2025 02:08:17.718 7f6551bf3a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 271319714 with 0 response partitions (1 implied) 10/13/2025 02:08:17.743 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 192 10/13/2025 02:08:17.743 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 10/13/2025 02:08:17.743 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/13/2025 02:08:17.743 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.743 7f6551bc8900 [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=1008357894, session_epoch=705, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=192, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/13/2025 02:08:17.743 7f6551bc8900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 709 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1008357894, session_epoch=705, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=192, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/13/2025 02:08:17.743 7f6551bc8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82948.313721, idle connection 261173.000000, request 304999.946833 10/13/2025 02:08:17.744 7f6551bc8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82947.867676, idle connection 261173.000000, request 304999.508858 10/13/2025 02:08:17.747 7f6551bc8040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 96 10/13/2025 02:08:17.747 7f6551bc8040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 10/13/2025 02:08:17.747 7f6551bc8040 [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)]) 10/13/2025 02:08:17.747 7f6551bc8040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.747 7f6551bc8040 [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=430232459, session_epoch=702, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.747 7f6551bc8040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 706 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=430232459, session_epoch=702, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.748 7f6551bc8040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83089.431641, idle connection 260790.000000, request 304999.962568 10/13/2025 02:08:17.748 7f6551bc8040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83089.126465, idle connection 260790.000000, request 304999.660015 10/13/2025 02:08:17.798 7f6551bf3d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84154.083252, idle connection 261658.000000, request 304397.837400 10/13/2025 02:08:17.799 7f6551bf3d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 10/13/2025 02:08:17.799 7f6551bf3d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.799 7f6551bf3d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 697 (602.8835773468018 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=169083415, topics=[]) 10/13/2025 02:08:17.799 7f6551bf3d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 169083415 with 0 response partitions (1 implied) 10/13/2025 02:08:17.800 7f6550d69860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 30 10/13/2025 02:08:17.800 7f6550d69860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 10/13/2025 02:08:17.800 7f6550d69860 [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)]) 10/13/2025 02:08:17.800 7f6550d69860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.800 7f6550d69860 [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=444494688, session_epoch=688, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.800 7f6550d69860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=444494688, session_epoch=688, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.800 7f6550d69860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83952.354980, idle connection 261542.000000, request 304999.952555 10/13/2025 02:08:17.800 7f6551bc82c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84427.048828, idle connection 261047.000000, request 304396.621704 10/13/2025 02:08:17.801 7f6551bc82c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696 10/13/2025 02:08:17.801 7f6551bc82c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.801 7f6551bc82c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 696 (603.6882400512695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1413607436, topics=[]) 10/13/2025 02:08:17.801 7f6551bc82c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1413607436 with 0 response partitions (1 implied) 10/13/2025 02:08:17.801 7f6550d69860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83951.263428, idle connection 261541.000000, request 304998.865366 10/13/2025 02:08:17.825 7f6550cfb900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 47 10/13/2025 02:08:17.825 7f6550cfb900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/13/2025 02:08:17.825 7f6550cfb900 [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)]) 10/13/2025 02:08:17.825 7f6550cfb900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.826 7f6550cfb900 [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=1961292805, session_epoch=688, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.826 7f6550cfb900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1961292805, session_epoch=688, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.826 7f6550cfb900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83986.315674, idle connection 261425.000000, request 304999.918938 10/13/2025 02:08:17.827 7f6550cfb900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83985.766602, idle connection 261424.000000, request 304999.382019 10/13/2025 02:08:17.862 7f6551bc8f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 321 10/13/2025 02:08:17.862 7f6551bc8f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 10/13/2025 02:08:17.862 7f6551bc8f40 [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)]) 10/13/2025 02:08:17.862 7f6551bc8f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.862 7f6551bc8f40 [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=1698447569, session_epoch=738, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.862 7f6551bc8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 742 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1698447569, session_epoch=738, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.862 7f6551bc8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83773.846436, idle connection 261653.000000, request 304999.941587 10/13/2025 02:08:17.863 7f6551bf32c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 187 10/13/2025 02:08:17.863 7f6551bf32c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 10/13/2025 02:08:17.863 7f6551bf32c0 [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)]) 10/13/2025 02:08:17.863 7f6551bf32c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.863 7f6551bf32c0 [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=577098459, session_epoch=714, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.863 7f6551bf32c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 718 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=577098459, session_epoch=714, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.863 7f6551bf32c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83457.375000, idle connection 260369.000000, request 304999.961615 10/13/2025 02:08:17.863 7f6551bc8d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84271.819336, idle connection 261202.000000, request 304396.678448 10/13/2025 02:08:17.864 7f6551bc8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83772.554199, idle connection 261651.000000, request 304998.661757 10/13/2025 02:08:17.864 7f6551bc8d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 714 10/13/2025 02:08:17.864 7f6551bc8d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.864 7f6551bc8d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 714 (604.0945053100586 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1957646406, topics=[]) 10/13/2025 02:08:17.864 7f6551bc8d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1957646406 with 0 response partitions (1 implied) 10/13/2025 02:08:17.865 7f6551bf32c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83455.933105, idle connection 260368.000000, request 304998.523235 10/13/2025 02:08:17.900 7f6551bc8b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 222 10/13/2025 02:08:17.900 7f6551bc8b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 10/13/2025 02:08:17.900 7f6551bc8b80 [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)]) 10/13/2025 02:08:17.900 7f6551bc8b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.900 7f6551bc8b80 [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=1356551684, session_epoch=706, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.900 7f6551bc8b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 710 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1356551684, session_epoch=706, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.901 7f6551bc8b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84092.455811, idle connection 261075.000000, request 304999.950409 10/13/2025 02:08:17.902 7f6551bc8b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84091.467773, idle connection 261074.000000, request 304998.967648 10/13/2025 02:08:17.923 7f6550d959a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83748.321777, idle connection 261190.000000, request 304399.124146 10/13/2025 02:08:17.923 7f6550d959a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 10/13/2025 02:08:17.923 7f6550d959a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.923 7f6550d959a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 695 (601.4478206634521 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1309062473, topics=[]) 10/13/2025 02:08:17.923 7f6550d959a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1309062473 with 0 response partitions (1 implied) 10/13/2025 02:08:17.926 7f6550d69720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 23 10/13/2025 02:08:17.926 7f6550d69720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 10/13/2025 02:08:17.926 7f6550d69720 [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)]) 10/13/2025 02:08:17.926 7f6550d69720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:17.926 7f6550d69720 [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=1055609205, session_epoch=686, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.926 7f6550d69720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1055609205, session_epoch=686, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:17.926 7f6550d69720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83005.114746, idle connection 261529.000000, request 304999.953508 10/13/2025 02:08:17.926 7f6551bc8860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83455.242432, idle connection 261587.000000, request 304397.940636 10/13/2025 02:08:17.927 7f6550d69720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83004.556641, idle connection 261528.000000, request 304999.400616 10/13/2025 02:08:17.927 7f6551bc8860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 728 10/13/2025 02:08:17.927 7f6551bc8860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.927 7f6551bc8860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 728 (602.7576923370361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2000717013, topics=[]) 10/13/2025 02:08:17.927 7f6551bc8860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2000717013 with 0 response partitions (1 implied) 10/13/2025 02:08:17.927 7f65531e9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83117.388184, idle connection 260895.000000, request 304398.556709 10/13/2025 02:08:17.928 7f65531e9e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1031 10/13/2025 02:08:17.928 7f65531e9e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.928 7f65531e9e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 1031 (601.9961833953857 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1639655434, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3790, last_stable_offset=3790, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xcd\x00\x00\x00\xf9\x00\x00\x00\x00\x02\xe2Gj\x00\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\x8c\x03\x00\x00\x00\xce\x02ObjectConfigNode:cn-jenkins-depl...')])]) 10/13/2025 02:08:17.928 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1639655434 with 1 response partitions (0 implied) 10/13/2025 02:08:17.928 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 261 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3789 10/13/2025 02:08:17.928 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3789 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 10/13/2025 02:08:17.929 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3790 (leader epoch 0) 10/13/2025 02:08:17.957 7f6551bc8400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83891.071289, idle connection 260498.000000, request 304398.508310 10/13/2025 02:08:17.957 7f6551bc8400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 744 10/13/2025 02:08:17.958 7f6551bc8400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.958 7f6551bc8400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 744 (602.3671627044678 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=447812889, topics=[]) 10/13/2025 02:08:17.958 7f6551bc8400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 447812889 with 0 response partitions (1 implied) 10/13/2025 02:08:17.960 7f6551bc8180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82641.616455, idle connection 260571.000000, request 304399.177074 10/13/2025 02:08:17.960 7f6551bc8180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 735 10/13/2025 02:08:17.960 7f6551bc8180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:17.960 7f6551bc8180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 735 (601.3698577880859 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=571205050, topics=[]) 10/13/2025 02:08:17.961 7f6551bc8180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 571205050 with 0 response partitions (1 implied) 10/13/2025 02:08:18.029 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3790 10/13/2025 02:08:18.029 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/13/2025 02:08:18.029 7f65531e9e00 [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)]) 10/13/2025 02:08:18.029 7f65531e9e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.030 7f65531e9e00 [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=1639655434, session_epoch=1028, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3790, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/13/2025 02:08:18.030 7f65531e9e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 1032 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1639655434, session_epoch=1028, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3790, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/13/2025 02:08:18.030 7f65531e9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83014.866699, idle connection 260792.000000, request 304999.933720 10/13/2025 02:08:18.030 7f65531e9e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83014.408447, idle connection 260792.000000, request 304999.484062 10/13/2025 02:08:18.055 7f6551bf3ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83149.615234, idle connection 260359.000000, request 304398.097992 10/13/2025 02:08:18.055 7f6551bf3ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 10/13/2025 02:08:18.055 7f6551bf3ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.056 7f6551bf3ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 688 (602.4339199066162 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1513267518, topics=[]) 10/13/2025 02:08:18.056 7f6551bf3ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1513267518 with 0 response partitions (1 implied) 10/13/2025 02:08:18.056 7f6551bc8720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 179 10/13/2025 02:08:18.057 7f6551bc8720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 10/13/2025 02:08:18.057 7f6551bc8720 [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)]) 10/13/2025 02:08:18.057 7f6551bc8720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.057 7f6551bc8720 [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=483803858, session_epoch=714, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.057 7f6551bc8720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 718 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=483803858, session_epoch=714, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.057 7f6551bc8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83400.935791, idle connection 260903.000000, request 304999.956131 10/13/2025 02:08:18.057 7f6550d95360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83185.891602, idle connection 261397.000000, request 304397.431612 10/13/2025 02:08:18.057 7f6550d1a5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83187.479736, idle connection 260306.000000, request 304397.933006 10/13/2025 02:08:18.058 7f6551bc8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83400.305908, idle connection 260902.000000, request 304999.329567 10/13/2025 02:08:18.058 7f6550d95360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 10/13/2025 02:08:18.058 7f6550d95360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.058 7f6550d95360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 695 (603.3523082733154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1007006786, topics=[]) 10/13/2025 02:08:18.058 7f6550d95360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1007006786 with 0 response partitions (1 implied) 10/13/2025 02:08:18.058 7f6550d1a5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 10/13/2025 02:08:18.058 7f6550d1a5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.058 7f6550d1a5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 684 (603.1785011291504 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1870722021, topics=[]) 10/13/2025 02:08:18.059 7f6550d1a5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1870722021 with 0 response partitions (1 implied) 10/13/2025 02:08:18.146 7f6551bf3040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 10/13/2025 02:08:18.146 7f6551bf3040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 10/13/2025 02:08:18.146 7f6551bf3040 [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)]) 10/13/2025 02:08:18.146 7f6551bf3040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.147 7f6551bf3040 [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=331100681, session_epoch=678, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.147 7f6551bf3040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=331100681, session_epoch=678, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.147 7f6551bf3040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82609.579590, idle connection 260020.000000, request 304999.933958 10/13/2025 02:08:18.147 7f6551bf3040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82609.107178, idle connection 260019.000000, request 304999.469519 10/13/2025 02:08:18.156 7f6551bf3400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/13/2025 02:08:18.156 7f6551bf3400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/13/2025 02:08:18.156 7f6551bf3400 [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)]) 10/13/2025 02:08:18.156 7f6551bf3400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.156 7f6551bf3400 [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=869820175, session_epoch=678, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.156 7f6551bf3400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=869820175, session_epoch=678, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.156 7f6551bf3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82688.060059, idle connection 260055.000000, request 304999.957800 10/13/2025 02:08:18.157 7f6551bc8a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 190 10/13/2025 02:08:18.157 7f6551bc8a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 10/13/2025 02:08:18.157 7f6551bc8a40 [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)]) 10/13/2025 02:08:18.157 7f6551bc8a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.157 7f6551bc8a40 [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=371133863, session_epoch=717, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.157 7f6551bc8a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 721 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=371133863, session_epoch=717, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.157 7f6551bc8a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83678.212646, idle connection 260440.000000, request 304999.961376 10/13/2025 02:08:18.157 7f6550dd0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83359.548096, idle connection 260690.000000, request 304396.910429 10/13/2025 02:08:18.158 7f6551bf3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82686.797607, idle connection 260053.000000, request 304998.699188 10/13/2025 02:08:18.158 7f6550dd0720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 10/13/2025 02:08:18.158 7f6550dd0720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.158 7f6550dd0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (603.7895679473877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1897201992, topics=[]) 10/13/2025 02:08:18.158 7f6550dd0720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1897201992 with 0 response partitions (1 implied) 10/13/2025 02:08:18.159 7f6551bc8a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83676.816162, idle connection 260439.000000, request 304998.568058 10/13/2025 02:08:18.160 7f6550df0720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 40 10/13/2025 02:08:18.160 7f6550df0720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 10/13/2025 02:08:18.160 7f6550df0720 [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)]) 10/13/2025 02:08:18.160 7f6550df0720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.160 7f6550df0720 [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=289826023, session_epoch=686, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.160 7f6550df0720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=289826023, session_epoch=686, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.160 7f6550df0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83491.977295, idle connection 260947.000000, request 304999.961615 10/13/2025 02:08:18.160 7f6551bf3220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 10/13/2025 02:08:18.160 7f6551bf3220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/13/2025 02:08:18.160 7f6551bf3220 [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)]) 10/13/2025 02:08:18.161 7f6551bf3220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.161 7f6551bf3220 [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=2079585631, session_epoch=678, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.161 7f6551bf3220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2079585631, session_epoch=678, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.161 7f6551bf3220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82747.990234, idle connection 260087.000000, request 304999.957085 10/13/2025 02:08:18.161 7f6550df0720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83491.000488, idle connection 260946.000000, request 304998.987675 10/13/2025 02:08:18.161 7f6551bf3220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82747.405518, idle connection 260086.000000, request 304999.376059 10/13/2025 02:08:18.168 7f6551bf3720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83354.924805, idle connection 260680.000000, request 304399.332762 10/13/2025 02:08:18.168 7f6551bf3720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 10/13/2025 02:08:18.168 7f6551bf3720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.169 7f6551bf3720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 687 (601.0539531707764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1146838253, topics=[]) 10/13/2025 02:08:18.169 7f6551bf3720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1146838253 with 0 response partitions (1 implied) 10/13/2025 02:08:18.194 7f6551bf3e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 27 10/13/2025 02:08:18.194 7f6551bf3e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/13/2025 02:08:18.194 7f6551bf3e00 [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)]) 10/13/2025 02:08:18.194 7f6551bf3e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.194 7f6551bf3e00 [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=1326168501, session_epoch=688, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.194 7f6551bf3e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1326168501, session_epoch=688, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.194 7f6551bf3e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82722.208740, idle connection 261092.000000, request 304999.955654 10/13/2025 02:08:18.194 7f6551bf3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83335.072998, idle connection 260316.000000, request 304397.877455 10/13/2025 02:08:18.195 7f6551bf3e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82721.663086, idle connection 261091.000000, request 304999.414921 10/13/2025 02:08:18.195 7f6551bf3860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 10/13/2025 02:08:18.195 7f6551bf3860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.195 7f6551bf3860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 694 (602.8275489807129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1280330098, topics=[]) 10/13/2025 02:08:18.195 7f6551bf3860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1280330098 with 0 response partitions (1 implied) 10/13/2025 02:08:18.318 7f6551bf3a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 17 10/13/2025 02:08:18.318 7f6551bf3a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/13/2025 02:08:18.318 7f6551bf3a40 [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)]) 10/13/2025 02:08:18.319 7f6551bf3a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.319 7f6551bf3a40 [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=271319714, session_epoch=685, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.319 7f6551bf3a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=271319714, session_epoch=685, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.319 7f6551bf3a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83807.651855, idle connection 259932.000000, request 304999.917507 10/13/2025 02:08:18.320 7f6551bf3a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83807.021973, idle connection 259931.000000, request 304999.303579 10/13/2025 02:08:18.344 7f6551bc8900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82347.309570, idle connection 260572.000000, request 304398.940563 10/13/2025 02:08:18.345 7f6551bc8900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 709 10/13/2025 02:08:18.345 7f6551bc8900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.345 7f6551bc8900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 709 (601.6736030578613 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008357894, topics=[]) 10/13/2025 02:08:18.345 7f6551bc8900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1008357894 with 0 response partitions (1 implied) 10/13/2025 02:08:18.348 7f6551bc8040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82488.797119, idle connection 260189.000000, request 304399.324894 10/13/2025 02:08:18.348 7f6551bc8040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 706 10/13/2025 02:08:18.348 7f6551bc8040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.349 7f6551bc8040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 706 (601.0360717773438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=430232459, topics=[]) 10/13/2025 02:08:18.349 7f6551bc8040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 430232459 with 0 response partitions (1 implied) 10/13/2025 02:08:18.401 7f6551bf3d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 78 10/13/2025 02:08:18.401 7f6551bf3d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/13/2025 02:08:18.401 7f6551bf3d60 [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)]) 10/13/2025 02:08:18.401 7f6551bf3d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.401 7f6551bf3d60 [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=169083415, session_epoch=694, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.402 7f6551bf3d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 698 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=169083415, session_epoch=694, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.402 7f6551bf3d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83550.727295, idle connection 261055.000000, request 304999.927759 10/13/2025 02:08:18.402 7f6551bc82c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 112 10/13/2025 02:08:18.402 7f6551bc82c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 10/13/2025 02:08:18.402 7f6551bc82c0 [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)]) 10/13/2025 02:08:18.402 7f6551bc82c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.402 7f6551bc82c0 [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=1413607436, session_epoch=693, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.402 7f6551bc82c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 697 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1413607436, session_epoch=693, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.402 7f6551bc82c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83824.966553, idle connection 260445.000000, request 304999.963284 10/13/2025 02:08:18.403 7f6550d69860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83349.888916, idle connection 260940.000000, request 304397.489548 10/13/2025 02:08:18.403 7f6551bf3d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83549.471191, idle connection 261054.000000, request 304998.684168 10/13/2025 02:08:18.403 7f6550d69860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 10/13/2025 02:08:18.403 7f6550d69860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.403 7f6550d69860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 692 (603.3039093017578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=444494688, topics=[]) 10/13/2025 02:08:18.404 7f6550d69860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 444494688 with 0 response partitions (1 implied) 10/13/2025 02:08:18.404 7f6551bc82c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83823.486572, idle connection 260443.000000, request 304998.486280 10/13/2025 02:08:18.428 7f6550cfb900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83384.503174, idle connection 260823.000000, request 304398.111105 10/13/2025 02:08:18.428 7f6550cfb900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 10/13/2025 02:08:18.428 7f6550cfb900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.428 7f6550cfb900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 692 (602.4672985076904 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1961292805, topics=[]) 10/13/2025 02:08:18.429 7f6550cfb900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1961292805 with 0 response partitions (1 implied) 10/13/2025 02:08:18.465 7f6551bc8d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 125 10/13/2025 02:08:18.465 7f6551bc8d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 10/13/2025 02:08:18.465 7f6551bc8d60 [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)]) 10/13/2025 02:08:18.465 7f6551bc8d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.465 7f6551bc8d60 [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=1957646406, session_epoch=711, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.465 7f6551bc8d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 715 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1957646406, session_epoch=711, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.465 7f6551bc8d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83669.770264, idle connection 260599.000000, request 304999.943733 10/13/2025 02:08:18.466 7f6551bc8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83170.611572, idle connection 261049.000000, request 304396.717787 10/13/2025 02:08:18.466 7f6551bf32c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82854.733887, idle connection 259767.000000, request 304397.323608 10/13/2025 02:08:18.466 7f6551bc8d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83669.025391, idle connection 260599.000000, request 304999.207735 10/13/2025 02:08:18.466 7f6551bc8f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742 10/13/2025 02:08:18.466 7f6551bc8f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.467 7f6551bc8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 742 (604.1855812072754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1698447569, topics=[]) 10/13/2025 02:08:18.467 7f6551bc8f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1698447569 with 0 response partitions (1 implied) 10/13/2025 02:08:18.467 7f6551bf32c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 718 10/13/2025 02:08:18.467 7f6551bf32c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.467 7f6551bf32c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 718 (603.94287109375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=577098459, topics=[]) 10/13/2025 02:08:18.467 7f6551bf32c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 577098459 with 0 response partitions (1 implied) 10/13/2025 02:08:18.502 7f6551bc8b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83490.599121, idle connection 260473.000000, request 304398.089409 10/13/2025 02:08:18.503 7f6551bc8b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 10/13/2025 02:08:18.503 7f6551bc8b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.503 7f6551bc8b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 710 (602.5264263153076 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1356551684, topics=[]) 10/13/2025 02:08:18.503 7f6551bc8b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1356551684 with 0 response partitions (1 implied) 10/13/2025 02:08:18.524 7f6550d959a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 52 10/13/2025 02:08:18.524 7f6550d959a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/13/2025 02:08:18.524 7f6550d959a0 [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)]) 10/13/2025 02:08:18.524 7f6550d959a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.524 7f6550d959a0 [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=1309062473, session_epoch=692, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.524 7f6550d959a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 696 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1309062473, session_epoch=692, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.524 7f6550d959a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83146.383789, idle connection 260588.000000, request 304999.940634 10/13/2025 02:08:18.525 7f6550d959a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83145.928223, idle connection 260587.000000, request 304999.489546 10/13/2025 02:08:18.527 7f6551bc8860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 248 10/13/2025 02:08:18.528 7f6551bc8860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 10/13/2025 02:08:18.528 7f6551bc8860 [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)]) 10/13/2025 02:08:18.528 7f6551bc8860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/13/2025 02:08:18.528 7f6551bc8860 [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=2000717013, session_epoch=725, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.528 7f6551bc8860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 729 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2000717013, session_epoch=725, topics=[], forgotten_topics_data=[]) 10/13/2025 02:08:18.528 7f6551bc8860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82853.571045, idle connection 260985.000000, request 304999.956131 10/13/2025 02:08:18.528 7f6550d69720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82402.996826, idle connection 260927.000000, request 304397.835016 10/13/2025 02:08:18.529 7f6551bc8860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82852.963379, idle connection 260984.000000, request 304999.348164 10/13/2025 02:08:18.529 7f6550d69720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 10/13/2025 02:08:18.529 7f6550d69720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/13/2025 02:08:18.529 7f6550d69720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (602.9503345489502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1055609205, topics=[]) 10/13/2025 02:08:18.529 7f6550d69720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1055609205 with 0 response partitions (1 implied)