03/26/2026 02:13:42.551 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 03/26/2026 02:13:42.551 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 03/26/2026 02:13:42.552 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.552 7fbb9053e5e0 [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=1678156831, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.552 7fbb9053e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1678156831, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.552 7fbb9053e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280130.334961, idle connection 218488.000000, request 304999.961853 03/26/2026 02:13:42.552 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 245 03/26/2026 02:13:42.552 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 03/26/2026 02:13:42.552 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 03/26/2026 02:13:42.552 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.552 7fbb90d6a540 [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=1334155973, session_epoch=296, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.552 7fbb90d6a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 299 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1334155973, session_epoch=296, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.552 7fbb90d6a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280628.080566, idle connection 218808.000000, request 304999.969244 03/26/2026 02:13:42.553 7fbb9053e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280129.467041, idle connection 218487.000000, request 304999.096870 03/26/2026 02:13:42.553 7fbb90d6a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280627.522461, idle connection 218807.000000, request 304999.413013 03/26/2026 02:13:42.598 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 205 03/26/2026 02:13:42.599 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 03/26/2026 02:13:42.599 7fbb9174fae0 [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)]) 03/26/2026 02:13:42.599 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.599 7fbb9174fae0 [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=1680813061, session_epoch=292, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.599 7fbb9174fae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 295 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1680813061, session_epoch=292, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.599 7fbb9174fae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279435.861816, idle connection 218686.000000, request 304999.954939 03/26/2026 02:13:42.599 7fbb9174fae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279435.499268, idle connection 218686.000000, request 304999.598503 03/26/2026 02:13:42.606 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 58 03/26/2026 02:13:42.606 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 03/26/2026 02:13:42.606 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 03/26/2026 02:13:42.606 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.606 7fbb9174f5e0 [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=1892731767, session_epoch=278, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.606 7fbb9174f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 281 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1892731767, session_epoch=278, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.606 7fbb9174f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279459.775635, idle connection 218554.000000, request 304999.959946 03/26/2026 02:13:42.606 7fbb8e6bb720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279551.171143, idle connection 218446.000000, request 304397.084236 03/26/2026 02:13:42.607 7fbb9174f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279459.327393, idle connection 218553.000000, request 304999.515772 03/26/2026 02:13:42.607 7fbb8e6bb720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:42.607 7fbb8e6bb720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.607 7fbb8e6bb720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (603.518009185791 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=247326985, topics=[]) 03/26/2026 02:13:42.607 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 247326985 with 0 response partitions (1 implied) 03/26/2026 02:13:42.623 7fbb9053e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279555.218262, idle connection 218425.000000, request 304399.132490 03/26/2026 02:13:42.624 7fbb9053e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/26/2026 02:13:42.624 7fbb9053e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.624 7fbb9053e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 271 (601.2318134307861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2074756401, topics=[]) 03/26/2026 02:13:42.624 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2074756401 with 0 response partitions (1 implied) 03/26/2026 02:13:42.709 7fbb90d6a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279334.333984, idle connection 218629.000000, request 304398.036957 03/26/2026 02:13:42.710 7fbb90d6a180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 03/26/2026 02:13:42.710 7fbb90d6a180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.710 7fbb90d6a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 286 (602.4668216705322 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=288163504, topics=[]) 03/26/2026 02:13:42.710 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 288163504 with 0 response partitions (1 implied) 03/26/2026 02:13:42.710 7fbb90d6a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279543.293213, idle connection 218613.000000, request 304398.016214 03/26/2026 02:13:42.710 7fbb90d6a040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 03/26/2026 02:13:42.710 7fbb90d6a040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.710 7fbb90d6a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 286 (602.2648811340332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=139656969, topics=[]) 03/26/2026 02:13:42.711 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 139656969 with 0 response partitions (1 implied) 03/26/2026 02:13:42.723 7fbb9174f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279554.170410, idle connection 218553.000000, request 304398.899078 03/26/2026 02:13:42.723 7fbb9174f900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 03/26/2026 02:13:42.723 7fbb9174f900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.723 7fbb9174f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 285 (601.529598236084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1376305268, topics=[]) 03/26/2026 02:13:42.723 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1376305268 with 0 response partitions (1 implied) 03/26/2026 02:13:42.806 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 40 03/26/2026 02:13:42.807 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 03/26/2026 02:13:42.807 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 03/26/2026 02:13:42.807 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.807 7fbb9174f400 [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=657121762, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.807 7fbb9174f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 278 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=657121762, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.807 7fbb9174f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279449.151123, idle connection 218399.000000, request 304999.950647 03/26/2026 02:13:42.807 7fbb9174f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279448.746582, idle connection 218399.000000, request 304999.552011 03/26/2026 02:13:42.814 7fbb9174f2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279447.671387, idle connection 218319.000000, request 304399.152279 03/26/2026 02:13:42.814 7fbb9174f2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 03/26/2026 02:13:42.814 7fbb9174f2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.814 7fbb9174f2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 277 (601.207971572876 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1476544711, topics=[]) 03/26/2026 02:13:42.815 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1476544711 with 0 response partitions (1 implied) 03/26/2026 02:13:42.815 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 49 03/26/2026 02:13:42.815 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 03/26/2026 02:13:42.815 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 03/26/2026 02:13:42.815 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.815 7fbb9174f860 [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=139810478, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.815 7fbb9174f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 282 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=139810478, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.815 7fbb9174f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279442.604492, idle connection 218360.000000, request 304999.965668 03/26/2026 02:13:42.816 7fbb9174f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279442.301758, idle connection 218359.000000, request 304999.664783 03/26/2026 02:13:42.818 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 214 03/26/2026 02:13:42.818 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 03/26/2026 02:13:42.818 7fbb90d6aae0 [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)]) 03/26/2026 02:13:42.818 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.818 7fbb90d6aae0 [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=1521128298, session_epoch=300, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.818 7fbb90d6aae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 303 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1521128298, session_epoch=300, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.818 7fbb90d6aae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279445.007324, idle connection 218617.000000, request 304999.963760 03/26/2026 02:13:42.818 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/26/2026 02:13:42.818 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 03/26/2026 02:13:42.818 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 03/26/2026 02:13:42.818 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.818 7fbb92300b80 [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=742834469, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.819 7fbb92300b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 269 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742834469, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.819 7fbb92300b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278954.147217, idle connection 218109.000000, request 304999.967813 03/26/2026 02:13:42.819 7fbb90d6aae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279444.129883, idle connection 218616.000000, request 304999.088049 03/26/2026 02:13:42.819 7fbb92300b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278953.611328, idle connection 218109.000000, request 304999.433279 03/26/2026 02:13:42.822 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/26/2026 02:13:42.822 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 03/26/2026 02:13:42.822 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 03/26/2026 02:13:42.822 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.822 7fbb8e6e20e0 [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=885575508, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.822 7fbb8e6e20e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 269 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885575508, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.823 7fbb8e6e20e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.326172, idle connection 218168.000000, request 304999.965429 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [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=776967202, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 269 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776967202, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.823 7fbb8e6bb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278953.147949, idle connection 218263.000000, request 304999.968529 03/26/2026 02:13:42.823 7fbb8e6e20e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278951.474854, idle connection 218167.000000, request 304999.115944 03/26/2026 02:13:42.824 7fbb8e6bb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.595215, idle connection 218262.000000, request 304999.417782 03/26/2026 02:13:42.834 7fbb9174f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280042.433594, idle connection 218309.000000, request 304398.453712 03/26/2026 02:13:42.834 7fbb9174f4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 03/26/2026 02:13:42.834 7fbb9174f4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.834 7fbb9174f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 276 (601.879358291626 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1846967730, topics=[]) 03/26/2026 02:13:42.834 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1846967730 with 0 response partitions (1 implied) 03/26/2026 02:13:42.834 7fbb9174fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279346.012451, idle connection 218476.000000, request 304398.480177 03/26/2026 02:13:42.835 7fbb9174fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 03/26/2026 02:13:42.835 7fbb9174fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:42.835 7fbb9174fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 288 (601.8052101135254 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1970678087, topics=[]) 03/26/2026 02:13:42.835 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1970678087 with 0 response partitions (1 implied) 03/26/2026 02:13:42.958 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 03/26/2026 02:13:42.959 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 03/26/2026 02:13:42.959 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 03/26/2026 02:13:42.959 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.959 7fbb923009a0 [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=341095875, session_epoch=278, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.959 7fbb923009a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 281 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=341095875, session_epoch=278, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.959 7fbb923009a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278917.956299, idle connection 217967.000000, request 304999.951601 03/26/2026 02:13:42.959 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 33 03/26/2026 02:13:42.959 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 03/26/2026 02:13:42.959 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 03/26/2026 02:13:42.959 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.960 7fbb9174fc20 [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=879276820, session_epoch=273, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.960 7fbb9174fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879276820, session_epoch=273, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.960 7fbb9174fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278919.673340, idle connection 218273.000000, request 304999.965668 03/26/2026 02:13:42.960 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 1 03/26/2026 02:13:42.960 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 03/26/2026 02:13:42.960 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 03/26/2026 02:13:42.960 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:42.960 7fbb9053e9a0 [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=1593155826, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.960 7fbb9053e9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593155826, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:42.960 7fbb9053e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278920.576416, idle connection 218050.000000, request 304999.968767 03/26/2026 02:13:42.961 7fbb923009a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278916.389893, idle connection 217966.000000, request 304998.393297 03/26/2026 02:13:42.961 7fbb9174fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278918.470459, idle connection 218272.000000, request 304998.765945 03/26/2026 02:13:42.961 7fbb9053e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278919.711670, idle connection 218049.000000, request 304999.107122 03/26/2026 02:13:43.002 7fbb90d6a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279546.641846, idle connection 218347.000000, request 304399.126530 03/26/2026 02:13:43.003 7fbb90d6a400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 03/26/2026 02:13:43.003 7fbb90d6a400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.003 7fbb90d6a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 294 (601.3343334197998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=849958729, topics=[]) 03/26/2026 02:13:43.003 7fbb90d6a400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 849958729 with 0 response partitions (1 implied) 03/26/2026 02:13:43.058 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 2 03/26/2026 02:13:43.058 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 03/26/2026 02:13:43.058 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 03/26/2026 02:13:43.058 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.058 7fbb92300d60 [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=1319558908, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.058 7fbb92300d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1319558908, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.058 7fbb92300d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278917.885742, idle connection 218038.000000, request 304999.952316 03/26/2026 02:13:43.059 7fbb9174ff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279425.219971, idle connection 218197.000000, request 304397.847414 03/26/2026 02:13:43.059 7fbb92300d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278917.354248, idle connection 218037.000000, request 304999.429703 03/26/2026 02:13:43.059 7fbb9174ff40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 03/26/2026 02:13:43.059 7fbb9174ff40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.059 7fbb9174ff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 296 (602.7882099151611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1210270230, topics=[]) 03/26/2026 02:13:43.059 7fbb9174ff40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1210270230 with 0 response partitions (1 implied) 03/26/2026 02:13:43.060 7fbb90d6a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280060.142334, idle connection 218276.000000, request 304398.489475 03/26/2026 02:13:43.060 7fbb90d6a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 03/26/2026 02:13:43.060 7fbb90d6a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.060 7fbb90d6a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 293 (601.8693447113037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=541706597, topics=[]) 03/26/2026 02:13:43.060 7fbb90d6a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 541706597 with 0 response partitions (1 implied) 03/26/2026 02:13:43.074 7fbb923007c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278508.625977, idle connection 217848.000000, request 304399.312496 03/26/2026 02:13:43.074 7fbb923007c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 412 03/26/2026 02:13:43.075 7fbb923007c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.075 7fbb923007c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 412 (601.1312007904053 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=174060836, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4255, last_stable_offset=4255, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10\x9e\x00\x00\x01\x05\x00\x00\x00\x00\x029m\x0e\xbd\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/26/2026 02:13:43.075 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 174060836 with 1 response partitions (0 implied) 03/26/2026 02:13:43.075 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4254 03/26/2026 02:13:43.075 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4254 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 03/26/2026 02:13:43.075 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4255 (leader epoch 0) 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [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=454738816, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=454738816, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.141 7fbb8e6bb5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278900.952637, idle connection 217938.000000, request 304999.950171 03/26/2026 02:13:43.142 7fbb8e6bb5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278900.550781, idle connection 217938.000000, request 304999.555111 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.147 7fbb92300cc0 [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=1046831045, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 277 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1046831045, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278931.388428, idle connection 217974.000000, request 304999.964237 03/26/2026 02:13:43.147 7fbb92300cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278931.087891, idle connection 217974.000000, request 304999.666452 03/26/2026 02:13:43.150 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 52 03/26/2026 02:13:43.150 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 03/26/2026 02:13:43.150 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 03/26/2026 02:13:43.150 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.150 7fbb9174f720 [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=428853525, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.150 7fbb9174f720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 282 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=428853525, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.150 7fbb9174f720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279433.510010, idle connection 218037.000000, request 304999.963522 03/26/2026 02:13:43.150 7fbb9053e4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279496.904297, idle connection 217850.000000, request 304398.023605 03/26/2026 02:13:43.151 7fbb9174f720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279433.076904, idle connection 218036.000000, request 304999.532461 03/26/2026 02:13:43.151 7fbb9053e4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:43.151 7fbb9053e4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.151 7fbb9053e4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (602.5600433349609 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098641316, topics=[]) 03/26/2026 02:13:43.151 7fbb9053e4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098641316 with 0 response partitions (1 implied) 03/26/2026 02:13:43.154 7fbb9053e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279527.948242, idle connection 217886.000000, request 304397.576571 03/26/2026 02:13:43.154 7fbb9053e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/26/2026 02:13:43.155 7fbb9053e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.155 7fbb9053e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 271 (602.7324199676514 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1678156831, topics=[]) 03/26/2026 02:13:43.155 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1678156831 with 0 response partitions (1 implied) 03/26/2026 02:13:43.155 7fbb90d6a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280025.681152, idle connection 218205.000000, request 304397.570372 03/26/2026 02:13:43.155 7fbb90d6a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 03/26/2026 02:13:43.155 7fbb90d6a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.155 7fbb90d6a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 299 (602.7016639709473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1334155973, topics=[]) 03/26/2026 02:13:43.155 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1334155973 with 0 response partitions (1 implied) 03/26/2026 02:13:43.176 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4255 03/26/2026 02:13:43.176 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 03/26/2026 02:13:43.176 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 03/26/2026 02:13:43.176 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.176 7fbb923007c0 [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=174060836, session_epoch=410, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4255, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/26/2026 02:13:43.176 7fbb923007c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 413 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=174060836, session_epoch=410, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4255, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/26/2026 02:13:43.176 7fbb923007c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278406.462646, idle connection 217745.000000, request 304999.954700 03/26/2026 02:13:43.177 7fbb923007c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278406.100830, idle connection 217745.000000, request 304999.598742 03/26/2026 02:13:43.200 7fbb9174fae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278835.138672, idle connection 218086.000000, request 304399.233341 03/26/2026 02:13:43.200 7fbb9174fae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 03/26/2026 02:13:43.200 7fbb9174fae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.200 7fbb9174fae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 295 (601.2094020843506 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1680813061, topics=[]) 03/26/2026 02:13:43.200 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1680813061 with 0 response partitions (1 implied) 03/26/2026 02:13:43.207 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 03/26/2026 02:13:43.207 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 03/26/2026 02:13:43.207 7fbb8e6bb720 [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)]) 03/26/2026 02:13:43.207 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.208 7fbb8e6bb720 [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=247326985, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.208 7fbb8e6bb720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247326985, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.208 7fbb8e6bb720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278949.679443, idle connection 217845.000000, request 304999.949932 03/26/2026 02:13:43.208 7fbb9174f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278857.891113, idle connection 217952.000000, request 304398.077965 03/26/2026 02:13:43.208 7fbb8e6bb720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278949.206543, idle connection 217844.000000, request 304999.481440 03/26/2026 02:13:43.208 7fbb9174f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 03/26/2026 02:13:43.208 7fbb9174f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.209 7fbb9174f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 281 (602.5102138519287 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1892731767, topics=[]) 03/26/2026 02:13:43.209 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1892731767 with 0 response partitions (1 implied) 03/26/2026 02:13:43.225 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4 03/26/2026 02:13:43.225 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 03/26/2026 02:13:43.225 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 03/26/2026 02:13:43.225 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.225 7fbb9053e720 [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=2074756401, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.226 7fbb9053e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 272 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2074756401, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.226 7fbb9053e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.915283, idle connection 217823.000000, request 304999.953270 03/26/2026 02:13:43.226 7fbb9053e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.550293, idle connection 217822.000000, request 304999.593973 03/26/2026 02:13:43.310 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 108 03/26/2026 02:13:43.310 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 03/26/2026 02:13:43.311 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 03/26/2026 02:13:43.311 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.311 7fbb90d6a180 [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=288163504, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.311 7fbb90d6a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 287 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=288163504, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.311 7fbb90d6a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278732.612793, idle connection 218027.000000, request 304999.946833 03/26/2026 02:13:43.311 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 91 03/26/2026 02:13:43.311 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 03/26/2026 02:13:43.311 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 03/26/2026 02:13:43.311 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.312 7fbb90d6a040 [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=139656969, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.312 7fbb90d6a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 287 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=139656969, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.312 7fbb90d6a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278941.694580, idle connection 218011.000000, request 304999.940157 03/26/2026 02:13:43.312 7fbb90d6a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278731.280029, idle connection 218026.000000, request 304998.623610 03/26/2026 02:13:43.313 7fbb90d6a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278940.768799, idle connection 218010.000000, request 304999.022722 03/26/2026 02:13:43.324 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 145 03/26/2026 02:13:43.324 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 03/26/2026 02:13:43.324 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 03/26/2026 02:13:43.324 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.324 7fbb9174f900 [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=1376305268, session_epoch=283, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.324 7fbb9174f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 286 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1376305268, session_epoch=283, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.324 7fbb9174f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.597900, idle connection 217952.000000, request 304999.955893 03/26/2026 02:13:43.325 7fbb9174f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.246582, idle connection 217951.000000, request 304999.609470 03/26/2026 02:13:43.408 7fbb9174f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278848.258057, idle connection 217798.000000, request 304399.057388 03/26/2026 02:13:43.408 7fbb9174f400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 03/26/2026 02:13:43.408 7fbb9174f400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.408 7fbb9174f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 278 (601.438045501709 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=657121762, topics=[]) 03/26/2026 02:13:43.409 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 657121762 with 0 response partitions (1 implied) 03/26/2026 02:13:43.415 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38 03/26/2026 02:13:43.415 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 03/26/2026 02:13:43.415 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 03/26/2026 02:13:43.415 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.415 7fbb9174f2c0 [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=1476544711, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.415 7fbb9174f2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 278 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1476544711, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.415 7fbb9174f2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278846.375488, idle connection 217718.000000, request 304999.957561 03/26/2026 02:13:43.416 7fbb9174f2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278846.011475, idle connection 217718.000000, request 304999.598026 03/26/2026 02:13:43.416 7fbb9174f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278841.856934, idle connection 217759.000000, request 304399.213314 03/26/2026 02:13:43.416 7fbb9174f860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 03/26/2026 02:13:43.416 7fbb9174f860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.416 7fbb9174f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 282 (601.212739944458 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=139810478, topics=[]) 03/26/2026 02:13:43.417 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 139810478 with 0 response partitions (1 implied) 03/26/2026 02:13:43.419 7fbb90d6aae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278843.608643, idle connection 218016.000000, request 304398.564339 03/26/2026 02:13:43.420 7fbb90d6aae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 03/26/2026 02:13:43.420 7fbb90d6aae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.420 7fbb90d6aae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 303 (601.7863750457764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1521128298, topics=[]) 03/26/2026 02:13:43.420 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1521128298 with 0 response partitions (1 implied) 03/26/2026 02:13:43.420 7fbb92300b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278352.704346, idle connection 217508.000000, request 304398.525238 03/26/2026 02:13:43.420 7fbb92300b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/26/2026 02:13:43.420 7fbb92300b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.420 7fbb92300b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 269 (601.7837524414062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=742834469, topics=[]) 03/26/2026 02:13:43.421 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 742834469 with 0 response partitions (1 implied) 03/26/2026 02:13:43.424 7fbb8e6e20e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278350.910645, idle connection 217567.000000, request 304398.548841 03/26/2026 02:13:43.424 7fbb8e6e20e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/26/2026 02:13:43.424 7fbb8e6e20e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.424 7fbb8e6e20e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 269 (601.7723083496094 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885575508, topics=[]) 03/26/2026 02:13:43.424 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 885575508 with 0 response partitions (1 implied) 03/26/2026 02:13:43.425 7fbb8e6bb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278351.709473, idle connection 217661.000000, request 304398.530245 03/26/2026 02:13:43.425 7fbb8e6bb7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/26/2026 02:13:43.425 7fbb8e6bb7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.425 7fbb8e6bb7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 269 (601.7622947692871 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=776967202, topics=[]) 03/26/2026 02:13:43.425 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 776967202 with 0 response partitions (1 implied) 03/26/2026 02:13:43.435 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 35 03/26/2026 02:13:43.435 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 03/26/2026 02:13:43.436 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 03/26/2026 02:13:43.436 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.436 7fbb9174f4a0 [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=1846967730, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.436 7fbb9174f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 277 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1846967730, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.436 7fbb9174f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279440.237061, idle connection 217707.000000, request 304999.957800 03/26/2026 02:13:43.436 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 172 03/26/2026 02:13:43.436 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 03/26/2026 02:13:43.436 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 03/26/2026 02:13:43.436 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.436 7fbb9174fcc0 [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=1970678087, session_epoch=286, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.436 7fbb9174fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 289 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1970678087, session_epoch=286, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.437 7fbb9174fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278743.827637, idle connection 217874.000000, request 304999.967575 03/26/2026 02:13:43.437 7fbb9174f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279439.158936, idle connection 217706.000000, request 304998.883009 03/26/2026 02:13:43.437 7fbb9174fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278743.076416, idle connection 217873.000000, request 304999.218225 03/26/2026 02:13:43.562 7fbb923009a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278315.443115, idle connection 217365.000000, request 304397.434711 03/26/2026 02:13:43.562 7fbb923009a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 03/26/2026 02:13:43.562 7fbb923009a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.562 7fbb923009a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 281 (603.217601776123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=341095875, topics=[]) 03/26/2026 02:13:43.562 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 341095875 with 0 response partitions (1 implied) 03/26/2026 02:13:43.563 7fbb9174fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278316.694336, idle connection 217670.000000, request 304396.984339 03/26/2026 02:13:43.563 7fbb9053e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278317.986816, idle connection 217447.000000, request 304397.377729 03/26/2026 02:13:43.563 7fbb9174fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 03/26/2026 02:13:43.563 7fbb9174fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.563 7fbb9174fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 276 (603.5699844360352 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=879276820, topics=[]) 03/26/2026 02:13:43.563 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 879276820 with 0 response partitions (1 implied) 03/26/2026 02:13:43.564 7fbb9053e9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:43.564 7fbb9053e9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.564 7fbb9053e9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (603.4269332885742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1593155826, topics=[]) 03/26/2026 02:13:43.564 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1593155826 with 0 response partitions (1 implied) 03/26/2026 02:13:43.603 7fbb90d6a400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 215 03/26/2026 02:13:43.604 7fbb90d6a400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 03/26/2026 02:13:43.604 7fbb90d6a400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 03/26/2026 02:13:43.604 7fbb90d6a400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.604 7fbb90d6a400 [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=849958729, session_epoch=292, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.604 7fbb90d6a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 295 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=849958729, session_epoch=292, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.604 7fbb90d6a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278944.994385, idle connection 217746.000000, request 304999.950886 03/26/2026 02:13:43.604 7fbb90d6a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278944.587402, idle connection 217745.000000, request 304999.550104 03/26/2026 02:13:43.660 7fbb9174ff40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247 03/26/2026 02:13:43.660 7fbb9174ff40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 03/26/2026 02:13:43.660 7fbb9174ff40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 03/26/2026 02:13:43.660 7fbb9174ff40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.660 7fbb9174ff40 [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=1210270230, session_epoch=294, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.660 7fbb9174ff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 297 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1210270230, session_epoch=294, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.660 7fbb9174ff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278823.443115, idle connection 217596.000000, request 304999.949932 03/26/2026 02:13:43.661 7fbb92300d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278315.633545, idle connection 217436.000000, request 304397.705793 03/26/2026 02:13:43.661 7fbb90d6a360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 182 03/26/2026 02:13:43.661 7fbb90d6a360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 03/26/2026 02:13:43.661 7fbb90d6a360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 03/26/2026 02:13:43.661 7fbb90d6a360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.661 7fbb90d6a360 [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=541706597, session_epoch=291, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.661 7fbb90d6a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 294 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=541706597, session_epoch=291, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.661 7fbb90d6a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279458.442627, idle connection 217674.000000, request 304999.965668 03/26/2026 02:13:43.662 7fbb9174ff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278822.241943, idle connection 217594.000000, request 304998.757124 03/26/2026 02:13:43.662 7fbb92300d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:43.662 7fbb92300d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.662 7fbb92300d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (603.7070751190186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1319558908, topics=[]) 03/26/2026 02:13:43.662 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1319558908 with 0 response partitions (1 implied) 03/26/2026 02:13:43.663 7fbb90d6a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279457.098633, idle connection 217673.000000, request 304998.621702 03/26/2026 02:13:43.743 7fbb8e6bb5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278299.626953, idle connection 217337.000000, request 304398.616314 03/26/2026 02:13:43.743 7fbb8e6bb5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:43.743 7fbb8e6bb5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.743 7fbb8e6bb5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (601.9842624664307 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=454738816, topics=[]) 03/26/2026 02:13:43.743 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 454738816 with 0 response partitions (1 implied) 03/26/2026 02:13:43.749 7fbb92300cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278329.789795, idle connection 217373.000000, request 304398.364305 03/26/2026 02:13:43.749 7fbb92300cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 03/26/2026 02:13:43.749 7fbb92300cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.749 7fbb92300cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 277 (601.9792556762695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1046831045, topics=[]) 03/26/2026 02:13:43.749 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1046831045 with 0 response partitions (1 implied) 03/26/2026 02:13:43.752 7fbb9053e4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 3 03/26/2026 02:13:43.752 7fbb9053e4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 03/26/2026 02:13:43.752 7fbb9053e4a0 [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)]) 03/26/2026 02:13:43.752 7fbb9053e4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.752 7fbb9053e4a0 [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=1098641316, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.752 7fbb9053e4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098641316, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.752 7fbb9053e4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278895.010986, idle connection 217248.000000, request 304999.959707 03/26/2026 02:13:43.752 7fbb9174f720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278831.224609, idle connection 217434.000000, request 304397.678852 03/26/2026 02:13:43.753 7fbb9053e4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278894.524902, idle connection 217248.000000, request 304999.477625 03/26/2026 02:13:43.753 7fbb9174f720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 03/26/2026 02:13:43.753 7fbb9174f720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.753 7fbb9174f720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 282 (602.9376983642578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=428853525, topics=[]) 03/26/2026 02:13:43.753 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 428853525 with 0 response partitions (1 implied) 03/26/2026 02:13:43.756 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 4 03/26/2026 02:13:43.756 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 03/26/2026 02:13:43.756 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 03/26/2026 02:13:43.756 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.756 7fbb9053e5e0 [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=1678156831, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.756 7fbb9053e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 272 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1678156831, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.756 7fbb9053e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278925.897949, idle connection 217284.000000, request 304999.965191 03/26/2026 02:13:43.756 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 245 03/26/2026 02:13:43.757 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 03/26/2026 02:13:43.757 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 03/26/2026 02:13:43.757 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.757 7fbb90d6a540 [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=1334155973, session_epoch=297, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.757 7fbb90d6a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 300 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1334155973, session_epoch=297, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.757 7fbb90d6a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279423.609619, idle connection 217603.000000, request 304999.965906 03/26/2026 02:13:43.757 7fbb9053e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278924.982666, idle connection 217283.000000, request 304999.052048 03/26/2026 02:13:43.757 7fbb90d6a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279423.061279, idle connection 217603.000000, request 304999.420881 03/26/2026 02:13:43.778 7fbb923007c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277804.613281, idle connection 217144.000000, request 304398.101568 03/26/2026 02:13:43.779 7fbb923007c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 413 03/26/2026 02:13:43.779 7fbb923007c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.779 7fbb923007c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 413 (602.5030612945557 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=174060836, topics=[]) 03/26/2026 02:13:43.779 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 174060836 with 0 response partitions (1 implied) 03/26/2026 02:13:43.801 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 205 03/26/2026 02:13:43.801 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 03/26/2026 02:13:43.802 7fbb9174fae0 [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)]) 03/26/2026 02:13:43.802 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.802 7fbb9174fae0 [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=1680813061, session_epoch=293, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.802 7fbb9174fae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 296 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1680813061, session_epoch=293, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.802 7fbb9174fae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278232.996582, idle connection 217484.000000, request 304999.953270 03/26/2026 02:13:43.802 7fbb9174fae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278232.619629, idle connection 217483.000000, request 304999.582291 03/26/2026 02:13:43.809 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 58 03/26/2026 02:13:43.809 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 03/26/2026 02:13:43.809 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 03/26/2026 02:13:43.809 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:43.809 7fbb9174f5e0 [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=1892731767, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.809 7fbb9174f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 282 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1892731767, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:43.810 7fbb9174f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278256.329102, idle connection 217350.000000, request 304999.962330 03/26/2026 02:13:43.810 7fbb8e6bb720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278347.724609, idle connection 217243.000000, request 304397.998571 03/26/2026 02:13:43.810 7fbb9174f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278255.866943, idle connection 217350.000000, request 304999.503374 03/26/2026 02:13:43.810 7fbb8e6bb720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/26/2026 02:13:43.810 7fbb8e6bb720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.810 7fbb8e6bb720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 271 (602.602481842041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=247326985, topics=[]) 03/26/2026 02:13:43.810 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 247326985 with 0 response partitions (1 implied) 03/26/2026 02:13:43.826 7fbb9053e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278352.212891, idle connection 217222.000000, request 304399.254799 03/26/2026 02:13:43.827 7fbb9053e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 03/26/2026 02:13:43.827 7fbb9053e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.827 7fbb9053e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 272 (601.1149883270264 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2074756401, topics=[]) 03/26/2026 02:13:43.827 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2074756401 with 0 response partitions (1 implied) 03/26/2026 02:13:43.913 7fbb90d6a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278130.509277, idle connection 217425.000000, request 304397.844791 03/26/2026 02:13:43.914 7fbb90d6a180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 03/26/2026 02:13:43.914 7fbb90d6a180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.914 7fbb90d6a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 287 (602.6475429534912 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=288163504, topics=[]) 03/26/2026 02:13:43.914 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 288163504 with 0 response partitions (1 implied) 03/26/2026 02:13:43.914 7fbb90d6a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278339.445801, idle connection 217409.000000, request 304397.697687 03/26/2026 02:13:43.914 7fbb90d6a040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 03/26/2026 02:13:43.914 7fbb90d6a040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.914 7fbb90d6a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 287 (602.5857925415039 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=139656969, topics=[]) 03/26/2026 02:13:43.914 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 139656969 with 0 response partitions (1 implied) 03/26/2026 02:13:43.925 7fbb9174f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278351.614014, idle connection 217351.000000, request 304398.973703 03/26/2026 02:13:43.926 7fbb9174f900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 03/26/2026 02:13:43.926 7fbb9174f900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:43.926 7fbb9174f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 286 (601.3836860656738 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1376305268, topics=[]) 03/26/2026 02:13:43.926 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1376305268 with 0 response partitions (1 implied) 03/26/2026 02:13:44.009 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 40 03/26/2026 02:13:44.009 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 03/26/2026 02:13:44.009 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 03/26/2026 02:13:44.009 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.009 7fbb9174f400 [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=657121762, session_epoch=276, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.010 7fbb9174f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 279 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=657121762, session_epoch=276, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.010 7fbb9174f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278246.530029, idle connection 217196.000000, request 304999.951839 03/26/2026 02:13:44.010 7fbb9174f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278246.131836, idle connection 217196.000000, request 304999.560118 03/26/2026 02:13:44.016 7fbb9174f2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278245.432373, idle connection 217117.000000, request 304399.017811 03/26/2026 02:13:44.017 7fbb9174f2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 03/26/2026 02:13:44.017 7fbb9174f2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.017 7fbb9174f2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 278 (601.3386249542236 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1476544711, topics=[]) 03/26/2026 02:13:44.017 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1476544711 with 0 response partitions (1 implied) 03/26/2026 02:13:44.017 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 49 03/26/2026 02:13:44.017 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 03/26/2026 02:13:44.017 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 03/26/2026 02:13:44.017 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.017 7fbb9174f860 [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=139810478, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.017 7fbb9174f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 283 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=139810478, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.017 7fbb9174f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278240.325195, idle connection 217158.000000, request 304999.963760 03/26/2026 02:13:44.018 7fbb9174f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278240.027344, idle connection 217157.000000, request 304999.667406 03/26/2026 02:13:44.020 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 214 03/26/2026 02:13:44.020 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 03/26/2026 02:13:44.020 7fbb90d6aae0 [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)]) 03/26/2026 02:13:44.020 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.020 7fbb90d6aae0 [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=1521128298, session_epoch=301, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.021 7fbb90d6aae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 304 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1521128298, session_epoch=301, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.021 7fbb90d6aae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278242.431641, idle connection 217415.000000, request 304999.965668 03/26/2026 02:13:44.021 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/26/2026 02:13:44.021 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 03/26/2026 02:13:44.021 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 03/26/2026 02:13:44.021 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.021 7fbb92300b80 [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=742834469, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.021 7fbb92300b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=742834469, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.021 7fbb92300b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277751.546143, idle connection 216907.000000, request 304999.968290 03/26/2026 02:13:44.022 7fbb90d6aae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278241.459717, idle connection 217414.000000, request 304998.995066 03/26/2026 02:13:44.022 7fbb92300b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.913818, idle connection 216906.000000, request 304999.337912 03/26/2026 02:13:44.025 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/26/2026 02:13:44.025 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 03/26/2026 02:13:44.025 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 03/26/2026 02:13:44.025 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.025 7fbb8e6e20e0 [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=885575508, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.025 7fbb8e6e20e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=885575508, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.025 7fbb8e6e20e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277749.770752, idle connection 216966.000000, request 304999.966145 03/26/2026 02:13:44.025 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 03/26/2026 02:13:44.025 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 03/26/2026 02:13:44.025 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 03/26/2026 02:13:44.025 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.026 7fbb8e6bb7c0 [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=776967202, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.026 7fbb8e6bb7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=776967202, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.026 7fbb8e6bb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.607910, idle connection 217060.000000, request 304999.969006 03/26/2026 02:13:44.026 7fbb8e6e20e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277748.910889, idle connection 216965.000000, request 304999.106884 03/26/2026 02:13:44.026 7fbb8e6bb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.015869, idle connection 217060.000000, request 304999.378920 03/26/2026 02:13:44.038 7fbb9174f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278838.565430, idle connection 217105.000000, request 304398.288250 03/26/2026 02:13:44.038 7fbb9174f4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 03/26/2026 02:13:44.038 7fbb9174f4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.038 7fbb9174f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 277 (602.0662784576416 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1846967730, topics=[]) 03/26/2026 02:13:44.038 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1846967730 with 0 response partitions (1 implied) 03/26/2026 02:13:44.038 7fbb9174fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278142.135010, idle connection 217272.000000, request 304398.276091 03/26/2026 02:13:44.038 7fbb9174fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 03/26/2026 02:13:44.038 7fbb9174fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.039 7fbb9174fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 289 (601.9964218139648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1970678087, topics=[]) 03/26/2026 02:13:44.039 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1970678087 with 0 response partitions (1 implied) 03/26/2026 02:13:44.163 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 03/26/2026 02:13:44.163 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 03/26/2026 02:13:44.163 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 03/26/2026 02:13:44.163 7fbb923009a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.163 7fbb923009a0 [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=341095875, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.164 7fbb923009a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 282 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=341095875, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.164 7fbb923009a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277713.250977, idle connection 216762.000000, request 304999.938726 03/26/2026 02:13:44.164 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 33 03/26/2026 02:13:44.164 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 03/26/2026 02:13:44.164 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 03/26/2026 02:13:44.164 7fbb9174fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.164 7fbb9174fc20 [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=879276820, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.164 7fbb9174fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 277 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879276820, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.164 7fbb9174fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277714.908203, idle connection 217069.000000, request 304999.964476 03/26/2026 02:13:44.165 7fbb923009a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277712.173096, idle connection 216761.000000, request 304998.869896 03/26/2026 02:13:44.165 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 1 03/26/2026 02:13:44.165 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 03/26/2026 02:13:44.165 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 03/26/2026 02:13:44.165 7fbb9053e9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.165 7fbb9053e9a0 [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=1593155826, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.165 7fbb9053e9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593155826, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.166 7fbb9053e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277715.381592, idle connection 216845.000000, request 304999.967098 03/26/2026 02:13:44.166 7fbb9174fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277713.616943, idle connection 217067.000000, request 304998.676777 03/26/2026 02:13:44.166 7fbb9053e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277714.769531, idle connection 216844.000000, request 304999.357700 03/26/2026 02:13:44.205 7fbb90d6a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278344.109375, idle connection 217145.000000, request 304399.067163 03/26/2026 02:13:44.205 7fbb90d6a400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 03/26/2026 02:13:44.205 7fbb90d6a400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.205 7fbb90d6a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 295 (601.4456748962402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=849958729, topics=[]) 03/26/2026 02:13:44.206 7fbb90d6a400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 849958729 with 0 response partitions (1 implied) 03/26/2026 02:13:44.263 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 2 03/26/2026 02:13:44.263 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 03/26/2026 02:13:44.263 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 03/26/2026 02:13:44.263 7fbb92300d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.263 7fbb92300d60 [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=1319558908, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.263 7fbb92300d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1319558908, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.263 7fbb92300d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277713.026123, idle connection 216833.000000, request 304999.951601 03/26/2026 02:13:44.263 7fbb9174ff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278220.352295, idle connection 216993.000000, request 304396.865606 03/26/2026 02:13:44.264 7fbb90d6a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278856.102051, idle connection 217072.000000, request 304397.627592 03/26/2026 02:13:44.264 7fbb92300d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277712.363525, idle connection 216832.000000, request 304999.297380 03/26/2026 02:13:44.264 7fbb9174ff40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 03/26/2026 02:13:44.264 7fbb9174ff40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.264 7fbb9174ff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 297 (603.9128303527832 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1210270230, topics=[]) 03/26/2026 02:13:44.264 7fbb9174ff40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1210270230 with 0 response partitions (1 implied) 03/26/2026 02:13:44.265 7fbb90d6a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 03/26/2026 02:13:44.265 7fbb90d6a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.265 7fbb90d6a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 294 (603.4610271453857 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=541706597, topics=[]) 03/26/2026 02:13:44.265 7fbb90d6a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 541706597 with 0 response partitions (1 implied) 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [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=454738816, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=454738816, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.344 7fbb8e6bb5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277697.824463, idle connection 216735.000000, request 304999.950647 03/26/2026 02:13:44.345 7fbb8e6bb5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277697.415039, idle connection 216735.000000, request 304999.548435 03/26/2026 02:13:44.349 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33 03/26/2026 02:13:44.349 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 03/26/2026 02:13:44.350 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 03/26/2026 02:13:44.350 7fbb92300cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.350 7fbb92300cc0 [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=1046831045, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.350 7fbb92300cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 278 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1046831045, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.350 7fbb92300cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277728.502686, idle connection 216772.000000, request 304999.959230 03/26/2026 02:13:44.350 7fbb92300cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277728.183350, idle connection 216771.000000, request 304999.644041 03/26/2026 02:13:44.353 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 52 03/26/2026 02:13:44.353 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 03/26/2026 02:13:44.354 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 03/26/2026 02:13:44.354 7fbb9174f720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.354 7fbb9174f720 [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=428853525, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.354 7fbb9174f720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 283 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=428853525, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.354 7fbb9174f720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278229.795654, idle connection 216833.000000, request 304999.964476 03/26/2026 02:13:44.354 7fbb9053e4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278293.205566, idle connection 216647.000000, request 304398.157120 03/26/2026 02:13:44.354 7fbb9174f720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278229.379150, idle connection 216833.000000, request 304999.549866 03/26/2026 02:13:44.355 7fbb9053e4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/26/2026 02:13:44.355 7fbb9053e4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.355 7fbb9053e4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 271 (602.4112701416016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098641316, topics=[]) 03/26/2026 02:13:44.355 7fbb9053e4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098641316 with 0 response partitions (1 implied) 03/26/2026 02:13:44.358 7fbb9053e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278324.478271, idle connection 216682.000000, request 304398.546696 03/26/2026 02:13:44.358 7fbb9053e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 03/26/2026 02:13:44.358 7fbb9053e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.358 7fbb9053e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 272 (601.7649173736572 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1678156831, topics=[]) 03/26/2026 02:13:44.358 7fbb9053e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1678156831 with 0 response partitions (1 implied) 03/26/2026 02:13:44.358 7fbb90d6a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278822.226807, idle connection 217002.000000, request 304398.585081 03/26/2026 02:13:44.358 7fbb90d6a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 03/26/2026 02:13:44.359 7fbb90d6a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.359 7fbb90d6a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 300 (601.6778945922852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1334155973, topics=[]) 03/26/2026 02:13:44.359 7fbb90d6a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1334155973 with 0 response partitions (1 implied) 03/26/2026 02:13:44.379 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4255 03/26/2026 02:13:44.379 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 03/26/2026 02:13:44.379 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 03/26/2026 02:13:44.380 7fbb923007c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.380 7fbb923007c0 [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=174060836, session_epoch=411, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.380 7fbb923007c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 414 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=174060836, session_epoch=411, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.380 7fbb923007c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277202.901611, idle connection 216542.000000, request 304999.956131 03/26/2026 02:13:44.380 7fbb923007c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277202.577393, idle connection 216542.000000, request 304999.635458 03/26/2026 02:13:44.403 7fbb9174fae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277632.180664, idle connection 216883.000000, request 304399.137497 03/26/2026 02:13:44.403 7fbb9174fae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 03/26/2026 02:13:44.403 7fbb9174fae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.403 7fbb9174fae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 296 (601.2725830078125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1680813061, topics=[]) 03/26/2026 02:13:44.403 7fbb9174fae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1680813061 with 0 response partitions (1 implied) 03/26/2026 02:13:44.411 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 03/26/2026 02:13:44.411 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 03/26/2026 02:13:44.411 7fbb8e6bb720 [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)]) 03/26/2026 02:13:44.411 7fbb8e6bb720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.411 7fbb8e6bb720 [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=247326985, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.411 7fbb8e6bb720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 272 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=247326985, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.411 7fbb8e6bb720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277746.277588, idle connection 216642.000000, request 304999.960899 03/26/2026 02:13:44.411 7fbb9174f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277654.494141, idle connection 216749.000000, request 304398.129225 03/26/2026 02:13:44.412 7fbb8e6bb720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277745.786377, idle connection 216641.000000, request 304999.473095 03/26/2026 02:13:44.412 7fbb9174f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 03/26/2026 02:13:44.412 7fbb9174f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.412 7fbb9174f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 282 (602.501392364502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1892731767, topics=[]) 03/26/2026 02:13:44.412 7fbb9174f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1892731767 with 0 response partitions (1 implied) 03/26/2026 02:13:44.427 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4 03/26/2026 02:13:44.427 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 03/26/2026 02:13:44.427 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 03/26/2026 02:13:44.427 7fbb9053e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.427 7fbb9053e720 [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=2074756401, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.428 7fbb9053e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 273 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2074756401, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.428 7fbb9053e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.938965, idle connection 216621.000000, request 304999.959707 03/26/2026 02:13:44.428 7fbb9053e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.613770, idle connection 216620.000000, request 304999.637127 03/26/2026 02:13:44.514 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 108 03/26/2026 02:13:44.514 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 03/26/2026 02:13:44.514 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 03/26/2026 02:13:44.514 7fbb90d6a180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.515 7fbb90d6a180 [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=288163504, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.515 7fbb90d6a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 288 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=288163504, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.515 7fbb90d6a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277528.860352, idle connection 216823.000000, request 304999.944687 03/26/2026 02:13:44.515 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 91 03/26/2026 02:13:44.515 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 03/26/2026 02:13:44.515 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 03/26/2026 02:13:44.515 7fbb90d6a040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.515 7fbb90d6a040 [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=139656969, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.515 7fbb90d6a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 288 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=139656969, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.515 7fbb90d6a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277738.016602, idle connection 216807.000000, request 304999.965668 03/26/2026 02:13:44.516 7fbb90d6a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277527.886963, idle connection 216822.000000, request 304998.983145 03/26/2026 02:13:44.516 7fbb90d6a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277737.416016, idle connection 216807.000000, request 304999.368191 03/26/2026 02:13:44.526 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 145 03/26/2026 02:13:44.526 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 03/26/2026 02:13:44.526 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 03/26/2026 02:13:44.526 7fbb9174f900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.527 7fbb9174f900 [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=1376305268, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.527 7fbb9174f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 287 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1376305268, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.527 7fbb9174f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.113037, idle connection 216749.000000, request 304999.958038 03/26/2026 02:13:44.527 7fbb9174f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277749.801758, idle connection 216749.000000, request 304999.650717 03/26/2026 02:13:44.611 7fbb9174f400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277645.688232, idle connection 216596.000000, request 304399.112225 03/26/2026 02:13:44.611 7fbb9174f400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 03/26/2026 02:13:44.611 7fbb9174f400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.611 7fbb9174f400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 279 (601.3588905334473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=657121762, topics=[]) 03/26/2026 02:13:44.611 7fbb9174f400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 657121762 with 0 response partitions (1 implied) 03/26/2026 02:13:44.617 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38 03/26/2026 02:13:44.617 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 03/26/2026 02:13:44.617 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 03/26/2026 02:13:44.617 7fbb9174f2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.617 7fbb9174f2c0 [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=1476544711, session_epoch=276, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.617 7fbb9174f2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 279 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1476544711, session_epoch=276, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.618 7fbb9174f2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277644.150879, idle connection 216516.000000, request 304999.960661 03/26/2026 02:13:44.618 7fbb9174f2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277643.807617, idle connection 216515.000000, request 304999.620438 03/26/2026 02:13:44.618 7fbb9174f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277639.697998, idle connection 216557.000000, request 304399.337530 03/26/2026 02:13:44.618 7fbb9174f860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 03/26/2026 02:13:44.618 7fbb9174f860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.618 7fbb9174f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 283 (601.029634475708 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=139810478, topics=[]) 03/26/2026 02:13:44.619 7fbb9174f860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 139810478 with 0 response partitions (1 implied) 03/26/2026 02:13:44.622 7fbb90d6aae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277640.919434, idle connection 216813.000000, request 304398.453712 03/26/2026 02:13:44.622 7fbb90d6aae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 03/26/2026 02:13:44.622 7fbb90d6aae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.622 7fbb90d6aae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 304 (601.8393039703369 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1521128298, topics=[]) 03/26/2026 02:13:44.623 7fbb90d6aae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1521128298 with 0 response partitions (1 implied) 03/26/2026 02:13:44.623 7fbb92300b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277150.067871, idle connection 216305.000000, request 304398.490429 03/26/2026 02:13:44.623 7fbb92300b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:44.623 7fbb92300b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.623 7fbb92300b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (601.7816066741943 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=742834469, topics=[]) 03/26/2026 02:13:44.623 7fbb92300b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 742834469 with 0 response partitions (1 implied) 03/26/2026 02:13:44.627 7fbb8e6e20e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277148.347900, idle connection 216364.000000, request 304398.543358 03/26/2026 02:13:44.627 7fbb8e6e20e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:44.627 7fbb8e6e20e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.627 7fbb8e6e20e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (601.7501354217529 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=885575508, topics=[]) 03/26/2026 02:13:44.627 7fbb8e6e20e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 885575508 with 0 response partitions (1 implied) 03/26/2026 02:13:44.627 7fbb8e6bb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277149.200439, idle connection 216459.000000, request 304398.562670 03/26/2026 02:13:44.627 7fbb8e6bb7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/26/2026 02:13:44.627 7fbb8e6bb7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/26/2026 02:13:44.627 7fbb8e6bb7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Response 270 (601.6936302185059 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=776967202, topics=[]) 03/26/2026 02:13:44.628 7fbb8e6bb7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 776967202 with 0 response partitions (1 implied) 03/26/2026 02:13:44.638 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 35 03/26/2026 02:13:44.638 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 03/26/2026 02:13:44.638 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 03/26/2026 02:13:44.639 7fbb9174f4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.639 7fbb9174f4a0 [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=1846967730, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.639 7fbb9174f4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 278 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1846967730, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.639 7fbb9174f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278237.316650, idle connection 216504.000000, request 304999.961138 03/26/2026 02:13:44.639 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 172 03/26/2026 02:13:44.639 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 03/26/2026 02:13:44.639 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 03/26/2026 02:13:44.639 7fbb9174fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/26/2026 02:13:44.639 7fbb9174fcc0 [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=1970678087, session_epoch=287, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.639 7fbb9174fcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.130', 9092)]>: Request 290 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1970678087, session_epoch=287, topics=[], forgotten_topics_data=[]) 03/26/2026 02:13:44.639 7fbb9174fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277540.914307, idle connection 216671.000000, request 304999.968767 03/26/2026 02:13:44.640 7fbb9174f4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278236.399902, idle connection 216503.000000, request 304999.047756 03/26/2026 02:13:44.640 7fbb9174fcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277540.352783, idle connection 216671.000000, request 304999.409199