09/22/2025 02:19:09.718 7f1a20f805e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=142612340, session_epoch=677, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.720 7f1a20f805e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83921.315186, idle connection 262517.000000, request 304999.955893 09/22/2025 02:19:09.720 7f1a20f80040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83919.660645, idle connection 262515.000000, request 304997.506618 09/22/2025 02:19:09.721 7f1a20f805e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83920.711670, idle connection 262517.000000, request 304999.357700 09/22/2025 02:19:09.741 7f1a20f80a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84538.896729, idle connection 261992.000000, request 304398.929119 09/22/2025 02:19:09.741 7f1a20f80a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696 09/22/2025 02:19:09.741 7f1a20f80a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:09.741 7f1a20f80a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 696 (601.517915725708 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2088538190, topics=[]) 09/22/2025 02:19:09.741 7f1a20f80a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2088538190 with 0 response partitions (1 implied) 09/22/2025 02:19:09.742 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 09/22/2025 02:19:09.742 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 09/22/2025 02:19:09.742 7f1a20f80400 [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)]) 09/22/2025 02:19:09.742 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.742 7f1a20f80400 [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=1817142821, session_epoch=677, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.742 7f1a20f80400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817142821, session_epoch=677, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.742 7f1a20f80400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83900.722412, idle connection 262496.000000, request 304999.957800 09/22/2025 02:19:09.743 7f1a20f80400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83900.300781, idle connection 262495.000000, request 304999.537706 09/22/2025 02:19:09.744 7f1a20f80cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84495.006104, idle connection 261899.000000, request 304398.995399 09/22/2025 02:19:09.744 7f1a20f80cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 09/22/2025 02:19:09.745 7f1a20f80cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:09.745 7f1a20f80cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 690 (601.3391017913818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2134678589, topics=[]) 09/22/2025 02:19:09.745 7f1a20f80cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2134678589 with 0 response partitions (1 implied) 09/22/2025 02:19:09.756 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 4 09/22/2025 02:19:09.756 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 09/22/2025 02:19:09.756 7f1a20121720 [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)]) 09/22/2025 02:19:09.756 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.756 7f1a20121720 [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=1340179034, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.756 7f1a20121720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1340179034, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.756 7f1a20121720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83902.984863, idle connection 262489.000000, request 304999.943972 09/22/2025 02:19:09.757 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 39 09/22/2025 02:19:09.757 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 09/22/2025 02:19:09.757 7f1a200b2ae0 [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)]) 09/22/2025 02:19:09.757 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.757 7f1a200b2ae0 [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=175045585, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.757 7f1a200b2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=175045585, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.757 7f1a200b2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85106.949707, idle connection 262484.000000, request 304999.962807 09/22/2025 02:19:09.757 7f1a20121720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83901.951660, idle connection 262488.000000, request 304998.920441 09/22/2025 02:19:09.758 7f1a200b2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85106.349609, idle connection 262483.000000, request 304999.366760 09/22/2025 02:19:09.770 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 26 09/22/2025 02:19:09.770 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 09/22/2025 02:19:09.770 7f1a2014d4a0 [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)]) 09/22/2025 02:19:09.770 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.770 7f1a2014d4a0 [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=835120645, session_epoch=682, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.770 7f1a2014d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=835120645, session_epoch=682, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.770 7f1a2014d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85095.143555, idle connection 262203.000000, request 304999.956846 09/22/2025 02:19:09.771 7f1a2014d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85094.805908, idle connection 262202.000000, request 304999.623299 09/22/2025 02:19:09.798 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 65 09/22/2025 02:19:09.798 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 09/22/2025 02:19:09.798 7f1a2014dae0 [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)]) 09/22/2025 02:19:09.798 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.798 7f1a2014dae0 [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=277818289, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.799 7f1a2014dae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277818289, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.799 7f1a2014dae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85417.402100, idle connection 262537.000000, request 304999.953032 09/22/2025 02:19:09.799 7f1a2014dae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85417.033691, idle connection 262536.000000, request 304999.589443 09/22/2025 02:19:09.808 7f1a20ecc180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85331.698975, idle connection 261898.000000, request 304399.229288 09/22/2025 02:19:09.808 7f1a20ecc180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 728 09/22/2025 02:19:09.808 7f1a20ecc180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:09.808 7f1a20ecc180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 728 (601.1929512023926 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1638271374, topics=[]) 09/22/2025 02:19:09.808 7f1a20ecc180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1638271374 with 0 response partitions (1 implied) 09/22/2025 02:19:09.809 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 309 09/22/2025 02:19:09.809 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 09/22/2025 02:19:09.809 7f1a20eccea0 [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)]) 09/22/2025 02:19:09.809 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.809 7f1a20eccea0 [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=272584755, session_epoch=727, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.809 7f1a20eccea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 731 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=272584755, session_epoch=727, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.809 7f1a20eccea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84431.407227, idle connection 262007.000000, request 304999.958754 09/22/2025 02:19:09.810 7f1a20eccea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84431.089111, idle connection 262007.000000, request 304999.644279 09/22/2025 02:19:09.844 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3786 09/22/2025 02:19:09.844 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 09/22/2025 02:19:09.844 7f1a225a1e00 [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)]) 09/22/2025 02:19:09.845 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.845 7f1a225a1e00 [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=1569562401, session_epoch=1008, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.845 7f1a225a1e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 1012 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569562401, session_epoch=1008, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.845 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84464.373291, idle connection 262207.000000, request 304999.936104 09/22/2025 02:19:09.845 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84463.874023, idle connection 262206.000000, request 304999.444008 09/22/2025 02:19:09.864 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 46 09/22/2025 02:19:09.864 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 09/22/2025 02:19:09.864 7f1a20f80ea0 [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)]) 09/22/2025 02:19:09.864 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.864 7f1a20f80ea0 [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=1770253246, session_epoch=688, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.864 7f1a20f80ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1770253246, session_epoch=688, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.864 7f1a20f80ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85023.969238, idle connection 262042.000000, request 304999.950886 09/22/2025 02:19:09.865 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 110 09/22/2025 02:19:09.865 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 09/22/2025 02:19:09.865 7f1a20ecc7c0 [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)]) 09/22/2025 02:19:09.865 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.865 7f1a20ecc7c0 [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=535025570, session_epoch=700, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.865 7f1a20ecc7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 704 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=535025570, session_epoch=700, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.865 7f1a20ecc7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84467.605713, idle connection 262894.000000, request 304999.965191 09/22/2025 02:19:09.865 7f1a20ecc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84695.331299, idle connection 262280.000000, request 304396.978378 09/22/2025 02:19:09.865 7f1a20f80ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85022.838135, idle connection 262041.000000, request 304998.826027 09/22/2025 02:19:09.866 7f1a20ecc2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 709 09/22/2025 02:19:09.866 7f1a20ecc2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:09.866 7f1a20ecc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 709 (603.7089824676514 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262067599, topics=[]) 09/22/2025 02:19:09.866 7f1a20ecc2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1262067599 with 0 response partitions (1 implied) 09/22/2025 02:19:09.866 7f1a20ecc7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84466.215088, idle connection 262892.000000, request 304998.575687 09/22/2025 02:19:09.869 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 181 09/22/2025 02:19:09.870 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 02:19:09.870 7f1a20f80f40 [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)]) 09/22/2025 02:19:09.870 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.870 7f1a20f80f40 [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=1205049933, session_epoch=712, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.870 7f1a20f80f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 716 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1205049933, session_epoch=712, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.870 7f1a20f80f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84882.890625, idle connection 262497.000000, request 304999.961615 09/22/2025 02:19:09.870 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 350 09/22/2025 02:19:09.870 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 02:19:09.870 7f1a20ecc400 [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)]) 09/22/2025 02:19:09.870 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.870 7f1a20ecc400 [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=2083347924, session_epoch=749, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.871 7f1a20ecc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2083347924, session_epoch=749, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.871 7f1a20ecc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85092.513916, idle connection 262779.000000, request 304999.953985 09/22/2025 02:19:09.871 7f1a20f80f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84881.964355, idle connection 262496.000000, request 304999.039173 09/22/2025 02:19:09.871 7f1a20ecc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85091.884277, idle connection 262779.000000, request 304999.330997 09/22/2025 02:19:09.957 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 40 09/22/2025 02:19:09.958 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 02:19:09.958 7f1a20ecc040 [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)]) 09/22/2025 02:19:09.958 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:09.958 7f1a20ecc040 [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=1445378303, session_epoch=685, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.958 7f1a20ecc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1445378303, session_epoch=685, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:09.958 7f1a20ecc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85256.080566, idle connection 262054.000000, request 304999.932289 09/22/2025 02:19:09.959 7f1a20ecc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85255.630859, idle connection 262054.000000, request 304999.491215 09/22/2025 02:19:09.960 7f1a20f807c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84598.709473, idle connection 262192.000000, request 304399.252415 09/22/2025 02:19:09.961 7f1a20f807c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 09/22/2025 02:19:09.961 7f1a20f807c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:09.961 7f1a20f807c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 695 (601.13525390625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=738521822, topics=[]) 09/22/2025 02:19:09.961 7f1a20f807c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 738521822 with 0 response partitions (1 implied) 09/22/2025 02:19:10.043 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 9 09/22/2025 02:19:10.043 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/22/2025 02:19:10.043 7f1a20121860 [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)]) 09/22/2025 02:19:10.043 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.043 7f1a20121860 [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=1778873578, session_epoch=680, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.043 7f1a20121860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1778873578, session_epoch=680, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.043 7f1a20121860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83965.906982, idle connection 261684.000000, request 304999.949217 09/22/2025 02:19:10.044 7f1a20121860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83965.498535, idle connection 261684.000000, request 304999.548197 09/22/2025 02:19:10.044 7f1a20f80180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83994.822021, idle connection 261237.000000, request 304398.998737 09/22/2025 02:19:10.044 7f1a20f80180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 09/22/2025 02:19:10.044 7f1a20f80180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.044 7f1a20f80180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 686 (601.431131362915 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1220227894, topics=[]) 09/22/2025 02:19:10.045 7f1a20f80180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1220227894 with 0 response partitions (1 implied) 09/22/2025 02:19:10.062 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 266 09/22/2025 02:19:10.062 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 09/22/2025 02:19:10.062 7f1a20eccb80 [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)]) 09/22/2025 02:19:10.062 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.062 7f1a20eccb80 [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=622222272, session_epoch=723, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.062 7f1a20eccb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 727 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=622222272, session_epoch=723, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.062 7f1a20eccb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83575.979004, idle connection 261998.000000, request 304999.950886 09/22/2025 02:19:10.062 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 254 09/22/2025 02:19:10.062 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 02:19:10.063 7f1a20ecc860 [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)]) 09/22/2025 02:19:10.063 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.063 7f1a20ecc860 [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=1217506319, session_epoch=720, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.063 7f1a20ecc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217506319, session_epoch=720, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.063 7f1a20ecc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83994.125000, idle connection 262022.000000, request 304999.965906 09/22/2025 02:19:10.063 7f1a20eccb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83574.991211, idle connection 261997.000000, request 304998.970509 09/22/2025 02:19:10.064 7f1a20ecc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83993.496094, idle connection 262022.000000, request 304999.339104 09/22/2025 02:19:10.087 7f1a20f80680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84236.976074, idle connection 261646.000000, request 304399.099588 09/22/2025 02:19:10.087 7f1a20f80680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 09/22/2025 02:19:10.087 7f1a20f80680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.087 7f1a20f80680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 690 (601.3617515563965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145885723, topics=[]) 09/22/2025 02:19:10.087 7f1a20f80680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 145885723 with 0 response partitions (1 implied) 09/22/2025 02:19:10.142 7f1a201a8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83723.236084, idle connection 261932.000000, request 304399.078131 09/22/2025 02:19:10.142 7f1a201a8720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 702 09/22/2025 02:19:10.142 7f1a201a8720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.142 7f1a201a8720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 702 (601.4254093170166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=782393377, topics=[]) 09/22/2025 02:19:10.142 7f1a201a8720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 782393377 with 0 response partitions (1 implied) 09/22/2025 02:19:10.161 7f1a20ecc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84582.408447, idle connection 261483.000000, request 304399.168253 09/22/2025 02:19:10.162 7f1a20ecc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721 09/22/2025 02:19:10.162 7f1a20ecc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.162 7f1a20ecc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 721 (601.2706756591797 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=48035887, topics=[]) 09/22/2025 02:19:10.162 7f1a20ecc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 48035887 with 0 response partitions (1 implied) 09/22/2025 02:19:10.242 7f1a20ecc540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 280 09/22/2025 02:19:10.242 7f1a20ecc540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 09/22/2025 02:19:10.242 7f1a20ecc540 [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)]) 09/22/2025 02:19:10.242 7f1a20ecc540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.242 7f1a20ecc540 [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=1256477054, session_epoch=716, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.242 7f1a20ecc540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 720 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1256477054, session_epoch=716, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.242 7f1a20ecc540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84693.675293, idle connection 262266.000000, request 304999.944448 09/22/2025 02:19:10.243 7f1a20ecc540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84693.120605, idle connection 262266.000000, request 304999.397278 09/22/2025 02:19:10.261 7f1a20f80360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 193 09/22/2025 02:19:10.261 7f1a20f80360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/22/2025 02:19:10.262 7f1a20f80360 [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)]) 09/22/2025 02:19:10.262 7f1a20f80360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.262 7f1a20f80360 [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=2100418175, session_epoch=720, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.262 7f1a20f80360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2100418175, session_epoch=720, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.262 7f1a20f80360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83372.841797, idle connection 261600.000000, request 304999.929428 09/22/2025 02:19:10.263 7f1a20f80360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83372.221924, idle connection 261599.000000, request 304999.317646 09/22/2025 02:19:10.306 7f1a201219a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 24 09/22/2025 02:19:10.307 7f1a201219a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 02:19:10.307 7f1a201219a0 [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)]) 09/22/2025 02:19:10.307 7f1a201219a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.307 7f1a201219a0 [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=1596385324, session_epoch=685, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.307 7f1a201219a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1596385324, session_epoch=685, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.307 7f1a201219a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84565.292725, idle connection 261802.000000, request 304999.946117 09/22/2025 02:19:10.307 7f1a200d15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 36 09/22/2025 02:19:10.307 7f1a200d15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 09/22/2025 02:19:10.307 7f1a200d15e0 [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)]) 09/22/2025 02:19:10.308 7f1a200d15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.308 7f1a200d15e0 [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=31953068, session_epoch=691, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.308 7f1a200d15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=31953068, session_epoch=691, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.308 7f1a200d15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84531.643066, idle connection 261927.000000, request 304999.965668 09/22/2025 02:19:10.308 7f1a201219a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84564.232666, idle connection 261801.000000, request 304998.895168 09/22/2025 02:19:10.309 7f1a200d15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84530.979248, idle connection 261926.000000, request 304999.305248 09/22/2025 02:19:10.321 7f1a20f80040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83319.054932, idle connection 261914.000000, request 304396.899223 09/22/2025 02:19:10.321 7f1a20f80040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 09/22/2025 02:19:10.321 7f1a20f80040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.321 7f1a20f80040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 681 (603.4910678863525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563451795, topics=[]) 09/22/2025 02:19:10.322 7f1a20f80040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1563451795 with 0 response partitions (1 implied) 09/22/2025 02:19:10.322 7f1a20f805e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83319.652588, idle connection 261916.000000, request 304398.297071 09/22/2025 02:19:10.322 7f1a20f805e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 09/22/2025 02:19:10.322 7f1a20f805e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.322 7f1a20f805e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 681 (601.9957065582275 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=142612340, topics=[]) 09/22/2025 02:19:10.322 7f1a20f805e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 142612340 with 0 response partitions (1 implied) 09/22/2025 02:19:10.342 7f1a20f80a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 73 09/22/2025 02:19:10.342 7f1a20f80a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 09/22/2025 02:19:10.342 7f1a20f80a40 [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)]) 09/22/2025 02:19:10.342 7f1a20f80a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.342 7f1a20f80a40 [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=2088538190, session_epoch=693, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.342 7f1a20f80a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=2088538190, session_epoch=693, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.342 7f1a20f80a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83937.443115, idle connection 261390.000000, request 304999.953270 09/22/2025 02:19:10.343 7f1a20f80a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83937.047852, idle connection 261390.000000, request 304999.562502 09/22/2025 02:19:10.343 7f1a20f80400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83299.998535, idle connection 261895.000000, request 304399.236917 09/22/2025 02:19:10.343 7f1a20f80400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 09/22/2025 02:19:10.343 7f1a20f80400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.343 7f1a20f80400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 681 (601.0828018188477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817142821, topics=[]) 09/22/2025 02:19:10.343 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1817142821 with 0 response partitions (1 implied) 09/22/2025 02:19:10.345 7f1a20f80cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 53 09/22/2025 02:19:10.345 7f1a20f80cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 09/22/2025 02:19:10.345 7f1a20f80cc0 [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)]) 09/22/2025 02:19:10.345 7f1a20f80cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.345 7f1a20f80cc0 [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=2134678589, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.346 7f1a20f80cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2134678589, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.346 7f1a20f80cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83893.565186, idle connection 261298.000000, request 304999.964714 09/22/2025 02:19:10.346 7f1a20f80cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83893.267822, idle connection 261297.000000, request 304999.669552 09/22/2025 02:19:10.358 7f1a20121720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83301.379883, idle connection 261888.000000, request 304398.347855 09/22/2025 02:19:10.358 7f1a20121720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 09/22/2025 02:19:10.358 7f1a20121720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.358 7f1a20121720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 682 (601.9949913024902 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1340179034, topics=[]) 09/22/2025 02:19:10.358 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1340179034 with 0 response partitions (1 implied) 09/22/2025 02:19:10.359 7f1a200b2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84505.393066, idle connection 261882.000000, request 304398.408890 09/22/2025 02:19:10.359 7f1a200b2ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 09/22/2025 02:19:10.359 7f1a200b2ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.359 7f1a200b2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 691 (601.8962860107422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=175045585, topics=[]) 09/22/2025 02:19:10.359 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 175045585 with 0 response partitions (1 implied) 09/22/2025 02:19:10.371 7f1a2014d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84494.193604, idle connection 261602.000000, request 304399.005175 09/22/2025 02:19:10.371 7f1a2014d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 09/22/2025 02:19:10.372 7f1a2014d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.372 7f1a2014d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 686 (601.3545989990234 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=835120645, topics=[]) 09/22/2025 02:19:10.372 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 835120645 with 0 response partitions (1 implied) 09/22/2025 02:19:10.399 7f1a2014dae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84816.663086, idle connection 261936.000000, request 304399.214745 09/22/2025 02:19:10.400 7f1a2014dae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 09/22/2025 02:19:10.400 7f1a2014dae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.400 7f1a2014dae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 691 (601.1548042297363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=277818289, topics=[]) 09/22/2025 02:19:10.400 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 277818289 with 0 response partitions (1 implied) 09/22/2025 02:19:10.409 7f1a20ecc180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 218 09/22/2025 02:19:10.409 7f1a20ecc180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 09/22/2025 02:19:10.409 7f1a20ecc180 [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)]) 09/22/2025 02:19:10.409 7f1a20ecc180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.409 7f1a20ecc180 [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=1638271374, session_epoch=725, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.409 7f1a20ecc180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1638271374, session_epoch=725, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.409 7f1a20ecc180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84730.359863, idle connection 261297.000000, request 304999.956131 09/22/2025 02:19:10.410 7f1a20ecc180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84729.873535, idle connection 261296.000000, request 304999.472857 09/22/2025 02:19:10.410 7f1a20eccea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83830.704346, idle connection 261407.000000, request 304399.248600 09/22/2025 02:19:10.410 7f1a20eccea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 731 09/22/2025 02:19:10.410 7f1a20eccea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.410 7f1a20eccea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 731 (601.1676788330078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=272584755, topics=[]) 09/22/2025 02:19:10.410 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 272584755 with 0 response partitions (1 implied) 09/22/2025 02:19:10.446 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83863.455322, idle connection 261606.000000, request 304399.018764 09/22/2025 02:19:10.446 7f1a225a1e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1012 09/22/2025 02:19:10.446 7f1a225a1e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.446 7f1a225a1e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 1012 (601.433515548706 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1569562401, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3787, last_stable_offset=3787, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xca\x00\x00\x01\x04\x00\x00\x00\x00\x02\xf6\xeb\x8a\xd7\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 09/22/2025 02:19:10.447 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1569562401 with 1 response partitions (0 implied) 09/22/2025 02:19:10.447 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3786 09/22/2025 02:19:10.447 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3786 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 09/22/2025 02:19:10.447 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3787 (leader epoch 0) 09/22/2025 02:19:10.466 7f1a20ecc2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 134 09/22/2025 02:19:10.466 7f1a20ecc2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 09/22/2025 02:19:10.466 7f1a20ecc2c0 [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)]) 09/22/2025 02:19:10.467 7f1a20ecc2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.467 7f1a20ecc2c0 [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=1262067599, session_epoch=706, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.467 7f1a20ecc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1262067599, session_epoch=706, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.467 7f1a20ecc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84093.596191, idle connection 261678.000000, request 304999.950409 09/22/2025 02:19:10.467 7f1a20f80ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84421.171387, idle connection 261439.000000, request 304397.157431 09/22/2025 02:19:10.467 7f1a20ecc7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83865.336426, idle connection 262291.000000, request 304397.698164 09/22/2025 02:19:10.468 7f1a20ecc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84092.929199, idle connection 261677.000000, request 304999.290943 09/22/2025 02:19:10.468 7f1a20f80ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 09/22/2025 02:19:10.468 7f1a20f80ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.468 7f1a20f80ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 692 (603.6276817321777 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1770253246, topics=[]) 09/22/2025 02:19:10.468 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1770253246 with 0 response partitions (1 implied) 09/22/2025 02:19:10.468 7f1a20ecc7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 704 09/22/2025 02:19:10.468 7f1a20ecc7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.468 7f1a20ecc7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 704 (603.4281253814697 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=535025570, topics=[]) 09/22/2025 02:19:10.469 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 535025570 with 0 response partitions (1 implied) 09/22/2025 02:19:10.472 7f1a20f80f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84281.375488, idle connection 261895.000000, request 304398.447990 09/22/2025 02:19:10.472 7f1a20f80f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 716 09/22/2025 02:19:10.472 7f1a20f80f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.472 7f1a20f80f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 716 (601.8438339233398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1205049933, topics=[]) 09/22/2025 02:19:10.472 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1205049933 with 0 response partitions (1 implied) 09/22/2025 02:19:10.472 7f1a20ecc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84491.041016, idle connection 262178.000000, request 304398.487329 09/22/2025 02:19:10.472 7f1a20ecc400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 753 09/22/2025 02:19:10.472 7f1a20ecc400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.473 7f1a20ecc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 753 (601.834774017334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2083347924, topics=[]) 09/22/2025 02:19:10.473 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2083347924 with 0 response partitions (1 implied) 09/22/2025 02:19:10.547 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3787 09/22/2025 02:19:10.548 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 09/22/2025 02:19:10.548 7f1a225a1e00 [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)]) 09/22/2025 02:19:10.548 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.548 7f1a225a1e00 [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=1569562401, session_epoch=1009, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3787, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 02:19:10.548 7f1a225a1e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 1013 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569562401, session_epoch=1009, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3787, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 02:19:10.548 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83761.201172, idle connection 261504.000000, request 304999.946833 09/22/2025 02:19:10.549 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83760.791260, idle connection 261503.000000, request 304999.545574 09/22/2025 02:19:10.559 7f1a20ecc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84655.214355, idle connection 261453.000000, request 304399.072886 09/22/2025 02:19:10.559 7f1a20ecc040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 09/22/2025 02:19:10.559 7f1a20ecc040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.559 7f1a20ecc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 689 (601.3329029083252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1445378303, topics=[]) 09/22/2025 02:19:10.560 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1445378303 with 0 response partitions (1 implied) 09/22/2025 02:19:10.561 7f1a20f807c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 45 09/22/2025 02:19:10.561 7f1a20f807c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 09/22/2025 02:19:10.561 7f1a20f807c0 [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)]) 09/22/2025 02:19:10.561 7f1a20f807c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.561 7f1a20f807c0 [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=738521822, session_epoch=692, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.562 7f1a20f807c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=738521822, session_epoch=692, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.562 7f1a20f807c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83997.436035, idle connection 261591.000000, request 304999.961376 09/22/2025 02:19:10.562 7f1a20f807c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83997.111572, idle connection 261590.000000, request 304999.638796 09/22/2025 02:19:10.644 7f1a20121860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83364.895996, idle connection 261083.000000, request 304398.942709 09/22/2025 02:19:10.645 7f1a20121860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 09/22/2025 02:19:10.645 7f1a20121860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.645 7f1a20121860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 684 (601.5355587005615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1778873578, topics=[]) 09/22/2025 02:19:10.645 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1778873578 with 0 response partitions (1 implied) 09/22/2025 02:19:10.645 7f1a20f80180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 15 09/22/2025 02:19:10.645 7f1a20f80180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 09/22/2025 02:19:10.645 7f1a20f80180 [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)]) 09/22/2025 02:19:10.645 7f1a20f80180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.645 7f1a20f80180 [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=1220227894, session_epoch=683, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.645 7f1a20f80180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1220227894, session_epoch=683, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.646 7f1a20f80180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83393.138428, idle connection 260636.000000, request 304999.961138 09/22/2025 02:19:10.646 7f1a20f80180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83392.782715, idle connection 260635.000000, request 304999.607325 09/22/2025 02:19:10.664 7f1a20eccb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82974.382812, idle connection 261396.000000, request 304398.357630 09/22/2025 02:19:10.664 7f1a20eccb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 727 09/22/2025 02:19:10.664 7f1a20eccb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.664 7f1a20eccb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 727 (602.0486354827881 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=622222272, topics=[]) 09/22/2025 02:19:10.664 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 622222272 with 0 response partitions (1 implied) 09/22/2025 02:19:10.665 7f1a20ecc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83392.449463, idle connection 261421.000000, request 304398.290634 09/22/2025 02:19:10.665 7f1a20ecc860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 724 09/22/2025 02:19:10.665 7f1a20ecc860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.665 7f1a20ecc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 724 (602.0030975341797 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217506319, topics=[]) 09/22/2025 02:19:10.665 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217506319 with 0 response partitions (1 implied) 09/22/2025 02:19:10.688 7f1a20f80680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 34 09/22/2025 02:19:10.688 7f1a20f80680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 09/22/2025 02:19:10.689 7f1a20f80680 [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)]) 09/22/2025 02:19:10.689 7f1a20f80680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.689 7f1a20f80680 [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=145885723, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.689 7f1a20f80680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145885723, session_epoch=687, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.689 7f1a20f80680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83634.794189, idle connection 261044.000000, request 304999.947786 09/22/2025 02:19:10.689 7f1a20f80680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83634.354492, idle connection 261044.000000, request 304999.517202 09/22/2025 02:19:10.743 7f1a201a8720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 83 09/22/2025 02:19:10.743 7f1a201a8720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/22/2025 02:19:10.743 7f1a201a8720 [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)]) 09/22/2025 02:19:10.743 7f1a201a8720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.743 7f1a201a8720 [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=782393377, session_epoch=699, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.744 7f1a201a8720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 703 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=782393377, session_epoch=699, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.744 7f1a201a8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83121.114746, idle connection 261330.000000, request 304999.948025 09/22/2025 02:19:10.744 7f1a201a8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83120.685547, idle connection 261329.000000, request 304999.526978 09/22/2025 02:19:10.763 7f1a20ecc9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 187 09/22/2025 02:19:10.763 7f1a20ecc9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 09/22/2025 02:19:10.763 7f1a20ecc9a0 [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)]) 09/22/2025 02:19:10.763 7f1a20ecc9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.763 7f1a20ecc9a0 [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=48035887, session_epoch=718, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.763 7f1a20ecc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=48035887, session_epoch=718, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.763 7f1a20ecc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83980.361572, idle connection 260881.000000, request 304999.952793 09/22/2025 02:19:10.764 7f1a20ecc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83979.998779, idle connection 260880.000000, request 304999.594688 09/22/2025 02:19:10.844 7f1a20ecc540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84092.434570, idle connection 261665.000000, request 304398.704767 09/22/2025 02:19:10.844 7f1a20ecc540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 09/22/2025 02:19:10.844 7f1a20ecc540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.844 7f1a20ecc540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 720 (601.825475692749 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1256477054, topics=[]) 09/22/2025 02:19:10.844 7f1a20ecc540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1256477054 with 0 response partitions (1 implied) 09/22/2025 02:19:10.863 7f1a20f80360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82771.768311, idle connection 260999.000000, request 304398.862123 09/22/2025 02:19:10.864 7f1a20f80360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 724 09/22/2025 02:19:10.864 7f1a20f80360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.864 7f1a20f80360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 724 (601.5384197235107 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2100418175, topics=[]) 09/22/2025 02:19:10.864 7f1a20f80360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2100418175 with 0 response partitions (1 implied) 09/22/2025 02:19:10.910 7f1a201219a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83962.900146, idle connection 261199.000000, request 304397.555113 09/22/2025 02:19:10.910 7f1a201219a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 09/22/2025 02:19:10.910 7f1a201219a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.910 7f1a201219a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 689 (602.8661727905273 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1596385324, topics=[]) 09/22/2025 02:19:10.910 7f1a201219a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1596385324 with 0 response partitions (1 implied) 09/22/2025 02:19:10.910 7f1a200d15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83929.171875, idle connection 261324.000000, request 304397.495031 09/22/2025 02:19:10.910 7f1a200d15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 09/22/2025 02:19:10.911 7f1a200d15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.911 7f1a200d15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 695 (602.8027534484863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=31953068, topics=[]) 09/22/2025 02:19:10.911 7f1a200d15e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 31953068 with 0 response partitions (1 implied) 09/22/2025 02:19:10.924 7f1a20f80040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 09/22/2025 02:19:10.924 7f1a20f80040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 09/22/2025 02:19:10.924 7f1a20f80040 [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)]) 09/22/2025 02:19:10.924 7f1a20f80040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.924 7f1a20f80040 [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=1563451795, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.924 7f1a20f80040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1563451795, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.924 7f1a20f80040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82715.804932, idle connection 261311.000000, request 304999.955177 09/22/2025 02:19:10.924 7f1a20f805e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 09/22/2025 02:19:10.924 7f1a20f805e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 09/22/2025 02:19:10.925 7f1a20f805e0 [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)]) 09/22/2025 02:19:10.925 7f1a20f805e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.925 7f1a20f805e0 [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=142612340, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.925 7f1a20f805e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=142612340, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.925 7f1a20f805e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82716.500244, idle connection 261312.000000, request 304999.965191 09/22/2025 02:19:10.926 7f1a20f80040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82714.468506, idle connection 261310.000000, request 304998.624325 09/22/2025 02:19:10.926 7f1a20f805e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82715.527832, idle connection 261312.000000, request 304998.996019 09/22/2025 02:19:10.943 7f1a20f80a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83336.713867, idle connection 260790.000000, request 304399.224281 09/22/2025 02:19:10.943 7f1a20f80a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 09/22/2025 02:19:10.943 7f1a20f80a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.943 7f1a20f80a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 697 (601.2363433837891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2088538190, topics=[]) 09/22/2025 02:19:10.944 7f1a20f80a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2088538190 with 0 response partitions (1 implied) 09/22/2025 02:19:10.944 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 09/22/2025 02:19:10.944 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 09/22/2025 02:19:10.944 7f1a20f80400 [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)]) 09/22/2025 02:19:10.944 7f1a20f80400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.944 7f1a20f80400 [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=1817142821, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.944 7f1a20f80400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1817142821, session_epoch=678, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.944 7f1a20f80400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82698.695801, idle connection 261294.000000, request 304999.960899 09/22/2025 02:19:10.945 7f1a20f80400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82698.367920, idle connection 261293.000000, request 304999.635458 09/22/2025 02:19:10.947 7f1a20f80cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83292.084229, idle connection 260696.000000, request 304398.484707 09/22/2025 02:19:10.947 7f1a20f80cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 09/22/2025 02:19:10.947 7f1a20f80cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:10.948 7f1a20f80cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 691 (601.834774017334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2134678589, topics=[]) 09/22/2025 02:19:10.948 7f1a20f80cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2134678589 with 0 response partitions (1 implied) 09/22/2025 02:19:10.959 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 4 09/22/2025 02:19:10.959 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 09/22/2025 02:19:10.959 7f1a20121720 [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)]) 09/22/2025 02:19:10.959 7f1a20121720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.959 7f1a20121720 [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=1340179034, session_epoch=679, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.959 7f1a20121720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1340179034, session_epoch=679, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.959 7f1a20121720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82700.170410, idle connection 261286.000000, request 304999.955893 09/22/2025 02:19:10.959 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 39 09/22/2025 02:19:10.959 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 09/22/2025 02:19:10.960 7f1a200b2ae0 [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)]) 09/22/2025 02:19:10.960 7f1a200b2ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.960 7f1a200b2ae0 [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=175045585, session_epoch=688, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.960 7f1a200b2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=175045585, session_epoch=688, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.960 7f1a200b2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83904.199463, idle connection 261281.000000, request 304999.965429 09/22/2025 02:19:10.960 7f1a20121720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82699.216553, idle connection 261285.000000, request 304999.007463 09/22/2025 02:19:10.960 7f1a200b2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83903.613037, idle connection 261280.000000, request 304999.381542 09/22/2025 02:19:10.972 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 26 09/22/2025 02:19:10.972 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 09/22/2025 02:19:10.973 7f1a2014d4a0 [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)]) 09/22/2025 02:19:10.973 7f1a2014d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:10.973 7f1a2014d4a0 [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=835120645, session_epoch=683, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.973 7f1a2014d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=835120645, session_epoch=683, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:10.973 7f1a2014d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83892.558594, idle connection 261000.000000, request 304999.952793 09/22/2025 02:19:10.973 7f1a2014d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83892.255615, idle connection 261000.000000, request 304999.662161 09/22/2025 02:19:11.000 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 65 09/22/2025 02:19:11.000 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 09/22/2025 02:19:11.000 7f1a2014dae0 [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)]) 09/22/2025 02:19:11.001 7f1a2014dae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.001 7f1a2014dae0 [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=277818289, session_epoch=688, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.001 7f1a2014dae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=277818289, session_epoch=688, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.001 7f1a2014dae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84215.282959, idle connection 261335.000000, request 304999.955177 09/22/2025 02:19:11.001 7f1a2014dae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84214.919189, idle connection 261334.000000, request 304999.594450 09/22/2025 02:19:11.010 7f1a20ecc180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84129.391113, idle connection 260696.000000, request 304398.988724 09/22/2025 02:19:11.010 7f1a20ecc180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 729 09/22/2025 02:19:11.010 7f1a20ecc180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.011 7f1a20ecc180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 729 (601.3762950897217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1638271374, topics=[]) 09/22/2025 02:19:11.011 7f1a20ecc180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1638271374 with 0 response partitions (1 implied) 09/22/2025 02:19:11.011 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 309 09/22/2025 02:19:11.011 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 09/22/2025 02:19:11.011 7f1a20eccea0 [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)]) 09/22/2025 02:19:11.011 7f1a20eccea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.011 7f1a20eccea0 [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=272584755, session_epoch=728, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.011 7f1a20eccea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 732 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=272584755, session_epoch=728, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.011 7f1a20eccea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83229.165771, idle connection 260805.000000, request 304999.961615 09/22/2025 02:19:11.012 7f1a20eccea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83228.816895, idle connection 260805.000000, request 304999.615431 09/22/2025 02:19:11.068 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 46 09/22/2025 02:19:11.068 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 09/22/2025 02:19:11.069 7f1a20f80ea0 [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)]) 09/22/2025 02:19:11.069 7f1a20f80ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.069 7f1a20f80ea0 [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=1770253246, session_epoch=689, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.069 7f1a20f80ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1770253246, session_epoch=689, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.069 7f1a20f80ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83819.332764, idle connection 260838.000000, request 304999.951601 09/22/2025 02:19:11.069 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 110 09/22/2025 02:19:11.069 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 09/22/2025 02:19:11.069 7f1a20ecc7c0 [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)]) 09/22/2025 02:19:11.069 7f1a20ecc7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.069 7f1a20ecc7c0 [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=535025570, session_epoch=701, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.070 7f1a20ecc7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 705 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=535025570, session_epoch=701, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.070 7f1a20ecc7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83262.970947, idle connection 261689.000000, request 304999.964714 09/22/2025 02:19:11.070 7f1a20ecc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83490.694092, idle connection 261075.000000, request 304397.054672 09/22/2025 02:19:11.070 7f1a20f80ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83818.204346, idle connection 260837.000000, request 304998.829603 09/22/2025 02:19:11.070 7f1a20ecc2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 09/22/2025 02:19:11.070 7f1a20ecc2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.070 7f1a20ecc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 710 (603.6133766174316 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262067599, topics=[]) 09/22/2025 02:19:11.071 7f1a20ecc2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1262067599 with 0 response partitions (1 implied) 09/22/2025 02:19:11.071 7f1a20ecc7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83261.699951, idle connection 261688.000000, request 304998.696566 09/22/2025 02:19:11.072 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 181 09/22/2025 02:19:11.072 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 02:19:11.072 7f1a20f80f40 [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)]) 09/22/2025 02:19:11.072 7f1a20f80f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.072 7f1a20f80f40 [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=1205049933, session_epoch=713, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.073 7f1a20f80f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 717 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1205049933, session_epoch=713, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.073 7f1a20f80f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83680.303955, idle connection 261294.000000, request 304999.964952 09/22/2025 02:19:11.073 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 350 09/22/2025 02:19:11.073 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 02:19:11.073 7f1a20ecc400 [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)]) 09/22/2025 02:19:11.073 7f1a20ecc400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.073 7f1a20ecc400 [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=2083347924, session_epoch=750, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.073 7f1a20ecc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 754 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2083347924, session_epoch=750, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.073 7f1a20ecc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83889.943604, idle connection 261577.000000, request 304999.966383 09/22/2025 02:19:11.074 7f1a20f80f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83679.415283, idle connection 261293.000000, request 304999.078751 09/22/2025 02:19:11.074 7f1a20ecc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83889.337891, idle connection 261576.000000, request 304999.363184 09/22/2025 02:19:11.149 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83160.418457, idle connection 260903.000000, request 304399.161577 09/22/2025 02:19:11.149 7f1a225a1e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1013 09/22/2025 02:19:11.149 7f1a225a1e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.149 7f1a225a1e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 1013 (601.3500690460205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1569562401, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3788, last_stable_offset=3788, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xcb\x00\x00\x01\x04\x00\x00\x00\x00\x02Y\x04%\xc0\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 09/22/2025 02:19:11.150 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1569562401 with 1 response partitions (0 implied) 09/22/2025 02:19:11.150 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3787 09/22/2025 02:19:11.150 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3787 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 09/22/2025 02:19:11.150 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3788 (leader epoch 0) 09/22/2025 02:19:11.160 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 40 09/22/2025 02:19:11.160 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 02:19:11.160 7f1a20ecc040 [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)]) 09/22/2025 02:19:11.160 7f1a20ecc040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.160 7f1a20ecc040 [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=1445378303, session_epoch=686, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.160 7f1a20ecc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1445378303, session_epoch=686, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.160 7f1a20ecc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84053.867676, idle connection 260852.000000, request 304999.952316 09/22/2025 02:19:11.161 7f1a20ecc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84053.495117, idle connection 260852.000000, request 304999.584913 09/22/2025 02:19:11.162 7f1a20f807c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83396.832275, idle connection 260990.000000, request 304399.358034 09/22/2025 02:19:11.162 7f1a20f807c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696 09/22/2025 02:19:11.162 7f1a20f807c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.163 7f1a20f807c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 696 (600.9654998779297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=738521822, topics=[]) 09/22/2025 02:19:11.163 7f1a20f807c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 738521822 with 0 response partitions (1 implied) 09/22/2025 02:19:11.245 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 9 09/22/2025 02:19:11.245 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/22/2025 02:19:11.245 7f1a20121860 [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)]) 09/22/2025 02:19:11.246 7f1a20121860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.246 7f1a20121860 [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=1778873578, session_epoch=681, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.246 7f1a20121860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1778873578, session_epoch=681, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.246 7f1a20121860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82763.302979, idle connection 260482.000000, request 304999.950171 09/22/2025 02:19:11.246 7f1a20121860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82762.873047, idle connection 260481.000000, request 304999.528170 09/22/2025 02:19:11.247 7f1a20f80180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82792.233154, idle connection 260035.000000, request 304399.057627 09/22/2025 02:19:11.247 7f1a20f80180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 09/22/2025 02:19:11.247 7f1a20f80180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.247 7f1a20f80180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 687 (601.3433933258057 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1220227894, topics=[]) 09/22/2025 02:19:11.247 7f1a20f80180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1220227894 with 0 response partitions (1 implied) 09/22/2025 02:19:11.250 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3788 09/22/2025 02:19:11.251 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 09/22/2025 02:19:11.251 7f1a225a1e00 [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)]) 09/22/2025 02:19:11.251 7f1a225a1e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.251 7f1a225a1e00 [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=1569562401, session_epoch=1010, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3788, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 02:19:11.251 7f1a225a1e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 1014 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569562401, session_epoch=1010, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3788, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 02:19:11.251 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83058.269043, idle connection 260801.000000, request 304999.961138 09/22/2025 02:19:11.251 7f1a225a1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83057.946777, idle connection 260801.000000, request 304999.641657 09/22/2025 02:19:11.265 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 266 09/22/2025 02:19:11.265 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 09/22/2025 02:19:11.265 7f1a20eccb80 [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)]) 09/22/2025 02:19:11.265 7f1a20eccb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.265 7f1a20eccb80 [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=622222272, session_epoch=724, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.265 7f1a20eccb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 728 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=622222272, session_epoch=724, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.265 7f1a20eccb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82373.028809, idle connection 260795.000000, request 304999.956846 09/22/2025 02:19:11.265 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 254 09/22/2025 02:19:11.265 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 02:19:11.265 7f1a20ecc860 [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)]) 09/22/2025 02:19:11.266 7f1a20ecc860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 02:19:11.266 7f1a20ecc860 [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=1217506319, session_epoch=721, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.266 7f1a20ecc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 725 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217506319, session_epoch=721, topics=[], forgotten_topics_data=[]) 09/22/2025 02:19:11.266 7f1a20ecc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82791.191162, idle connection 260819.000000, request 304999.966145 09/22/2025 02:19:11.266 7f1a20eccb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82372.099609, idle connection 260794.000000, request 304999.032259 09/22/2025 02:19:11.266 7f1a20ecc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82790.615967, idle connection 260819.000000, request 304999.393940 09/22/2025 02:19:11.290 7f1a20f80680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83034.033447, idle connection 260443.000000, request 304399.194241 09/22/2025 02:19:11.290 7f1a20f80680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 09/22/2025 02:19:11.290 7f1a20f80680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.290 7f1a20f80680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 691 (601.2332439422607 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145885723, topics=[]) 09/22/2025 02:19:11.290 7f1a20f80680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 145885723 with 0 response partitions (1 implied) 09/22/2025 02:19:11.345 7f1a201a8720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82519.984131, idle connection 260728.000000, request 304398.818970 09/22/2025 02:19:11.345 7f1a201a8720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 703 09/22/2025 02:19:11.345 7f1a201a8720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.345 7f1a201a8720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 703 (601.5892028808594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=782393377, topics=[]) 09/22/2025 02:19:11.345 7f1a201a8720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 782393377 with 0 response partitions (1 implied) 09/22/2025 02:19:11.364 7f1a20ecc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83379.508057, idle connection 260280.000000, request 304399.099112 09/22/2025 02:19:11.364 7f1a20ecc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 722 09/22/2025 02:19:11.364 7f1a20ecc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 02:19:11.365 7f1a20ecc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 722 (601.2616157531738 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=48035887, topics=[]) 09/22/2025 02:19:11.365 7f1a20ecc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 48035887 with 0 response partitions (1 implied)