10/02/2025 04:11:39.779 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:39.780 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:39.780 7f089f23e720 [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=1587067153, session_epoch=7066, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.781 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7077 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7066, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.781 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282530.588135, idle connection 221349.000000, request 304999.897003 10/02/2025 04:11:39.781 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:39.781 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:39.781 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:39.781 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:39.781 7f089f23eb80 [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=1262728381, session_epoch=7094, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.781 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7117 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7094, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.782 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280120.719971, idle connection 458619.000000, request 304999.960899 10/02/2025 04:11:39.782 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:39.782 7f089f23ea40 [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/02/2025 04:11:39.782 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:39.782 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:39.782 7f089f23ea40 [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=563486034, session_epoch=7071, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.782 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7089 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7071, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.782 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280122.277588, idle connection 219407.000000, request 304999.959707 10/02/2025 04:11:39.783 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282528.701172, idle connection 221347.000000, request 304998.019457 10/02/2025 04:11:39.783 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280119.331299, idle connection 458618.000000, request 304998.575926 10/02/2025 04:11:39.783 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280121.346191, idle connection 219406.000000, request 304999.035120 10/02/2025 04:11:39.822 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:39.822 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:39.822 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:39.822 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:39.822 7f089f23e2c0 [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=1550865089, session_epoch=7075, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.822 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7098 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7075, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.822 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280150.243652, idle connection 219187.000000, request 304999.949932 10/02/2025 04:11:39.823 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280149.847412, idle connection 219187.000000, request 304999.561310 10/02/2025 04:11:39.874 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283153.406494, idle connection 220858.000000, request 304398.131132 10/02/2025 04:11:39.875 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7082 10/02/2025 04:11:39.875 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:39.875 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7082 (602.4932861328125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:39.875 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:39.875 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279548.282959, idle connection 458150.000000, request 304397.774696 10/02/2025 04:11:39.875 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7015 10/02/2025 04:11:39.875 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:39.876 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7015 (602.5564670562744 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:39.876 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:39.981 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:39.981 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:39.981 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:39.982 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:39.982 7f089f23e540 [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=584438549, session_epoch=7075, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.982 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7090 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7075, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:39.982 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281334.666992, idle connection 219759.000000, request 304999.947548 10/02/2025 04:11:39.982 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281334.239502, idle connection 219759.000000, request 304999.527931 10/02/2025 04:11:39.986 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281243.571045, idle connection 220160.000000, request 304399.018288 10/02/2025 04:11:39.986 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7672 10/02/2025 04:11:39.986 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:39.986 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7672 (601.452112197876 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:39.986 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied) 10/02/2025 04:11:40.035 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 205 10/02/2025 04:11:40.035 7f089f23e400 [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/02/2025 04:11:40.035 7f089f23e400 [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/02/2025 04:11:40.035 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:40.035 7f089f23e400 [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=885979671, session_epoch=7041, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.035 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7057 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885979671, session_epoch=7041, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.036 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278937.731201, idle connection 456305.000000, request 304999.942303 10/02/2025 04:11:40.036 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278937.324951, idle connection 456305.000000, request 304999.543428 10/02/2025 04:11:40.081 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281939.484131, idle connection 221074.000000, request 304397.995710 10/02/2025 04:11:40.082 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8171 10/02/2025 04:11:40.082 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.082 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8171 (602.571964263916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[]) 10/02/2025 04:11:40.082 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 0 response partitions (1 implied) 10/02/2025 04:11:40.107 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 646 10/02/2025 04:11:40.107 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:40.107 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:40.107 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:40.108 7f089f23e900 [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=145942367, session_epoch=7159, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.108 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7167 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7159, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.108 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282536.477783, idle connection 221012.000000, request 304999.934196 10/02/2025 04:11:40.108 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282536.031738, idle connection 221012.000000, request 304999.503136 10/02/2025 04:11:40.176 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3819 10/02/2025 04:11:40.176 7f089f23ee00 [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/02/2025 04:11:40.176 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/02/2025 04:11:40.176 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:40.176 7f089f23ee00 [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=678086140, session_epoch=7590, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.177 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7605 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=678086140, session_epoch=7590, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.177 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281422.749023, idle connection 220440.000000, request 304999.925613 10/02/2025 04:11:40.177 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281422.209961, idle connection 220440.000000, request 304999.399900 10/02/2025 04:11:40.384 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281927.123047, idle connection 220746.000000, request 304396.431684 10/02/2025 04:11:40.385 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7077 10/02/2025 04:11:40.385 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.385 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7077 (604.0918827056885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1587067153, topics=[]) 10/02/2025 04:11:40.385 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1587067153 with 0 response partitions (1 implied) 10/02/2025 04:11:40.385 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279517.160156, idle connection 458016.000000, request 304396.403074 10/02/2025 04:11:40.385 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279519.299561, idle connection 218804.000000, request 304396.987438 10/02/2025 04:11:40.385 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7117 10/02/2025 04:11:40.385 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.386 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7117 (604.0236949920654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262728381, topics=[]) 10/02/2025 04:11:40.386 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1262728381 with 0 response partitions (1 implied) 10/02/2025 04:11:40.386 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7089 10/02/2025 04:11:40.386 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.386 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7089 (603.792667388916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=563486034, topics=[]) 10/02/2025 04:11:40.386 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 563486034 with 0 response partitions (1 implied) 10/02/2025 04:11:40.423 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279549.342041, idle connection 218586.000000, request 304399.046659 10/02/2025 04:11:40.424 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7098 10/02/2025 04:11:40.424 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.424 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7098 (601.4490127563477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1550865089, topics=[]) 10/02/2025 04:11:40.424 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1550865089 with 0 response partitions (1 implied) 10/02/2025 04:11:40.476 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 295 10/02/2025 04:11:40.477 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/02/2025 04:11:40.477 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 10/02/2025 04:11:40.477 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:40.477 7f089e3be040 [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=69561686, session_epoch=7068, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.477 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7083 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=69561686, session_epoch=7068, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.477 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282550.576904, idle connection 220255.000000, request 304999.950647 10/02/2025 04:11:40.477 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/02/2025 04:11:40.477 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/02/2025 04:11:40.477 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 10/02/2025 04:11:40.477 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:40.477 7f08a083d4a0 [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=76155561, session_epoch=6989, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.478 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7016 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=76155561, session_epoch=6989, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.478 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278945.823730, idle connection 457548.000000, request 304999.966145 10/02/2025 04:11:40.478 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282549.523193, idle connection 220254.000000, request 304998.904467 10/02/2025 04:11:40.478 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278945.166992, idle connection 457547.000000, request 304999.312878 10/02/2025 04:11:40.584 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280732.258545, idle connection 219157.000000, request 304397.540331 10/02/2025 04:11:40.585 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7090 10/02/2025 04:11:40.585 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.585 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7090 (603.0383110046387 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=584438549, topics=[]) 10/02/2025 04:11:40.585 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 584438549 with 0 response partitions (1 implied) 10/02/2025 04:11:40.588 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3756 10/02/2025 04:11:40.588 7f089f23ed60 [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/02/2025 04:11:40.588 7f089f23ed60 [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/02/2025 04:11:40.588 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:40.588 7f089f23ed60 [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=803606486, session_epoch=7662, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.588 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7673 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=803606486, session_epoch=7662, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.588 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280641.009766, idle connection 219558.000000, request 304999.950647 10/02/2025 04:11:40.589 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280640.579590, idle connection 219557.000000, request 304999.525785 10/02/2025 04:11:40.637 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278336.461670, idle connection 455704.000000, request 304398.674011 10/02/2025 04:11:40.637 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7057 10/02/2025 04:11:40.637 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.637 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7057 (601.8378734588623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885979671, topics=[]) 10/02/2025 04:11:40.638 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 885979671 with 0 response partitions (1 implied) 10/02/2025 04:11:40.683 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 6234 10/02/2025 04:11:40.683 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/02/2025 04:11:40.683 7f089f23e7c0 [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)]) 10/02/2025 04:11:40.683 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:40.683 7f089f23e7c0 [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=1442988832, session_epoch=8159, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.684 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8172 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1442988832, session_epoch=8159, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.684 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281337.221436, idle connection 220472.000000, request 304999.946356 10/02/2025 04:11:40.684 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281336.806396, idle connection 220472.000000, request 304999.538898 10/02/2025 04:11:40.709 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281935.088623, idle connection 220411.000000, request 304398.552418 10/02/2025 04:11:40.710 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7167 10/02/2025 04:11:40.710 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.710 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7167 (602.0536422729492 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145942367, topics=[]) 10/02/2025 04:11:40.710 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 145942367 with 0 response partitions (1 implied) 10/02/2025 04:11:40.779 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280820.999512, idle connection 219839.000000, request 304398.171425 10/02/2025 04:11:40.779 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7605 10/02/2025 04:11:40.779 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:40.779 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7605 (602.5235652923584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=678086140, topics=[]) 10/02/2025 04:11:40.780 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 678086140 with 0 response partitions (1 implied) 10/02/2025 04:11:40.985 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 502 10/02/2025 04:11:40.986 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/02/2025 04:11:40.986 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:40.986 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:40.986 7f089f23e720 [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=1587067153, session_epoch=7067, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.986 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7078 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7067, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.986 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281325.186523, idle connection 220144.000000, request 304999.932289 10/02/2025 04:11:40.986 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:40.986 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:40.987 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:40.987 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:40.987 7f089f23eb80 [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=1262728381, session_epoch=7095, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.987 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7118 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7095, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.987 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278915.352295, idle connection 457414.000000, request 304999.962091 10/02/2025 04:11:40.988 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281323.354736, idle connection 220142.000000, request 304998.113632 10/02/2025 04:11:40.988 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:40.988 7f089f23ea40 [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/02/2025 04:11:40.988 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:40.988 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:40.989 7f089f23ea40 [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=563486034, session_epoch=7072, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.989 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7090 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7072, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:40.989 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278915.688232, idle connection 218201.000000, request 304999.957800 10/02/2025 04:11:40.989 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278913.109619, idle connection 457411.000000, request 304997.722626 10/02/2025 04:11:40.990 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278914.992920, idle connection 218200.000000, request 304999.266148 10/02/2025 04:11:41.024 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:41.025 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:41.025 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:41.025 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:41.025 7f089f23e2c0 [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=1550865089, session_epoch=7076, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.025 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7099 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7076, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.025 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278947.492188, idle connection 217984.000000, request 304999.934673 10/02/2025 04:11:41.026 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278947.050781, idle connection 217984.000000, request 304999.506235 10/02/2025 04:11:41.079 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281948.640869, idle connection 219653.000000, request 304398.014069 10/02/2025 04:11:41.079 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7083 10/02/2025 04:11:41.079 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.080 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7083 (602.5333404541016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:41.080 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:41.080 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278343.643066, idle connection 456946.000000, request 304397.786617 10/02/2025 04:11:41.080 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7016 10/02/2025 04:11:41.080 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.080 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7016 (602.5111675262451 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:41.080 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:41.185 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:41.186 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:41.186 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:41.186 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:41.186 7f089f23e540 [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=584438549, session_epoch=7076, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.186 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7091 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7076, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.186 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280130.414795, idle connection 218555.000000, request 304999.947309 10/02/2025 04:11:41.187 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280129.981934, idle connection 218554.000000, request 304999.522209 10/02/2025 04:11:41.189 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280040.183350, idle connection 218957.000000, request 304399.121284 10/02/2025 04:11:41.189 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7673 10/02/2025 04:11:41.190 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.190 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7673 (601.2721061706543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:41.190 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied) 10/02/2025 04:11:41.238 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 205 10/02/2025 04:11:41.238 7f089f23e400 [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/02/2025 04:11:41.238 7f089f23e400 [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/02/2025 04:11:41.238 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:41.238 7f089f23e400 [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=885979671, session_epoch=7042, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.239 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7058 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885979671, session_epoch=7042, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.239 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277734.663086, idle connection 455102.000000, request 304999.945879 10/02/2025 04:11:41.239 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277734.270996, idle connection 455102.000000, request 304999.563456 10/02/2025 04:11:41.285 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280735.618652, idle connection 219870.000000, request 304398.340464 10/02/2025 04:11:41.286 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8172 10/02/2025 04:11:41.286 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.286 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8172 (602.1842956542969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[]) 10/02/2025 04:11:41.286 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 0 response partitions (1 implied) 10/02/2025 04:11:41.312 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 646 10/02/2025 04:11:41.312 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:41.312 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:41.312 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:41.312 7f089f23e900 [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=145942367, session_epoch=7160, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.312 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7168 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7160, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.312 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281331.857178, idle connection 219808.000000, request 304999.948263 10/02/2025 04:11:41.313 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281331.431641, idle connection 219807.000000, request 304999.531031 10/02/2025 04:11:41.382 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3819 10/02/2025 04:11:41.382 7f089f23ee00 [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/02/2025 04:11:41.382 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/02/2025 04:11:41.382 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:41.382 7f089f23ee00 [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=678086140, session_epoch=7591, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.382 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7606 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=678086140, session_epoch=7591, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.382 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280217.063721, idle connection 219235.000000, request 304999.945879 10/02/2025 04:11:41.383 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280216.635254, idle connection 219234.000000, request 304999.522448 10/02/2025 04:11:41.590 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280721.397705, idle connection 219540.000000, request 304396.149158 10/02/2025 04:11:41.590 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7078 10/02/2025 04:11:41.590 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.591 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7078 (604.4282913208008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1587067153, topics=[]) 10/02/2025 04:11:41.591 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1587067153 with 0 response partitions (1 implied) 10/02/2025 04:11:41.591 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278311.338867, idle connection 456810.000000, request 304395.946741 10/02/2025 04:11:41.591 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278313.457275, idle connection 217599.000000, request 304397.727251 10/02/2025 04:11:41.591 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7118 10/02/2025 04:11:41.591 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.591 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7118 (604.5441627502441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262728381, topics=[]) 10/02/2025 04:11:41.592 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1262728381 with 0 response partitions (1 implied) 10/02/2025 04:11:41.592 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7090 10/02/2025 04:11:41.592 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.592 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7090 (603.0521392822266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=563486034, topics=[]) 10/02/2025 04:11:41.592 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 563486034 with 0 response partitions (1 implied) 10/02/2025 04:11:41.626 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278346.564941, idle connection 217383.000000, request 304399.010181 10/02/2025 04:11:41.626 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7099 10/02/2025 04:11:41.627 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.627 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7099 (601.4871597290039 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1550865089, topics=[]) 10/02/2025 04:11:41.627 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1550865089 with 0 response partitions (1 implied) 10/02/2025 04:11:41.681 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 295 10/02/2025 04:11:41.681 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/02/2025 04:11:41.682 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 10/02/2025 04:11:41.682 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:41.682 7f089e3be040 [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=69561686, session_epoch=7069, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.682 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7084 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=69561686, session_epoch=7069, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.682 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281345.580811, idle connection 219050.000000, request 304999.944687 10/02/2025 04:11:41.682 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/02/2025 04:11:41.682 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/02/2025 04:11:41.682 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 10/02/2025 04:11:41.683 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:41.683 7f08a083d4a0 [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=76155561, session_epoch=6990, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.683 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7017 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=76155561, session_epoch=6990, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.683 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277740.680664, idle connection 456343.000000, request 304999.960899 10/02/2025 04:11:41.683 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281344.369385, idle connection 219049.000000, request 304998.742342 10/02/2025 04:11:41.684 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277740.002930, idle connection 456342.000000, request 304999.287128 10/02/2025 04:11:41.787 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279529.153320, idle connection 217953.000000, request 304398.685217 10/02/2025 04:11:41.788 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7091 10/02/2025 04:11:41.788 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.788 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7091 (602.0302772521973 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=584438549, topics=[]) 10/02/2025 04:11:41.788 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 584438549 with 0 response partitions (1 implied) 10/02/2025 04:11:41.791 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3756 10/02/2025 04:11:41.791 7f089f23ed60 [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/02/2025 04:11:41.791 7f089f23ed60 [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/02/2025 04:11:41.791 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:41.791 7f089f23ed60 [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=803606486, session_epoch=7663, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.791 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7674 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=803606486, session_epoch=7663, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.791 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279438.274414, idle connection 218355.000000, request 304999.956369 10/02/2025 04:11:41.792 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279437.864502, idle connection 218355.000000, request 304999.550581 10/02/2025 04:11:41.840 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277132.865234, idle connection 454501.000000, request 304398.150206 10/02/2025 04:11:41.841 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7058 10/02/2025 04:11:41.841 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.841 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7058 (602.3428440093994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885979671, topics=[]) 10/02/2025 04:11:41.841 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 885979671 with 0 response partitions (1 implied) 10/02/2025 04:11:41.887 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 6234 10/02/2025 04:11:41.888 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/02/2025 04:11:41.888 7f089f23e7c0 [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)]) 10/02/2025 04:11:41.888 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:41.888 7f089f23e7c0 [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=1442988832, session_epoch=8160, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.888 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8173 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1442988832, session_epoch=8160, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:41.888 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280132.906738, idle connection 219268.000000, request 304999.948502 10/02/2025 04:11:41.888 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280132.501709, idle connection 219267.000000, request 304999.550581 10/02/2025 04:11:41.914 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280730.636719, idle connection 219207.000000, request 304398.730755 10/02/2025 04:11:41.914 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7168 10/02/2025 04:11:41.914 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.914 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7168 (601.7887592315674 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145942367, topics=[]) 10/02/2025 04:11:41.914 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 145942367 with 0 response partitions (1 implied) 10/02/2025 04:11:41.984 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279615.575439, idle connection 218633.000000, request 304398.457766 10/02/2025 04:11:41.984 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7606 10/02/2025 04:11:41.984 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:41.984 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7606 (602.07200050354 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=678086140, topics=[]) 10/02/2025 04:11:41.985 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 678086140 with 0 response partitions (1 implied) 10/02/2025 04:11:42.191 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 502 10/02/2025 04:11:42.191 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/02/2025 04:11:42.191 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:42.191 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:42.192 7f089f23e720 [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=1587067153, session_epoch=7068, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.192 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7079 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7068, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.192 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280119.490234, idle connection 218938.000000, request 304999.946117 10/02/2025 04:11:42.192 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:42.192 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:42.192 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:42.192 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:42.192 7f089f23eb80 [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=1262728381, session_epoch=7096, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.192 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7096, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.193 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277709.699951, idle connection 456208.000000, request 304999.962807 10/02/2025 04:11:42.193 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280118.437256, idle connection 218937.000000, request 304998.901844 10/02/2025 04:11:42.193 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:42.193 7f089f23ea40 [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/02/2025 04:11:42.193 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:42.193 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:42.193 7f089f23ea40 [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=563486034, session_epoch=7073, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.193 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7091 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7073, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.193 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277711.030029, idle connection 216996.000000, request 304999.966145 10/02/2025 04:11:42.194 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277708.468018, idle connection 456207.000000, request 304998.734713 10/02/2025 04:11:42.194 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277710.396484, idle connection 216996.000000, request 304999.334335 10/02/2025 04:11:42.227 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:42.227 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:42.227 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:42.227 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:42.228 7f089f23e2c0 [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=1550865089, session_epoch=7077, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.228 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7100 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7077, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.228 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277744.816650, idle connection 216782.000000, request 304999.949694 10/02/2025 04:11:42.228 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277744.426270, idle connection 216781.000000, request 304999.565601 10/02/2025 04:11:42.284 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280743.616699, idle connection 218448.000000, request 304397.982836 10/02/2025 04:11:42.284 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7084 10/02/2025 04:11:42.284 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.285 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7084 (602.5397777557373 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:42.285 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:42.285 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277138.649170, idle connection 455741.000000, request 304397.931337 10/02/2025 04:11:42.285 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7017 10/02/2025 04:11:42.285 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.285 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7017 (602.3569107055664 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:42.285 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:42.389 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:42.389 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:42.389 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:42.389 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:42.389 7f089f23e540 [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=584438549, session_epoch=7077, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.389 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7092 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7077, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.389 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278927.155029, idle connection 217351.000000, request 304999.947309 10/02/2025 04:11:42.390 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278926.749756, idle connection 217351.000000, request 304999.550581 10/02/2025 04:11:42.392 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278837.531006, idle connection 217754.000000, request 304399.217129 10/02/2025 04:11:42.392 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7674 10/02/2025 04:11:42.392 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.392 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7674 (601.1638641357422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:42.392 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied) 10/02/2025 04:11:42.441 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 205 10/02/2025 04:11:42.442 7f089f23e400 [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/02/2025 04:11:42.442 7f089f23e400 [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/02/2025 04:11:42.442 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:42.442 7f089f23e400 [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=885979671, session_epoch=7043, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.442 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7059 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885979671, session_epoch=7043, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.442 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276531.066406, idle connection 453899.000000, request 304999.949217 10/02/2025 04:11:42.443 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276530.599121, idle connection 453898.000000, request 304999.489307 10/02/2025 04:11:42.489 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279531.752686, idle connection 218667.000000, request 304398.793936 10/02/2025 04:11:42.490 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8173 10/02/2025 04:11:42.490 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.490 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8173 (601.8025875091553 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[]) 10/02/2025 04:11:42.490 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 0 response partitions (1 implied) 10/02/2025 04:11:42.516 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 646 10/02/2025 04:11:42.517 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:42.517 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:42.517 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:42.517 7f089f23e900 [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=145942367, session_epoch=7161, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.517 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7169 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7161, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.518 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280126.680420, idle connection 218603.000000, request 304999.912500 10/02/2025 04:11:42.518 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280126.024170, idle connection 218602.000000, request 304999.274254 10/02/2025 04:11:42.586 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3819 10/02/2025 04:11:42.586 7f089f23ee00 [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/02/2025 04:11:42.586 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/02/2025 04:11:42.586 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:42.587 7f089f23ee00 [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=678086140, session_epoch=7592, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.587 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7607 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=678086140, session_epoch=7592, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.587 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279012.477051, idle connection 218030.000000, request 304999.930859 10/02/2025 04:11:42.588 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279011.902588, idle connection 218029.000000, request 304999.367714 10/02/2025 04:11:42.794 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279516.951416, idle connection 218336.000000, request 304397.405863 10/02/2025 04:11:42.795 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7079 10/02/2025 04:11:42.795 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.795 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7079 (603.2607555389404 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1587067153, topics=[]) 10/02/2025 04:11:42.795 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1587067153 with 0 response partitions (1 implied) 10/02/2025 04:11:42.796 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277106.681396, idle connection 455605.000000, request 304396.944761 10/02/2025 04:11:42.796 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277108.819824, idle connection 216394.000000, request 304397.756815 10/02/2025 04:11:42.796 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7119 10/02/2025 04:11:42.796 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.796 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7119 (603.5475730895996 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262728381, topics=[]) 10/02/2025 04:11:42.796 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1262728381 with 0 response partitions (1 implied) 10/02/2025 04:11:42.796 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7091 10/02/2025 04:11:42.797 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.797 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7091 (603.1231880187988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=563486034, topics=[]) 10/02/2025 04:11:42.797 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 563486034 with 0 response partitions (1 implied) 10/02/2025 04:11:42.829 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277143.934570, idle connection 216181.000000, request 304399.058819 10/02/2025 04:11:42.829 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7100 10/02/2025 04:11:42.829 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.829 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7100 (601.6967296600342 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1550865089, topics=[]) 10/02/2025 04:11:42.830 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1550865089 with 0 response partitions (1 implied) 10/02/2025 04:11:42.885 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 295 10/02/2025 04:11:42.886 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/02/2025 04:11:42.886 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 10/02/2025 04:11:42.886 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:42.886 7f089e3be040 [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=69561686, session_epoch=7070, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.886 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7085 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=69561686, session_epoch=7070, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.886 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280141.260498, idle connection 217846.000000, request 304999.922514 10/02/2025 04:11:42.887 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/02/2025 04:11:42.887 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/02/2025 04:11:42.887 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 10/02/2025 04:11:42.887 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:42.887 7f08a083d4a0 [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=76155561, session_epoch=6991, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.887 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7018 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=76155561, session_epoch=6991, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.888 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276536.028320, idle connection 455138.000000, request 304999.937773 10/02/2025 04:11:42.889 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280139.086914, idle connection 217844.000000, request 304997.758627 10/02/2025 04:11:42.889 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276534.513184, idle connection 455137.000000, request 304998.428583 10/02/2025 04:11:42.990 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278326.242432, idle connection 216751.000000, request 304399.036884 10/02/2025 04:11:42.991 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7092 10/02/2025 04:11:42.991 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:42.991 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7092 (601.503849029541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=584438549, topics=[]) 10/02/2025 04:11:42.991 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 584438549 with 0 response partitions (1 implied) 10/02/2025 04:11:42.993 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3756 10/02/2025 04:11:42.994 7f089f23ed60 [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/02/2025 04:11:42.994 7f089f23ed60 [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/02/2025 04:11:42.994 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:42.994 7f089f23ed60 [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=803606486, session_epoch=7664, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.994 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7675 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=803606486, session_epoch=7664, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:42.994 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278235.369873, idle connection 217152.000000, request 304999.955177 10/02/2025 04:11:42.995 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278234.816406, idle connection 217152.000000, request 304999.401569 10/02/2025 04:11:43.043 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275930.015625, idle connection 453298.000000, request 304398.898125 10/02/2025 04:11:43.044 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7059 10/02/2025 04:11:43.044 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.044 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7059 (601.6325950622559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885979671, topics=[]) 10/02/2025 04:11:43.044 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 885979671 with 0 response partitions (1 implied) 10/02/2025 04:11:43.090 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 6234 10/02/2025 04:11:43.091 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/02/2025 04:11:43.091 7f089f23e7c0 [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)]) 10/02/2025 04:11:43.091 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:43.091 7f089f23e7c0 [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=1442988832, session_epoch=8161, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.091 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8174 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1442988832, session_epoch=8161, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.091 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278929.809082, idle connection 218065.000000, request 304999.946356 10/02/2025 04:11:43.092 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278929.284912, idle connection 218064.000000, request 304999.430895 10/02/2025 04:11:43.119 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279525.443359, idle connection 218001.000000, request 304398.688555 10/02/2025 04:11:43.119 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7169 10/02/2025 04:11:43.119 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.119 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7169 (601.8743515014648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145942367, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=647, last_stable_offset=647, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x02\x86\x00\x00\x01\x17\x00\x00\x00\x00\x02.\x92\xa4g\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\xc8\x03\x00\x00\x00\x8a\x03ObjectVMITable:default-global-sy...')])]) 10/02/2025 04:11:43.120 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 145942367 with 1 response partitions (0 implied) 10/02/2025 04:11:43.120 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-12', partition=0) with offset 646 10/02/2025 04:11:43.120 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 646 for assigned partition TopicPartition(topic='-uve-topic-12', partition=0) 10/02/2025 04:11:43.120 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-12', partition=0) to 647 (leader epoch 0) 10/02/2025 04:11:43.188 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278411.181641, idle connection 217429.000000, request 304398.639679 10/02/2025 04:11:43.189 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7607 10/02/2025 04:11:43.189 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.189 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7607 (601.8741130828857 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=678086140, topics=[]) 10/02/2025 04:11:43.189 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 678086140 with 0 response partitions (1 implied) 10/02/2025 04:11:43.221 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 647 10/02/2025 04:11:43.221 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:43.221 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-12', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:43.221 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:43.221 7f089f23e900 [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=145942367, session_epoch=7162, topics=[(topic='-uve-topic-12', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=647, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/02/2025 04:11:43.221 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7170 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7162, topics=[(topic='-uve-topic-12', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=647, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/02/2025 04:11:43.221 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279423.009521, idle connection 217899.000000, request 304999.932766 10/02/2025 04:11:43.222 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279422.605469, idle connection 217898.000000, request 304999.537468 10/02/2025 04:11:43.396 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 502 10/02/2025 04:11:43.396 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/02/2025 04:11:43.396 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:43.396 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:43.396 7f089f23e720 [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=1587067153, session_epoch=7069, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.397 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7080 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7069, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.397 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278914.638428, idle connection 217733.000000, request 304999.947548 10/02/2025 04:11:43.397 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:43.397 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:43.397 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:43.397 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:43.397 7f089f23eb80 [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=1262728381, session_epoch=7097, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.397 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7097, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.397 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276504.826660, idle connection 455003.000000, request 304999.962330 10/02/2025 04:11:43.398 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278913.539551, idle connection 217732.000000, request 304998.856544 10/02/2025 04:11:43.398 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:43.398 7f089f23ea40 [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/02/2025 04:11:43.398 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:43.398 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:43.398 7f089f23ea40 [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=563486034, session_epoch=7074, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.398 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7092 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7074, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.398 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276506.105957, idle connection 215791.000000, request 304999.965429 10/02/2025 04:11:43.399 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276503.563965, idle connection 455002.000000, request 304998.703957 10/02/2025 04:11:43.399 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276505.316895, idle connection 215790.000000, request 304999.178171 10/02/2025 04:11:43.430 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:43.430 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:43.430 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:43.430 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:43.431 7f089f23e2c0 [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=1550865089, session_epoch=7078, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.431 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7101 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7078, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.431 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276541.882080, idle connection 215579.000000, request 304999.951839 10/02/2025 04:11:43.431 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276541.499268, idle connection 215578.000000, request 304999.575138 10/02/2025 04:11:43.490 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279537.990723, idle connection 217243.000000, request 304396.661043 10/02/2025 04:11:43.490 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7085 10/02/2025 04:11:43.490 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.490 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7085 (604.0995121002197 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:43.491 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:43.491 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275932.420654, idle connection 454535.000000, request 304396.336317 10/02/2025 04:11:43.491 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7018 10/02/2025 04:11:43.491 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.492 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7018 (604.0544509887695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:43.492 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:43.592 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:43.592 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:43.592 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:43.592 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:43.592 7f089f23e540 [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=584438549, session_epoch=7078, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.592 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7093 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7078, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.593 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277724.011719, idle connection 216148.000000, request 304999.925137 10/02/2025 04:11:43.593 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277723.333008, idle connection 216148.000000, request 304999.256134 10/02/2025 04:11:43.595 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277634.380859, idle connection 216551.000000, request 304398.963928 10/02/2025 04:11:43.595 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7675 10/02/2025 04:11:43.595 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.596 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7675 (601.6325950622559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:43.596 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied) 10/02/2025 04:11:43.644 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 205 10/02/2025 04:11:43.645 7f089f23e400 [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/02/2025 04:11:43.645 7f089f23e400 [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/02/2025 04:11:43.645 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:43.645 7f089f23e400 [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=885979671, session_epoch=7044, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.645 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7060 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885979671, session_epoch=7044, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.645 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275328.177734, idle connection 452696.000000, request 304999.944687 10/02/2025 04:11:43.646 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275327.739746, idle connection 452695.000000, request 304999.515772 10/02/2025 04:11:43.692 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278328.759277, idle connection 217464.000000, request 304398.897171 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8174 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8174 (601.6824245452881 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=6235, last_stable_offset=6235, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x18Z\x00\x00\x00\xfc\x00\x00\x00\x00\x02/b\x18\xdc\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\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...')])]) 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 1 response partitions (0 implied) 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 264 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 6234 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 6234 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 10/02/2025 04:11:43.693 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 6235 (leader epoch 0) 10/02/2025 04:11:43.789 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3819 10/02/2025 04:11:43.790 7f089f23ee00 [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/02/2025 04:11:43.790 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/02/2025 04:11:43.790 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:43.790 7f089f23ee00 [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=678086140, session_epoch=7593, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.790 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7608 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=678086140, session_epoch=7593, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:43.790 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277809.353516, idle connection 216827.000000, request 304999.946356 10/02/2025 04:11:43.791 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277808.939697, idle connection 216827.000000, request 304999.541521 10/02/2025 04:11:43.794 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 6235 10/02/2025 04:11:43.794 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/02/2025 04:11:43.794 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 10/02/2025 04:11:43.794 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:43.794 7f089f23e7c0 [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=1442988832, session_epoch=8162, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=6235, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/02/2025 04:11:43.794 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8175 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1442988832, session_epoch=8162, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=6235, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/02/2025 04:11:43.795 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278226.407471, idle connection 217361.000000, request 304999.958754 10/02/2025 04:11:43.795 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278226.054932, idle connection 217361.000000, request 304999.608755 10/02/2025 04:11:43.822 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278822.096436, idle connection 217298.000000, request 304398.928642 10/02/2025 04:11:43.823 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7170 10/02/2025 04:11:43.823 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:43.823 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7170 (601.5949249267578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145942367, topics=[]) 10/02/2025 04:11:43.823 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 145942367 with 0 response partitions (1 implied) 10/02/2025 04:11:44.000 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278311.466064, idle connection 217130.000000, request 304396.772861 10/02/2025 04:11:44.000 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7080 10/02/2025 04:11:44.000 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.000 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7080 (603.7595272064209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1587067153, topics=[]) 10/02/2025 04:11:44.001 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1587067153 with 0 response partitions (1 implied) 10/02/2025 04:11:44.001 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275901.493164, idle connection 454400.000000, request 304396.630287 10/02/2025 04:11:44.001 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275903.643066, idle connection 215189.000000, request 304397.503614 10/02/2025 04:11:44.001 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7120 10/02/2025 04:11:44.001 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.001 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7120 (603.785514831543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262728381, topics=[]) 10/02/2025 04:11:44.001 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1262728381 with 0 response partitions (1 implied) 10/02/2025 04:11:44.002 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7092 10/02/2025 04:11:44.002 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.002 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7092 (603.2648086547852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=563486034, topics=[]) 10/02/2025 04:11:44.002 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 563486034 with 0 response partitions (1 implied) 10/02/2025 04:11:44.032 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275941.004883, idle connection 214978.000000, request 304399.068356 10/02/2025 04:11:44.032 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7101 10/02/2025 04:11:44.032 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.032 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7101 (601.4375686645508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1550865089, topics=[]) 10/02/2025 04:11:44.032 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1550865089 with 0 response partitions (1 implied) 10/02/2025 04:11:44.092 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 295 10/02/2025 04:11:44.092 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/02/2025 04:11:44.092 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 10/02/2025 04:11:44.092 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:44.092 7f089e3be040 [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=69561686, session_epoch=7071, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.092 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7086 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=69561686, session_epoch=7071, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.093 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278935.066162, idle connection 216640.000000, request 304999.948740 10/02/2025 04:11:44.093 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278934.639648, idle connection 216639.000000, request 304999.529362 10/02/2025 04:11:44.093 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/02/2025 04:11:44.093 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/02/2025 04:11:44.093 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 10/02/2025 04:11:44.093 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:44.093 7f08a083d4a0 [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=76155561, session_epoch=6992, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.094 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7019 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=76155561, session_epoch=6992, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.094 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275329.862549, idle connection 453932.000000, request 304999.963045 10/02/2025 04:11:44.094 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275329.477783, idle connection 453932.000000, request 304999.580145 10/02/2025 04:11:44.195 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277121.765137, idle connection 215546.000000, request 304397.685051 10/02/2025 04:11:44.195 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7093 10/02/2025 04:11:44.195 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.195 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7093 (602.8542518615723 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=584438549, topics=[]) 10/02/2025 04:11:44.196 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 584438549 with 0 response partitions (1 implied) 10/02/2025 04:11:44.197 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3756 10/02/2025 04:11:44.197 7f089f23ed60 [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/02/2025 04:11:44.197 7f089f23ed60 [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/02/2025 04:11:44.197 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:44.197 7f089f23ed60 [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=803606486, session_epoch=7665, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.197 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7676 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=803606486, session_epoch=7665, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.197 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277031.914307, idle connection 215949.000000, request 304999.948978 10/02/2025 04:11:44.198 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277031.507568, idle connection 215948.000000, request 304999.547482 10/02/2025 04:11:44.246 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274727.232666, idle connection 452095.000000, request 304399.003029 10/02/2025 04:11:44.246 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7060 10/02/2025 04:11:44.246 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.247 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7060 (601.4642715454102 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885979671, topics=[]) 10/02/2025 04:11:44.247 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 885979671 with 0 response partitions (1 implied) 10/02/2025 04:11:44.392 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277207.924561, idle connection 216226.000000, request 304398.518324 10/02/2025 04:11:44.392 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7608 10/02/2025 04:11:44.392 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.392 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7608 (602.1218299865723 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=678086140, topics=[]) 10/02/2025 04:11:44.392 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 678086140 with 0 response partitions (1 implied) 10/02/2025 04:11:44.396 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277625.270508, idle connection 216760.000000, request 304398.820400 10/02/2025 04:11:44.396 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8175 10/02/2025 04:11:44.396 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.396 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8175 (601.5353202819824 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[]) 10/02/2025 04:11:44.396 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 0 response partitions (1 implied) 10/02/2025 04:11:44.423 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 647 10/02/2025 04:11:44.424 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:44.424 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:44.424 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:44.424 7f089f23e900 [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=145942367, session_epoch=7163, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.424 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7171 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7163, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.424 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278220.141113, idle connection 216696.000000, request 304999.949455 10/02/2025 04:11:44.425 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278219.735840, idle connection 216696.000000, request 304999.550104 10/02/2025 04:11:44.601 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 502 10/02/2025 04:11:44.601 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/02/2025 04:11:44.601 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:44.602 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:44.602 7f089f23e720 [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=1587067153, session_epoch=7070, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.602 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7081 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7070, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.602 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277709.236572, idle connection 216528.000000, request 304999.932528 10/02/2025 04:11:44.602 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:44.602 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:44.603 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:44.603 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:44.603 7f089f23eb80 [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=1262728381, session_epoch=7098, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.603 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7121 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7098, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.603 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275299.326904, idle connection 453798.000000, request 304999.957561 10/02/2025 04:11:44.603 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:44.603 7f089f23ea40 [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/02/2025 04:11:44.603 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:44.603 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:44.603 7f089f23ea40 [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=563486034, session_epoch=7075, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.603 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7093 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7075, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.604 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275300.917969, idle connection 214586.000000, request 304999.959230 10/02/2025 04:11:44.604 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277707.311768, idle connection 216526.000000, request 304998.019457 10/02/2025 04:11:44.604 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275297.915771, idle connection 453796.000000, request 304998.550653 10/02/2025 04:11:44.605 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275299.897217, idle connection 214585.000000, request 304998.941660 10/02/2025 04:11:44.633 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:44.633 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:44.633 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:44.633 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:44.633 7f089f23e2c0 [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=1550865089, session_epoch=7079, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.634 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7102 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7079, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.634 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275338.930908, idle connection 214376.000000, request 304999.935389 10/02/2025 04:11:44.634 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275338.379150, idle connection 214375.000000, request 304999.394894 10/02/2025 04:11:44.694 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278333.319824, idle connection 216038.000000, request 304398.189068 10/02/2025 04:11:44.695 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7086 10/02/2025 04:11:44.695 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.695 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7086 (602.5288105010986 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:44.695 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:44.696 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274727.979980, idle connection 453330.000000, request 304398.079157 10/02/2025 04:11:44.696 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7019 10/02/2025 04:11:44.696 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.696 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7019 (602.2915840148926 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:44.696 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:44.796 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:44.796 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:44.796 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:44.796 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:44.796 7f089f23e540 [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=584438549, session_epoch=7079, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.797 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7094 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7079, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.797 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276519.905762, idle connection 214944.000000, request 304999.946594 10/02/2025 04:11:44.797 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276519.433350, idle connection 214944.000000, request 304999.481916 10/02/2025 04:11:44.798 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276431.086670, idle connection 215348.000000, request 304399.126053 10/02/2025 04:11:44.799 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7676 10/02/2025 04:11:44.799 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:44.799 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7676 (601.2599468231201 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:44.799 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied) 10/02/2025 04:11:44.848 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 205 10/02/2025 04:11:44.848 7f089f23e400 [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/02/2025 04:11:44.848 7f089f23e400 [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/02/2025 04:11:44.848 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:44.849 7f089f23e400 [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=885979671, session_epoch=7045, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.849 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7061 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885979671, session_epoch=7045, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.849 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274124.450684, idle connection 451492.000000, request 304999.947548 10/02/2025 04:11:44.849 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274124.027588, idle connection 451492.000000, request 304999.531984 10/02/2025 04:11:44.993 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3819 10/02/2025 04:11:44.993 7f089f23ee00 [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/02/2025 04:11:44.994 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/02/2025 04:11:44.994 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:44.994 7f089f23ee00 [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=678086140, session_epoch=7594, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.994 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7609 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=678086140, session_epoch=7594, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.994 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276605.436768, idle connection 215623.000000, request 304999.944210 10/02/2025 04:11:44.994 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276605.034180, idle connection 215623.000000, request 304999.550104 10/02/2025 04:11:44.997 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 6235 10/02/2025 04:11:44.997 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/02/2025 04:11:44.998 7f089f23e7c0 [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)]) 10/02/2025 04:11:44.998 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:44.998 7f089f23e7c0 [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=1442988832, session_epoch=8163, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.998 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8176 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1442988832, session_epoch=8163, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:44.998 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277022.922852, idle connection 216158.000000, request 304999.959230 10/02/2025 04:11:44.998 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277022.609863, idle connection 216157.000000, request 304999.649525 10/02/2025 04:11:45.026 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277618.390625, idle connection 216094.000000, request 304398.199558 10/02/2025 04:11:45.026 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7171 10/02/2025 04:11:45.026 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.027 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7171 (602.4312973022461 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145942367, topics=[]) 10/02/2025 04:11:45.027 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 145942367 with 0 response partitions (1 implied) 10/02/2025 04:11:45.205 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277106.171875, idle connection 215925.000000, request 304396.869659 10/02/2025 04:11:45.206 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7081 10/02/2025 04:11:45.206 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.206 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7081 (603.827714920044 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1587067153, topics=[]) 10/02/2025 04:11:45.206 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1587067153 with 0 response partitions (1 implied) 10/02/2025 04:11:45.206 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274695.910889, idle connection 453194.000000, request 304396.538973 10/02/2025 04:11:45.207 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274697.970215, idle connection 213983.000000, request 304397.010565 10/02/2025 04:11:45.207 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7121 10/02/2025 04:11:45.207 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.207 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7121 (604.0339469909668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262728381, topics=[]) 10/02/2025 04:11:45.207 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1262728381 with 0 response partitions (1 implied) 10/02/2025 04:11:45.207 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7093 10/02/2025 04:11:45.208 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.208 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7093 (604.034423828125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=563486034, topics=[]) 10/02/2025 04:11:45.208 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 563486034 with 0 response partitions (1 implied) 10/02/2025 04:11:45.235 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274737.821777, idle connection 213775.000000, request 304398.830652 10/02/2025 04:11:45.235 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7102 10/02/2025 04:11:45.235 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.235 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7102 (601.7186641693115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1550865089, topics=[]) 10/02/2025 04:11:45.236 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1550865089 with 0 response partitions (1 implied) 10/02/2025 04:11:45.296 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 295 10/02/2025 04:11:45.296 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/02/2025 04:11:45.296 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 10/02/2025 04:11:45.296 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:45.297 7f089e3be040 [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=69561686, session_epoch=7072, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.297 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7087 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=69561686, session_epoch=7072, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.297 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277730.791504, idle connection 215436.000000, request 304999.947786 10/02/2025 04:11:45.297 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/02/2025 04:11:45.297 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/02/2025 04:11:45.297 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 10/02/2025 04:11:45.297 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:45.297 7f08a083d4a0 [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=76155561, session_epoch=6993, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.298 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7020 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=76155561, session_epoch=6993, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.298 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274125.867676, idle connection 452728.000000, request 304999.957800 10/02/2025 04:11:45.298 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277729.585205, idle connection 215434.000000, request 304998.750687 10/02/2025 04:11:45.298 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274125.123779, idle connection 452727.000000, request 304999.215364 10/02/2025 04:11:45.398 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275918.506592, idle connection 214343.000000, request 304398.546219 10/02/2025 04:11:45.399 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7094 10/02/2025 04:11:45.399 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.399 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7094 (602.1013259887695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=584438549, topics=[]) 10/02/2025 04:11:45.399 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 584438549 with 0 response partitions (1 implied) 10/02/2025 04:11:45.399 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3756 10/02/2025 04:11:45.399 7f089f23ed60 [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/02/2025 04:11:45.399 7f089f23ed60 [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/02/2025 04:11:45.400 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:45.400 7f089f23ed60 [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=803606486, session_epoch=7666, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.400 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7677 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=803606486, session_epoch=7666, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.400 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275829.494629, idle connection 214746.000000, request 304999.956369 10/02/2025 04:11:45.400 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275829.118164, idle connection 214746.000000, request 304999.581099 10/02/2025 04:11:45.450 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 273523.504883, idle connection 450891.000000, request 304399.001122 10/02/2025 04:11:45.450 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7061 10/02/2025 04:11:45.450 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.450 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7061 (601.5758514404297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885979671, topics=[]) 10/02/2025 04:11:45.451 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 885979671 with 0 response partitions (1 implied) 10/02/2025 04:11:45.595 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276004.128174, idle connection 215022.000000, request 304398.633480 10/02/2025 04:11:45.596 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7609 10/02/2025 04:11:45.596 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.596 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7609 (601.895809173584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=678086140, topics=[]) 10/02/2025 04:11:45.596 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 678086140 with 0 response partitions (1 implied) 10/02/2025 04:11:45.600 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276421.400146, idle connection 215556.000000, request 304398.430347 10/02/2025 04:11:45.600 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8176 10/02/2025 04:11:45.600 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.600 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8176 (601.9949913024902 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[]) 10/02/2025 04:11:45.600 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 0 response partitions (1 implied) 10/02/2025 04:11:45.627 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 647 10/02/2025 04:11:45.628 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:45.628 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:45.628 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:45.628 7f089f23e900 [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=145942367, session_epoch=7164, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.628 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7172 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7164, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.628 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277016.115967, idle connection 215492.000000, request 304999.948263 10/02/2025 04:11:45.629 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277015.684326, idle connection 215492.000000, request 304999.524355 10/02/2025 04:11:45.807 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 502 10/02/2025 04:11:45.807 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/02/2025 04:11:45.807 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:45.807 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:45.807 7f089f23e720 [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=1587067153, session_epoch=7071, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.807 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7082 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7071, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.807 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276504.018066, idle connection 215323.000000, request 304999.946117 10/02/2025 04:11:45.808 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:45.808 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:45.808 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:45.808 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:45.808 7f089f23eb80 [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=1262728381, session_epoch=7099, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.808 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7122 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7099, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.808 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274094.230225, idle connection 452593.000000, request 304999.963284 10/02/2025 04:11:45.808 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276502.966553, idle connection 215322.000000, request 304998.903036 10/02/2025 04:11:45.809 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:45.809 7f089f23ea40 [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/02/2025 04:11:45.809 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:45.809 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:45.809 7f089f23ea40 [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=563486034, session_epoch=7076, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.809 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7094 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7076, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.809 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274095.524414, idle connection 213381.000000, request 304999.964952 10/02/2025 04:11:45.809 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274092.965088, idle connection 452591.000000, request 304998.700857 10/02/2025 04:11:45.810 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274094.880859, idle connection 213380.000000, request 304999.323845 10/02/2025 04:11:45.836 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:45.836 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:45.836 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:45.836 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:45.836 7f089f23e2c0 [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=1550865089, session_epoch=7080, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.837 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7103 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7080, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:45.837 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274135.943604, idle connection 213173.000000, request 304999.949694 10/02/2025 04:11:45.837 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274135.558594, idle connection 213172.000000, request 304999.571323 10/02/2025 04:11:45.899 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277128.300293, idle connection 214833.000000, request 304397.456408 10/02/2025 04:11:45.900 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7087 10/02/2025 04:11:45.900 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.900 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7087 (603.0538082122803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:45.900 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:45.900 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 273523.275635, idle connection 452125.000000, request 304397.367239 10/02/2025 04:11:45.900 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7020 10/02/2025 04:11:45.901 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:45.901 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7020 (602.9989719390869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:45.901 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:45.999 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:45.999 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:46.000 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:46.000 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:46.000 7f089f23e540 [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=584438549, session_epoch=7080, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.000 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7095 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7080, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.000 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275316.577148, idle connection 213741.000000, request 304999.947786 10/02/2025 04:11:46.001 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275316.041992, idle connection 213740.000000, request 304999.419689 10/02/2025 04:11:46.001 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275228.508789, idle connection 214145.000000, request 304398.973227 10/02/2025 04:11:46.001 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7677 10/02/2025 04:11:46.001 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.001 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7677 (601.5157699584961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:46.001 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied) 10/02/2025 04:11:46.052 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 205 10/02/2025 04:11:46.052 7f089f23e400 [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/02/2025 04:11:46.052 7f089f23e400 [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/02/2025 04:11:46.052 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:46.052 7f089f23e400 [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=885979671, session_epoch=7046, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.053 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7062 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885979671, session_epoch=7046, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.053 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272920.625488, idle connection 450288.000000, request 304999.949455 10/02/2025 04:11:46.053 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272920.224854, idle connection 450288.000000, request 304999.556303 10/02/2025 04:11:46.197 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3819 10/02/2025 04:11:46.197 7f089f23ee00 [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/02/2025 04:11:46.197 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 10/02/2025 04:11:46.198 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:46.198 7f089f23ee00 [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=678086140, session_epoch=7595, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.198 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7610 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=678086140, session_epoch=7595, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.198 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275401.514160, idle connection 214419.000000, request 304999.946356 10/02/2025 04:11:46.198 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275401.076172, idle connection 214419.000000, request 304999.517441 10/02/2025 04:11:46.201 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 6235 10/02/2025 04:11:46.201 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/02/2025 04:11:46.202 7f089f23e7c0 [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)]) 10/02/2025 04:11:46.202 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:46.202 7f089f23e7c0 [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=1442988832, session_epoch=8164, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.202 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8177 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1442988832, session_epoch=8164, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.203 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275818.355225, idle connection 214953.000000, request 304999.955416 10/02/2025 04:11:46.203 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275818.008301, idle connection 214953.000000, request 304999.612093 10/02/2025 04:11:46.230 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276414.566162, idle connection 214890.000000, request 304398.398399 10/02/2025 04:11:46.230 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7172 10/02/2025 04:11:46.230 7f089f23e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.230 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7172 (602.1475791931152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=145942367, topics=[]) 10/02/2025 04:11:46.230 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 145942367 with 0 response partitions (1 implied) 10/02/2025 04:11:46.410 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275901.542969, idle connection 214720.000000, request 304397.468328 10/02/2025 04:11:46.410 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7082 10/02/2025 04:11:46.410 7f089f23e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.410 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7082 (603.1093597412109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1587067153, topics=[]) 10/02/2025 04:11:46.411 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1587067153 with 0 response partitions (1 implied) 10/02/2025 04:11:46.411 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 273491.488770, idle connection 451990.000000, request 304397.222042 10/02/2025 04:11:46.411 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 273493.635498, idle connection 212779.000000, request 304398.077965 10/02/2025 04:11:46.411 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7122 10/02/2025 04:11:46.411 7f089f23eb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.411 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7122 (603.2171249389648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1262728381, topics=[]) 10/02/2025 04:11:46.411 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1262728381 with 0 response partitions (1 implied) 10/02/2025 04:11:46.412 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7094 10/02/2025 04:11:46.412 7f089f23ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.412 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7094 (602.8144359588623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=563486034, topics=[]) 10/02/2025 04:11:46.412 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 563486034 with 0 response partitions (1 implied) 10/02/2025 04:11:46.438 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 273535.060303, idle connection 212572.000000, request 304399.064064 10/02/2025 04:11:46.438 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7103 10/02/2025 04:11:46.438 7f089f23e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.438 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7103 (601.4754772186279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1550865089, topics=[]) 10/02/2025 04:11:46.438 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1550865089 with 0 response partitions (1 implied) 10/02/2025 04:11:46.501 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 295 10/02/2025 04:11:46.501 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 10/02/2025 04:11:46.501 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 10/02/2025 04:11:46.501 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:46.501 7f089e3be040 [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=69561686, session_epoch=7073, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.502 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7088 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=69561686, session_epoch=7073, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.502 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276525.683594, idle connection 214230.000000, request 304999.921560 10/02/2025 04:11:46.502 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/02/2025 04:11:46.502 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 10/02/2025 04:11:46.502 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 10/02/2025 04:11:46.503 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:46.503 7f08a083d4a0 [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=76155561, session_epoch=6994, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.503 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7021 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=76155561, session_epoch=6994, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.503 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272920.444824, idle connection 451523.000000, request 304999.940157 10/02/2025 04:11:46.504 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 276523.892334, idle connection 214229.000000, request 304998.137712 10/02/2025 04:11:46.504 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272919.340332, idle connection 451521.000000, request 304998.831749 10/02/2025 04:11:46.602 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274714.862793, idle connection 213139.000000, request 304398.233891 10/02/2025 04:11:46.602 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7095 10/02/2025 04:11:46.602 7f089f23e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.602 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7095 (602.3695468902588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=584438549, topics=[]) 10/02/2025 04:11:46.603 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 584438549 with 0 response partitions (1 implied) 10/02/2025 04:11:46.603 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3756 10/02/2025 04:11:46.603 7f089f23ed60 [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/02/2025 04:11:46.603 7f089f23ed60 [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/02/2025 04:11:46.603 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:46.603 7f089f23ed60 [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=803606486, session_epoch=7667, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.603 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7678 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=803606486, session_epoch=7667, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.603 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274625.985840, idle connection 213543.000000, request 304999.955654 10/02/2025 04:11:46.604 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274625.624023, idle connection 213542.000000, request 304999.598742 10/02/2025 04:11:46.654 7f089f23e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272319.684326, idle connection 449687.000000, request 304399.007559 10/02/2025 04:11:46.654 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7062 10/02/2025 04:11:46.654 7f089f23e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.654 7f089f23e400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Response 7062 (601.5567779541016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885979671, topics=[]) 10/02/2025 04:11:46.654 7f089f23e400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 885979671 with 0 response partitions (1 implied) 10/02/2025 04:11:46.800 7f089f23ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274799.528076, idle connection 213817.000000, request 304397.960901 10/02/2025 04:11:46.800 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7610 10/02/2025 04:11:46.800 7f089f23ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.801 7f089f23ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7610 (602.5595664978027 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=678086140, topics=[]) 10/02/2025 04:11:46.801 7f089f23ee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 678086140 with 0 response partitions (1 implied) 10/02/2025 04:11:46.804 7f089f23e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275216.820557, idle connection 214352.000000, request 304398.419857 10/02/2025 04:11:46.804 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8177 10/02/2025 04:11:46.804 7f089f23e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:46.805 7f089f23e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8177 (601.9642353057861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1442988832, topics=[]) 10/02/2025 04:11:46.805 7f089f23e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1442988832 with 0 response partitions (1 implied) 10/02/2025 04:11:46.832 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 647 10/02/2025 04:11:46.832 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/02/2025 04:11:46.832 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/02/2025 04:11:46.832 7f089f23e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:46.832 7f089f23e900 [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=145942367, session_epoch=7165, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.833 7f089f23e900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7173 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=145942367, session_epoch=7165, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:46.833 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275811.584717, idle connection 214287.000000, request 304999.946594 10/02/2025 04:11:46.833 7f089f23e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275811.172363, idle connection 214287.000000, request 304999.541998 10/02/2025 04:11:47.011 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 502 10/02/2025 04:11:47.011 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 10/02/2025 04:11:47.011 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 10/02/2025 04:11:47.011 7f089f23e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:47.011 7f089f23e720 [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=1587067153, session_epoch=7072, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.012 7f089f23e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7083 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1587067153, session_epoch=7072, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.012 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275299.633545, idle connection 214118.000000, request 304999.947786 10/02/2025 04:11:47.012 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 424 10/02/2025 04:11:47.012 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 10/02/2025 04:11:47.012 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 10/02/2025 04:11:47.012 7f089f23eb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:47.012 7f089f23eb80 [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=1262728381, session_epoch=7100, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.012 7f089f23eb80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7123 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1262728381, session_epoch=7100, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.012 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272889.825439, idle connection 451388.000000, request 304999.961615 10/02/2025 04:11:47.013 7f089f23e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275298.552979, idle connection 214117.000000, request 304998.875380 10/02/2025 04:11:47.013 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 10/02/2025 04:11:47.013 7f089f23ea40 [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/02/2025 04:11:47.013 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 10/02/2025 04:11:47.013 7f089f23ea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/02/2025 04:11:47.013 7f089f23ea40 [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=563486034, session_epoch=7077, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.013 7f089f23ea40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7095 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=563486034, session_epoch=7077, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.013 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272891.107178, idle connection 212176.000000, request 304999.966860 10/02/2025 04:11:47.014 7f089f23eb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272888.537354, idle connection 451387.000000, request 304998.678207 10/02/2025 04:11:47.014 7f089f23ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272890.437012, idle connection 212176.000000, request 304999.298811 10/02/2025 04:11:47.039 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 641 10/02/2025 04:11:47.039 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/02/2025 04:11:47.039 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/02/2025 04:11:47.039 7f089f23e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/02/2025 04:11:47.039 7f089f23e2c0 [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=1550865089, session_epoch=7081, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.039 7f089f23e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 7104 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1550865089, session_epoch=7081, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.039 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272933.346191, idle connection 211970.000000, request 304999.955177 10/02/2025 04:11:47.040 7f089f23e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272932.994385, idle connection 211970.000000, request 304999.609232 10/02/2025 04:11:47.105 7f089e3be040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 275922.867920, idle connection 213628.000000, request 304397.113800 10/02/2025 04:11:47.105 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7088 10/02/2025 04:11:47.105 7f089e3be040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:47.105 7f089e3be040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7088 (603.4305095672607 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=69561686, topics=[]) 10/02/2025 04:11:47.105 7f089e3be040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 69561686 with 0 response partitions (1 implied) 10/02/2025 04:11:47.106 7f08a083d4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 272317.871582, idle connection 450920.000000, request 304397.375584 10/02/2025 04:11:47.106 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7021 10/02/2025 04:11:47.106 7f08a083d4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:47.106 7f08a083d4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 7021 (602.9794216156006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=76155561, topics=[]) 10/02/2025 04:11:47.106 7f08a083d4a0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 76155561 with 0 response partitions (1 implied) 10/02/2025 04:11:47.203 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 349 10/02/2025 04:11:47.203 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/02/2025 04:11:47.203 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/02/2025 04:11:47.203 7f089f23e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/02/2025 04:11:47.203 7f089f23e540 [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=584438549, session_epoch=7081, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.203 7f089f23e540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.49', 9092)]>: Request 7096 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=584438549, session_epoch=7081, topics=[], forgotten_topics_data=[]) 10/02/2025 04:11:47.204 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274112.984619, idle connection 212537.000000, request 304999.948502 10/02/2025 04:11:47.204 7f089f23e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274112.581055, idle connection 212537.000000, request 304999.553442 10/02/2025 04:11:47.204 7f089f23ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 274025.160400, idle connection 212942.000000, request 304399.134159 10/02/2025 04:11:47.205 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7678 10/02/2025 04:11:47.205 7f089f23ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/02/2025 04:11:47.205 7f089f23ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7678 (601.3305187225342 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=803606486, topics=[]) 10/02/2025 04:11:47.205 7f089f23ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 803606486 with 0 response partitions (1 implied)