10/20/2025 04:24:46.702 7fd5d74a9ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7459 10/20/2025 04:24:46.703 7fd5d74a9ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:46.704 7fd5d74a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 7459 (603.4049987792969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=764516958, topics=[]) 10/20/2025 04:24:46.704 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 764516958 with 0 response partitions (1 implied) 10/20/2025 04:24:46.804 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 295 10/20/2025 04:24:46.804 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/20/2025 04:24:46.804 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/20/2025 04:24:46.805 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:46.805 7fd5d74664a0 [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=1790461714, session_epoch=6819, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:46.805 7fd5d74664a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 6837 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1790461714, session_epoch=6819, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:46.805 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289718.947754, idle connection 228757.000000, request 304999.947786 10/20/2025 04:24:46.805 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289718.443359, idle connection 228756.000000, request 304999.450207 10/20/2025 04:24:46.819 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 290491.291748, idle connection 229234.000000, request 304398.849964 10/20/2025 04:24:46.819 7fd5d74a9720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7354 10/20/2025 04:24:46.819 7fd5d74a9720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:46.819 7fd5d74a9720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 7354 (601.6137599945068 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=965437490, topics=[]) 10/20/2025 04:24:46.819 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 965437490 with 0 response partitions (1 implied) 10/20/2025 04:24:46.991 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 259 10/20/2025 04:24:46.991 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 10/20/2025 04:24:46.991 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 10/20/2025 04:24:46.992 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:46.992 7fd5d74894a0 [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=1382423064, session_epoch=6805, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:46.992 7fd5d74894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 6821 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1382423064, session_epoch=6805, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:46.992 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288547.632080, idle connection 100624.000000, request 304999.948740 10/20/2025 04:24:46.992 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288547.178467, idle connection 100623.000000, request 304999.503136 10/20/2025 04:24:47.010 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4027 10/20/2025 04:24:47.010 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 10/20/2025 04:24:47.010 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 10/20/2025 04:24:47.010 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:47.011 7fd5d851f040 [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=1907225978, session_epoch=7326, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.011 7fd5d851f040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 7342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1907225978, session_epoch=7326, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.011 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 290509.840576, idle connection 166679.000000, request 304999.949455 10/20/2025 04:24:47.011 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 290509.452148, idle connection 166679.000000, request 304999.569416 10/20/2025 04:24:47.095 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 286736.303467, idle connection 100799.000000, request 304397.911310 10/20/2025 04:24:47.095 7fd5d74c7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6794 10/20/2025 04:24:47.096 7fd5d74c7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.096 7fd5d74c7360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 6794 (602.5772094726562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=887498609, topics=[]) 10/20/2025 04:24:47.096 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 887498609 with 0 response partitions (1 implied) 10/20/2025 04:24:47.096 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283122.217773, idle connection 459837.000000, request 304397.754431 10/20/2025 04:24:47.096 7fd5d74f8f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6815 10/20/2025 04:24:47.096 7fd5d74f8f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.096 7fd5d74f8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6815 (602.557897567749 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1174656800, topics=[]) 10/20/2025 04:24:47.096 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1174656800 with 0 response partitions (1 implied) 10/20/2025 04:24:47.192 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 292347.142578, idle connection 230669.000000, request 304398.813725 10/20/2025 04:24:47.192 7fd5d851f180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7402 10/20/2025 04:24:47.193 7fd5d851f180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.193 7fd5d851f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 7402 (601.7045974731445 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2117897749, topics=[]) 10/20/2025 04:24:47.193 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2117897749 with 0 response partitions (1 implied) 10/20/2025 04:24:47.285 7fd5d74a9f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289950.792236, idle connection 229337.000000, request 304399.032116 10/20/2025 04:24:47.286 7fd5d74a9f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7228 10/20/2025 04:24:47.286 7fd5d74a9f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.286 7fd5d74a9f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7228 (601.5958786010742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=995492197, topics=[]) 10/20/2025 04:24:47.286 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 995492197 with 0 response partitions (1 implied) 10/20/2025 04:24:47.306 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 5043 10/20/2025 04:24:47.306 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 10/20/2025 04:24:47.306 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 10/20/2025 04:24:47.306 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:47.306 7fd5d74a9ae0 [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=764516958, session_epoch=7446, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.306 7fd5d74a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 7460 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=764516958, session_epoch=7446, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.307 7fd5d74a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 292243.756836, idle connection 231152.000000, request 304999.944448 10/20/2025 04:24:47.307 7fd5d74a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 292243.350830, idle connection 231152.000000, request 304999.550104 10/20/2025 04:24:47.407 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289117.093018, idle connection 228155.000000, request 304398.092747 10/20/2025 04:24:47.407 7fd5d74664a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6837 10/20/2025 04:24:47.407 7fd5d74664a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.407 7fd5d74664a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 6837 (602.4916172027588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1790461714, topics=[]) 10/20/2025 04:24:47.408 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1790461714 with 0 response partitions (1 implied) 10/20/2025 04:24:47.421 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3125 10/20/2025 04:24:47.421 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 10/20/2025 04:24:47.421 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 10/20/2025 04:24:47.421 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:47.422 7fd5d74a9720 [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=965437490, session_epoch=7344, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.422 7fd5d74a9720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 7355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=965437490, session_epoch=7344, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.422 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289888.077148, idle connection 228630.000000, request 304999.937057 10/20/2025 04:24:47.422 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289887.662598, idle connection 228630.000000, request 304999.531269 10/20/2025 04:24:47.593 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287946.629639, idle connection 100023.000000, request 304398.946047 10/20/2025 04:24:47.593 7fd5d74894a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6821 10/20/2025 04:24:47.593 7fd5d74894a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.594 7fd5d74894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 6821 (601.6483306884766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1382423064, topics=[]) 10/20/2025 04:24:47.594 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1382423064 with 0 response partitions (1 implied) 10/20/2025 04:24:47.612 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289908.975098, idle connection 166078.000000, request 304399.083853 10/20/2025 04:24:47.612 7fd5d851f040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7342 10/20/2025 04:24:47.612 7fd5d851f040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.612 7fd5d851f040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 7342 (601.4418601989746 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1907225978, topics=[]) 10/20/2025 04:24:47.612 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1907225978 with 0 response partitions (1 implied) 10/20/2025 04:24:47.697 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 188 10/20/2025 04:24:47.697 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 10/20/2025 04:24:47.697 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/20/2025 04:24:47.697 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:47.697 7fd5d74c7360 [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=887498609, session_epoch=6775, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.698 7fd5d74c7360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 6795 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=887498609, session_epoch=6775, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.698 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 286133.755615, idle connection 100197.000000, request 304999.951124 10/20/2025 04:24:47.698 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 217 10/20/2025 04:24:47.698 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 10/20/2025 04:24:47.698 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 10/20/2025 04:24:47.698 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/20/2025 04:24:47.698 7fd5d74f8f40 [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=1174656800, session_epoch=6790, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.698 7fd5d74f8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6816 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1174656800, session_epoch=6790, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.698 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282519.840820, idle connection 459235.000000, request 304999.961853 10/20/2025 04:24:47.699 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 286132.680420, idle connection 100195.000000, request 304998.883486 10/20/2025 04:24:47.699 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282519.205322, idle connection 459234.000000, request 304999.329805 10/20/2025 04:24:47.795 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3492 10/20/2025 04:24:47.795 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 10/20/2025 04:24:47.795 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 10/20/2025 04:24:47.795 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:47.795 7fd5d851f180 [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=2117897749, session_epoch=7392, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.795 7fd5d851f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 7403 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2117897749, session_epoch=7392, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.796 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 291743.721191, idle connection 230065.000000, request 304999.950647 10/20/2025 04:24:47.796 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 291743.288086, idle connection 230065.000000, request 304999.525547 10/20/2025 04:24:47.886 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3014 10/20/2025 04:24:47.887 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 10/20/2025 04:24:47.887 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/20/2025 04:24:47.887 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/20/2025 04:24:47.887 7fd5d74a9f40 [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=995492197, session_epoch=7221, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.887 7fd5d74a9f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7229 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=995492197, session_epoch=7221, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:47.887 7fd5d74a9f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289348.885986, idle connection 228735.000000, request 304999.950409 10/20/2025 04:24:47.888 7fd5d74a9f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289348.490967, idle connection 228734.000000, request 304999.564171 10/20/2025 04:24:47.908 7fd5d74a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 291642.458984, idle connection 230551.000000, request 304398.654699 10/20/2025 04:24:47.908 7fd5d74a9ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7460 10/20/2025 04:24:47.908 7fd5d74a9ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:47.908 7fd5d74a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 7460 (601.8223762512207 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=764516958, topics=[]) 10/20/2025 04:24:47.908 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 764516958 with 0 response partitions (1 implied) 10/20/2025 04:24:48.008 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 295 10/20/2025 04:24:48.008 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/20/2025 04:24:48.008 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/20/2025 04:24:48.008 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:48.009 7fd5d74664a0 [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=1790461714, session_epoch=6820, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.009 7fd5d74664a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 6838 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1790461714, session_epoch=6820, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.009 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288515.047363, idle connection 227553.000000, request 304999.936581 10/20/2025 04:24:48.009 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288514.425293, idle connection 227552.000000, request 304999.321461 10/20/2025 04:24:48.024 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289286.207764, idle connection 228028.000000, request 304398.069143 10/20/2025 04:24:48.024 7fd5d74a9720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7355 10/20/2025 04:24:48.024 7fd5d74a9720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.024 7fd5d74a9720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 7355 (602.4689674377441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=965437490, topics=[]) 10/20/2025 04:24:48.024 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 965437490 with 0 response partitions (1 implied) 10/20/2025 04:24:48.195 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 259 10/20/2025 04:24:48.196 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 10/20/2025 04:24:48.196 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 10/20/2025 04:24:48.196 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:48.196 7fd5d74894a0 [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=1382423064, session_epoch=6806, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.196 7fd5d74894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 6822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1382423064, session_epoch=6806, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.196 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287343.406738, idle connection 99420.000000, request 304999.949217 10/20/2025 04:24:48.197 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287342.871338, idle connection 99419.000000, request 304999.421120 10/20/2025 04:24:48.214 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4027 10/20/2025 04:24:48.214 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 10/20/2025 04:24:48.214 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 10/20/2025 04:24:48.214 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:48.214 7fd5d851f040 [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=1907225978, session_epoch=7327, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.214 7fd5d851f040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 7343 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1907225978, session_epoch=7327, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.214 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289306.406250, idle connection 165476.000000, request 304999.955654 10/20/2025 04:24:48.215 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289306.052979, idle connection 165475.000000, request 304999.607563 10/20/2025 04:24:48.301 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285530.943115, idle connection 99594.000000, request 304397.138119 10/20/2025 04:24:48.301 7fd5d74c7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6795 10/20/2025 04:24:48.301 7fd5d74c7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.301 7fd5d74c7360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 6795 (603.3732891082764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=887498609, topics=[]) 10/20/2025 04:24:48.301 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 887498609 with 0 response partitions (1 implied) 10/20/2025 04:24:48.301 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281916.864746, idle connection 458632.000000, request 304396.987200 10/20/2025 04:24:48.302 7fd5d74f8f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6816 10/20/2025 04:24:48.302 7fd5d74f8f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.302 7fd5d74f8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6816 (603.4328937530518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1174656800, topics=[]) 10/20/2025 04:24:48.302 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1174656800 with 0 response partitions (1 implied) 10/20/2025 04:24:48.396 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 291142.806641, idle connection 229464.000000, request 304399.036884 10/20/2025 04:24:48.397 7fd5d851f180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7403 10/20/2025 04:24:48.397 7fd5d851f180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.397 7fd5d851f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 7403 (601.4621257781982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2117897749, topics=[]) 10/20/2025 04:24:48.397 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2117897749 with 0 response partitions (1 implied) 10/20/2025 04:24:48.488 7fd5d74a9f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288747.995850, idle connection 228134.000000, request 304399.061203 10/20/2025 04:24:48.488 7fd5d74a9f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7229 10/20/2025 04:24:48.489 7fd5d74a9f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.489 7fd5d74a9f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7229 (601.6199588775635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=995492197, topics=[]) 10/20/2025 04:24:48.489 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 995492197 with 0 response partitions (1 implied) 10/20/2025 04:24:48.509 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 5043 10/20/2025 04:24:48.510 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 10/20/2025 04:24:48.510 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 10/20/2025 04:24:48.510 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:48.510 7fd5d74a9ae0 [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=764516958, session_epoch=7447, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.510 7fd5d74a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 7461 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=764516958, session_epoch=7447, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.510 7fd5d74a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 291040.133545, idle connection 229949.000000, request 304999.938488 10/20/2025 04:24:48.511 7fd5d74a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 291039.707520, idle connection 229948.000000, request 304999.520302 10/20/2025 04:24:48.611 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287912.787109, idle connection 226951.000000, request 304397.678375 10/20/2025 04:24:48.611 7fd5d74664a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6838 10/20/2025 04:24:48.611 7fd5d74664a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.612 7fd5d74664a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 6838 (602.8244495391846 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1790461714, topics=[]) 10/20/2025 04:24:48.612 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1790461714 with 0 response partitions (1 implied) 10/20/2025 04:24:48.626 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3125 10/20/2025 04:24:48.626 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 10/20/2025 04:24:48.626 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 10/20/2025 04:24:48.626 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:48.627 7fd5d74a9720 [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=965437490, session_epoch=7345, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.627 7fd5d74a9720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 7356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=965437490, session_epoch=7345, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.627 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288683.086182, idle connection 227425.000000, request 304999.939680 10/20/2025 04:24:48.627 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288682.674805, idle connection 227425.000000, request 304999.536753 10/20/2025 04:24:48.797 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 286742.308350, idle connection 98818.000000, request 304398.852348 10/20/2025 04:24:48.798 7fd5d74894a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6822 10/20/2025 04:24:48.798 7fd5d74894a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.798 7fd5d74894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 6822 (601.6805171966553 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1382423064, topics=[]) 10/20/2025 04:24:48.798 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1382423064 with 0 response partitions (1 implied) 10/20/2025 04:24:48.815 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288705.623779, idle connection 164875.000000, request 304399.172068 10/20/2025 04:24:48.815 7fd5d851f040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7343 10/20/2025 04:24:48.815 7fd5d851f040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:48.816 7fd5d851f040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 7343 (601.2952327728271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1907225978, topics=[]) 10/20/2025 04:24:48.816 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1907225978 with 0 response partitions (1 implied) 10/20/2025 04:24:48.902 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 188 10/20/2025 04:24:48.902 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 10/20/2025 04:24:48.903 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/20/2025 04:24:48.903 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:48.903 7fd5d74c7360 [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=887498609, session_epoch=6776, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.903 7fd5d74c7360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 6796 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=887498609, session_epoch=6776, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.903 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284928.448975, idle connection 98991.000000, request 304999.947548 10/20/2025 04:24:48.903 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 217 10/20/2025 04:24:48.903 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 10/20/2025 04:24:48.903 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 10/20/2025 04:24:48.903 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/20/2025 04:24:48.903 7fd5d74f8f40 [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=1174656800, session_epoch=6791, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.904 7fd5d74f8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6817 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1174656800, session_epoch=6791, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:48.904 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281314.585449, idle connection 458029.000000, request 304999.966145 10/20/2025 04:24:48.904 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284927.404053, idle connection 98990.000000, request 304998.911142 10/20/2025 04:24:48.904 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281313.910645, idle connection 458029.000000, request 304999.294043 10/20/2025 04:24:48.999 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3492 10/20/2025 04:24:48.999 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 10/20/2025 04:24:48.999 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 10/20/2025 04:24:48.999 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:48.999 7fd5d851f180 [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=2117897749, session_epoch=7393, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.000 7fd5d851f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 7404 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2117897749, session_epoch=7393, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.000 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 290539.507812, idle connection 228861.000000, request 304999.951124 10/20/2025 04:24:49.000 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 290539.053223, idle connection 228861.000000, request 304999.502897 10/20/2025 04:24:49.089 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3014 10/20/2025 04:24:49.090 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 10/20/2025 04:24:49.090 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/20/2025 04:24:49.090 7fd5d74a9f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/20/2025 04:24:49.090 7fd5d74a9f40 [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=995492197, session_epoch=7222, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.090 7fd5d74a9f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7230 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=995492197, session_epoch=7222, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.090 7fd5d74a9f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288145.818115, idle connection 227532.000000, request 304999.950409 10/20/2025 04:24:49.091 7fd5d74a9f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288145.416504, idle connection 227531.000000, request 304999.556065 10/20/2025 04:24:49.111 7fd5d74a9ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 290439.237061, idle connection 229348.000000, request 304399.043322 10/20/2025 04:24:49.111 7fd5d74a9ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7461 10/20/2025 04:24:49.112 7fd5d74a9ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:49.112 7fd5d74a9ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 7461 (601.4869213104248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=764516958, topics=[]) 10/20/2025 04:24:49.112 7fd5d74a9ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 764516958 with 0 response partitions (1 implied) 10/20/2025 04:24:49.212 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 295 10/20/2025 04:24:49.212 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/20/2025 04:24:49.212 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/20/2025 04:24:49.213 7fd5d74664a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:49.213 7fd5d74664a0 [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=1790461714, session_epoch=6821, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.213 7fd5d74664a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 6839 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1790461714, session_epoch=6821, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.213 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287310.917236, idle connection 226349.000000, request 304999.949217 10/20/2025 04:24:49.213 7fd5d74664a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 287310.528076, idle connection 226348.000000, request 304999.567032 10/20/2025 04:24:49.228 7fd5d74a9720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288082.274902, idle connection 226825.000000, request 304399.134398 10/20/2025 04:24:49.228 7fd5d74a9720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7356 10/20/2025 04:24:49.228 7fd5d74a9720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:49.228 7fd5d74a9720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 7356 (601.2978553771973 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=965437490, topics=[]) 10/20/2025 04:24:49.228 7fd5d74a9720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 965437490 with 0 response partitions (1 implied) 10/20/2025 04:24:49.400 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 259 10/20/2025 04:24:49.400 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 10/20/2025 04:24:49.400 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 10/20/2025 04:24:49.400 7fd5d74894a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/20/2025 04:24:49.401 7fd5d74894a0 [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=1382423064, session_epoch=6807, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.401 7fd5d74894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 6823 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1382423064, session_epoch=6807, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.401 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 286138.708252, idle connection 98215.000000, request 304999.938726 10/20/2025 04:24:49.401 7fd5d74894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 286138.281738, idle connection 98214.000000, request 304999.520302 10/20/2025 04:24:49.417 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4027 10/20/2025 04:24:49.417 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 10/20/2025 04:24:49.417 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 10/20/2025 04:24:49.417 7fd5d851f040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/20/2025 04:24:49.417 7fd5d851f040 [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=1907225978, session_epoch=7328, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.417 7fd5d851f040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 7344 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1907225978, session_epoch=7328, topics=[], forgotten_topics_data=[]) 10/20/2025 04:24:49.418 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288103.087891, idle connection 164272.000000, request 304999.948978 10/20/2025 04:24:49.418 7fd5d851f040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 288102.657715, idle connection 164272.000000, request 304999.525785 10/20/2025 04:24:49.506 7fd5d74c7360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284325.741211, idle connection 98389.000000, request 304397.240639 10/20/2025 04:24:49.506 7fd5d74c7360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6796 10/20/2025 04:24:49.506 7fd5d74c7360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:49.506 7fd5d74c7360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 6796 (603.2617092132568 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=887498609, topics=[]) 10/20/2025 04:24:49.506 7fd5d74c7360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 887498609 with 0 response partitions (1 implied) 10/20/2025 04:24:49.507 7fd5d74f8f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280711.684814, idle connection 457427.000000, request 304397.064447 10/20/2025 04:24:49.507 7fd5d74f8f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6817 10/20/2025 04:24:49.507 7fd5d74f8f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:49.507 7fd5d74f8f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6817 (603.2395362854004 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1174656800, topics=[]) 10/20/2025 04:24:49.507 7fd5d74f8f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1174656800 with 0 response partitions (1 implied) 10/20/2025 04:24:49.601 7fd5d851f180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 289938.552246, idle connection 228260.000000, request 304398.994923 10/20/2025 04:24:49.601 7fd5d851f180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7404 10/20/2025 04:24:49.601 7fd5d851f180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/20/2025 04:24:49.601 7fd5d851f180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 7404 (601.5322208404541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2117897749, topics=[]) 10/20/2025 04:24:49.601 7fd5d851f180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2117897749 with 0 response partitions (1 implied)