03/23/2026 02:16:21.030 7fc44e36b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 297 (601.6182899475098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=138193259, topics=[]) 03/23/2026 02:16:21.030 7fc44e36b360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 138193259 with 0 response partitions (1 implied) 03/23/2026 02:16:21.030 7fc44e257720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 293 03/23/2026 02:16:21.030 7fc44e257720 [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/23/2026 02:16:21.030 7fc44e257720 [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/23/2026 02:16:21.031 7fc44e257720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.031 7fc44e257720 [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=1542934703, session_epoch=300, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.031 7fc44e257720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1542934703, session_epoch=300, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.031 7fc44e257720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280162.953613, idle connection 218545.000000, request 304999.954224 03/23/2026 02:16:21.032 7fc44e257720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280162.279053, idle connection 218544.000000, request 304999.285936 03/23/2026 02:16:21.032 7fc44e36b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 28 03/23/2026 02:16:21.032 7fc44e36b7c0 [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/23/2026 02:16:21.032 7fc44e36b7c0 [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/23/2026 02:16:21.032 7fc44e36b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.032 7fc44e36b7c0 [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=406884542, session_epoch=271, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.032 7fc44e36b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 274 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406884542, session_epoch=271, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.032 7fc44e36b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280167.733887, idle connection 218343.000000, request 304999.964952 03/23/2026 02:16:21.034 7fc44e36b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280165.641602, idle connection 218341.000000, request 304997.874022 03/23/2026 02:16:21.039 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279327.333008, idle connection 218070.000000, request 304395.334721 03/23/2026 02:16:21.040 7fc44c5a6ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 414 03/23/2026 02:16:21.040 7fc44c5a6ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.040 7fc44c5a6ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 414 (605.1108837127686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=171809573, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3994, last_stable_offset=3994, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\x99\x00\x00\x01\x04\x00\x00\x00\x00\x02^\xf1\xa5\xa1\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/23/2026 02:16:21.040 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 171809573 with 1 response partitions (0 implied) 03/23/2026 02:16:21.040 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3993 03/23/2026 02:16:21.040 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3993 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 03/23/2026 02:16:21.041 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3994 (leader epoch 0) 03/23/2026 02:16:21.067 7fc44c5a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279547.506592, idle connection 218040.000000, request 304399.139881 03/23/2026 02:16:21.067 7fc44c5a6d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/23/2026 02:16:21.067 7fc44c5a6d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.067 7fc44c5a6d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 271 (601.4173030853271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=593055773, topics=[]) 03/23/2026 02:16:21.068 7fc44c5a6d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 593055773 with 0 response partitions (1 implied) 03/23/2026 02:16:21.080 7fc44e36b040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 25 03/23/2026 02:16:21.080 7fc44e36b040 [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/23/2026 02:16:21.080 7fc44e36b040 [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/23/2026 02:16:21.080 7fc44e36b040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.080 7fc44e36b040 [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=1650040860, session_epoch=273, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.080 7fc44e36b040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1650040860, session_epoch=273, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.080 7fc44e36b040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278938.222656, idle connection 218243.000000, request 304999.952078 03/23/2026 02:16:21.081 7fc44e36b040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278937.816650, idle connection 218243.000000, request 304999.552965 03/23/2026 02:16:21.125 7fc44bba5d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 03/23/2026 02:16:21.126 7fc44bba5d60 [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/23/2026 02:16:21.126 7fc44bba5d60 [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/23/2026 02:16:21.126 7fc44bba5d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.126 7fc44bba5d60 [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=1044719715, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.126 7fc44bba5d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1044719715, session_epoch=266, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.126 7fc44bba5d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278951.128662, idle connection 218128.000000, request 304999.951363 03/23/2026 02:16:21.126 7fc44bba5d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278950.731934, idle connection 218127.000000, request 304999.561548 03/23/2026 02:16:21.141 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3994 03/23/2026 02:16:21.141 7fc44c5a6ea0 [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/23/2026 02:16:21.141 7fc44c5a6ea0 [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/23/2026 02:16:21.141 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.141 7fc44c5a6ea0 [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=171809573, session_epoch=412, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3994, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/23/2026 02:16:21.142 7fc44c5a6ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 415 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=171809573, session_epoch=412, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3994, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/23/2026 02:16:21.142 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279224.830322, idle connection 217967.000000, request 304999.938250 03/23/2026 02:16:21.142 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279224.451660, idle connection 217967.000000, request 304999.565840 03/23/2026 02:16:21.150 7fc44c18a040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 61 03/23/2026 02:16:21.150 7fc44c18a040 [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/23/2026 02:16:21.151 7fc44c18a040 [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/23/2026 02:16:21.151 7fc44c18a040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.151 7fc44c18a040 [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=1259605411, session_epoch=281, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.151 7fc44c18a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 284 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1259605411, session_epoch=281, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.151 7fc44c18a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278951.465576, idle connection 218152.000000, request 304999.953747 03/23/2026 02:16:21.151 7fc44c18a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278951.096191, idle connection 218152.000000, request 304999.591112 03/23/2026 02:16:21.172 7fc44e36bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278849.906250, idle connection 218216.000000, request 304399.133921 03/23/2026 02:16:21.172 7fc44e36bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 03/23/2026 02:16:21.172 7fc44e36bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.172 7fc44e36bcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 281 (601.3689041137695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=736006542, topics=[]) 03/23/2026 02:16:21.172 7fc44e36bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 736006542 with 0 response partitions (1 implied) 03/23/2026 02:16:21.200 7fc44e36be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 109 03/23/2026 02:16:21.200 7fc44e36be00 [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/23/2026 02:16:21.200 7fc44e36be00 [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/23/2026 02:16:21.200 7fc44e36be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.200 7fc44e36be00 [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=1091956160, session_epoch=282, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.200 7fc44e36be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 285 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1091956160, session_epoch=282, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.200 7fc44e36be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279449.512207, idle connection 218225.000000, request 304999.944448 03/23/2026 02:16:21.201 7fc44e36be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279449.033691, idle connection 218224.000000, request 304999.473572 03/23/2026 02:16:21.225 7fc44e2574a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 155 03/23/2026 02:16:21.226 7fc44e2574a0 [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/23/2026 02:16:21.226 7fc44e2574a0 [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/23/2026 02:16:21.226 7fc44e2574a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.226 7fc44e2574a0 [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=987292387, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.226 7fc44e2574a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=987292387, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.227 7fc44e2574a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280142.323730, idle connection 218330.000000, request 304999.919891 03/23/2026 02:16:21.227 7fc44e36ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48 03/23/2026 02:16:21.227 7fc44e36ba40 [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/23/2026 02:16:21.227 7fc44e36ba40 [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/23/2026 02:16:21.227 7fc44e36ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.227 7fc44e36ba40 [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=1014471641, session_epoch=277, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.227 7fc44e36ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 280 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1014471641, session_epoch=277, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.227 7fc44e36ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278935.830322, idle connection 218167.000000, request 304999.942303 03/23/2026 02:16:21.228 7fc44e2574a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280140.928467, idle connection 218329.000000, request 304998.543024 03/23/2026 02:16:21.228 7fc44e36ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278935.037598, idle connection 218166.000000, request 304999.160290 03/23/2026 02:16:21.250 7fc44e36b4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 13 03/23/2026 02:16:21.250 7fc44e36b4a0 [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/23/2026 02:16:21.251 7fc44e36b4a0 [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/23/2026 02:16:21.251 7fc44e36b4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.251 7fc44e36b4a0 [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=1996197811, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.251 7fc44e36b4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1996197811, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.251 7fc44e36b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278926.253906, idle connection 218093.000000, request 304999.950886 03/23/2026 02:16:21.251 7fc44c18a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279528.907227, idle connection 218007.000000, request 304397.631407 03/23/2026 02:16:21.252 7fc44e36b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278925.680664, idle connection 218093.000000, request 304999.385357 03/23/2026 02:16:21.252 7fc44c18a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/23/2026 02:16:21.252 7fc44c18a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.252 7fc44c18a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 269 (603.0731201171875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=664204336, topics=[]) 03/23/2026 02:16:21.252 7fc44c18a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 664204336 with 0 response partitions (1 implied) 03/23/2026 02:16:21.300 7fc44e257680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279546.907227, idle connection 218242.000000, request 304399.056673 03/23/2026 02:16:21.300 7fc44e257680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 03/23/2026 02:16:21.300 7fc44e257680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.300 7fc44e257680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 292 (601.4478206634521 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=651604046, topics=[]) 03/23/2026 02:16:21.300 7fc44e257680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 651604046 with 0 response partitions (1 implied) 03/23/2026 02:16:21.366 7fc44e36b720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 34 03/23/2026 02:16:21.366 7fc44e36b720 [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/23/2026 02:16:21.366 7fc44e36b720 [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/23/2026 02:16:21.366 7fc44e36b720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.367 7fc44e36b720 [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=213155310, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.367 7fc44e36b720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=213155310, session_epoch=275, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.367 7fc44e36b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278922.695801, idle connection 217988.000000, request 304999.943495 03/23/2026 02:16:21.367 7fc44e36bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279525.461670, idle connection 218110.000000, request 304397.435427 03/23/2026 02:16:21.367 7fc44e36b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278922.094971, idle connection 217988.000000, request 304999.351740 03/23/2026 02:16:21.368 7fc44e36bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 03/23/2026 02:16:21.368 7fc44e36bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.368 7fc44e36bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 287 (603.2979488372803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927992269, topics=[]) 03/23/2026 02:16:21.368 7fc44e36bae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927992269 with 0 response partitions (1 implied) 03/23/2026 02:16:21.379 7fc44eee3f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2 03/23/2026 02:16:21.380 7fc44eee3f40 [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/23/2026 02:16:21.380 7fc44eee3f40 [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/23/2026 02:16:21.380 7fc44eee3f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.380 7fc44eee3f40 [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=1725652678, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.380 7fc44eee3f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1725652678, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.380 7fc44eee3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278946.027344, idle connection 217785.000000, request 304999.953032 03/23/2026 02:16:21.380 7fc44eee3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278945.648193, idle connection 217785.000000, request 304999.579906 03/23/2026 02:16:21.400 7fc44e257180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 264 03/23/2026 02:16:21.400 7fc44e257180 [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/23/2026 02:16:21.400 7fc44e257180 [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/23/2026 02:16:21.400 7fc44e257180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.400 7fc44e257180 [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=474087266, session_epoch=298, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.400 7fc44e257180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 301 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=474087266, session_epoch=298, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.400 7fc44e257180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279443.598633, idle connection 218101.000000, request 304999.954700 03/23/2026 02:16:21.401 7fc44e257180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279443.130127, idle connection 218100.000000, request 304999.490976 03/23/2026 02:16:21.418 7fc44e36b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 63 03/23/2026 02:16:21.418 7fc44e36b180 [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/23/2026 02:16:21.418 7fc44e36b180 [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/23/2026 02:16:21.418 7fc44e36b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.418 7fc44e36b180 [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=1524502808, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.418 7fc44e36b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1524502808, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.418 7fc44e36b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278919.065674, idle connection 217901.000000, request 304999.943495 03/23/2026 02:16:21.419 7fc44e36b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278918.652344, idle connection 217901.000000, request 304999.541998 03/23/2026 02:16:21.435 7fc44e36bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 87 03/23/2026 02:16:21.435 7fc44e36bc20 [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/23/2026 02:16:21.435 7fc44e36bc20 [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/23/2026 02:16:21.435 7fc44e36bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.436 7fc44e36bc20 [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=1354711734, session_epoch=283, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.436 7fc44e36bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1354711734, session_epoch=283, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.436 7fc44e36bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278953.390625, idle connection 217996.000000, request 304999.922276 03/23/2026 02:16:21.437 7fc44e36bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278952.802979, idle connection 217995.000000, request 304999.344349 03/23/2026 02:16:21.510 7fc44bba5e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279541.392578, idle connection 217712.000000, request 304398.833275 03/23/2026 02:16:21.510 7fc44bba5e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:21.510 7fc44bba5e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.510 7fc44bba5e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (601.7210483551025 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=399975691, topics=[]) 03/23/2026 02:16:21.511 7fc44bba5e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 399975691 with 0 response partitions (1 implied) 03/23/2026 02:16:21.517 7fc44e36bea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 234 03/23/2026 02:16:21.518 7fc44e36bea0 [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/23/2026 02:16:21.518 7fc44e36bea0 [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/23/2026 02:16:21.518 7fc44e36bea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.518 7fc44e36bea0 [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=1646947982, session_epoch=298, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.518 7fc44e36bea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 301 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1646947982, session_epoch=298, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.518 7fc44e36bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278939.136963, idle connection 217937.000000, request 304999.952078 03/23/2026 02:16:21.518 7fc44c5a6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278318.835693, idle connection 217576.000000, request 304397.467852 03/23/2026 02:16:21.519 7fc44e36bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278938.573242, idle connection 217936.000000, request 304999.395132 03/23/2026 02:16:21.519 7fc44c5a6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/23/2026 02:16:21.519 7fc44c5a6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.519 7fc44c5a6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 269 (603.2285690307617 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1331112178, topics=[]) 03/23/2026 02:16:21.519 7fc44c5a6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1331112178 with 0 response partitions (1 implied) 03/23/2026 02:16:21.519 7fc44bba5720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 03/23/2026 02:16:21.519 7fc44bba5720 [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/23/2026 02:16:21.519 7fc44bba5720 [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/23/2026 02:16:21.520 7fc44bba5720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.520 7fc44bba5720 [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=67906960, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.520 7fc44bba5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=67906960, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.520 7fc44bba5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278960.522705, idle connection 217715.000000, request 304999.960423 03/23/2026 02:16:21.520 7fc44bba5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278960.094971, idle connection 217715.000000, request 304999.535084 03/23/2026 02:16:21.566 7fc44c5a69a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278345.817383, idle connection 217537.000000, request 304398.948431 03/23/2026 02:16:21.566 7fc44c5a69a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/23/2026 02:16:21.566 7fc44c5a69a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.566 7fc44c5a69a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 269 (601.6039848327637 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=356390323, topics=[]) 03/23/2026 02:16:21.567 7fc44c5a69a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 356390323 with 0 response partitions (1 implied) 03/23/2026 02:16:21.582 7fc44c5a6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278241.653076, idle connection 217522.000000, request 304399.116278 03/23/2026 02:16:21.583 7fc44c5a6c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 03/23/2026 02:16:21.583 7fc44c5a6c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.583 7fc44c5a6c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 272 (601.3295650482178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008941912, topics=[]) 03/23/2026 02:16:21.583 7fc44c5a6c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1008941912 with 0 response partitions (1 implied) 03/23/2026 02:16:21.609 7fc44bba5400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278355.180664, idle connection 217558.000000, request 304399.070024 03/23/2026 02:16:21.610 7fc44bba5400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/23/2026 02:16:21.610 7fc44bba5400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.610 7fc44bba5400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 269 (601.4468669891357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1918797836, topics=[]) 03/23/2026 02:16:21.610 7fc44bba5400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1918797836 with 0 response partitions (1 implied) 03/23/2026 02:16:21.616 7fc44c5a6ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 62 03/23/2026 02:16:21.617 7fc44c5a6ae0 [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/23/2026 02:16:21.617 7fc44c5a6ae0 [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/23/2026 02:16:21.617 7fc44c5a6ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.617 7fc44c5a6ae0 [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=1379646182, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.617 7fc44c5a6ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1379646182, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.617 7fc44c5a6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278251.908936, idle connection 217483.000000, request 304999.951363 03/23/2026 02:16:21.618 7fc44c5a6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278251.490479, idle connection 217483.000000, request 304999.539614 03/23/2026 02:16:21.618 7fc44e2577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278859.744629, idle connection 217947.000000, request 304399.209499 03/23/2026 02:16:21.618 7fc44e2577c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 03/23/2026 02:16:21.618 7fc44e2577c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.618 7fc44e2577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 295 (601.1192798614502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1295728411, topics=[]) 03/23/2026 02:16:21.618 7fc44e2577c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1295728411 with 0 response partitions (1 implied) 03/23/2026 02:16:21.630 7fc44e36b360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 197 03/23/2026 02:16:21.631 7fc44e36b360 [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/23/2026 02:16:21.631 7fc44e36b360 [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/23/2026 02:16:21.631 7fc44e36b360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.631 7fc44e36b360 [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=138193259, session_epoch=295, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.631 7fc44e36b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 298 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=138193259, session_epoch=295, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.631 7fc44e36b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279457.180664, idle connection 217863.000000, request 304999.946356 03/23/2026 02:16:21.632 7fc44e36b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279456.766602, idle connection 217862.000000, request 304999.539375 03/23/2026 02:16:21.633 7fc44e257720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279560.912354, idle connection 217943.000000, request 304397.919178 03/23/2026 02:16:21.633 7fc44e257720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 03/23/2026 02:16:21.633 7fc44e257720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.633 7fc44e257720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 303 (602.4188995361328 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1542934703, topics=[]) 03/23/2026 02:16:21.633 7fc44e257720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1542934703 with 0 response partitions (1 implied) 03/23/2026 02:16:21.639 7fc44e36b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279561.034180, idle connection 217737.000000, request 304393.262386 03/23/2026 02:16:21.639 7fc44e36b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 03/23/2026 02:16:21.639 7fc44e36b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.639 7fc44e36b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 274 (607.1155071258545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=406884542, topics=[]) 03/23/2026 02:16:21.639 7fc44e36b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 406884542 with 0 response partitions (1 implied) 03/23/2026 02:16:21.668 7fc44c5a6d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 7 03/23/2026 02:16:21.668 7fc44c5a6d60 [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/23/2026 02:16:21.668 7fc44c5a6d60 [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/23/2026 02:16:21.668 7fc44c5a6d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.668 7fc44c5a6d60 [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=593055773, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.668 7fc44c5a6d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=593055773, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.669 7fc44c5a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278945.639893, idle connection 217438.000000, request 304999.949217 03/23/2026 02:16:21.669 7fc44c5a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278945.214844, idle connection 217437.000000, request 304999.531507 03/23/2026 02:16:21.681 7fc44e36b040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278337.408691, idle connection 217643.000000, request 304399.142027 03/23/2026 02:16:21.682 7fc44e36b040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 03/23/2026 02:16:21.682 7fc44e36b040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.682 7fc44e36b040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 276 (601.3288497924805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1650040860, topics=[]) 03/23/2026 02:16:21.682 7fc44e36b040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1650040860 with 0 response partitions (1 implied) 03/23/2026 02:16:21.728 7fc44bba5d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278349.368164, idle connection 217526.000000, request 304398.186684 03/23/2026 02:16:21.728 7fc44bba5d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 03/23/2026 02:16:21.728 7fc44bba5d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.728 7fc44bba5d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 269 (602.3874282836914 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1044719715, topics=[]) 03/23/2026 02:16:21.729 7fc44bba5d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1044719715 with 0 response partitions (1 implied) 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278624.025635, idle connection 217367.000000, request 304399.132967 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 415 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 415 (601.3836860656738 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=171809573, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3995, last_stable_offset=3995, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\x9a\x00\x00\x01\x04\x00\x00\x00\x00\x02\xd7R\xf0\xab\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 171809573 with 1 response partitions (0 implied) 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3994 03/23/2026 02:16:21.743 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3994 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 03/23/2026 02:16:21.744 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3995 (leader epoch 0) 03/23/2026 02:16:21.752 7fc44c18a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278350.129883, idle connection 217551.000000, request 304398.618221 03/23/2026 02:16:21.753 7fc44c18a040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 03/23/2026 02:16:21.753 7fc44c18a040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.753 7fc44c18a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 284 (601.8209457397461 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1259605411, topics=[]) 03/23/2026 02:16:21.753 7fc44c18a040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1259605411 with 0 response partitions (1 implied) 03/23/2026 02:16:21.773 7fc44e36bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44 03/23/2026 02:16:21.773 7fc44e36bcc0 [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/23/2026 02:16:21.773 7fc44e36bcc0 [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/23/2026 02:16:21.773 7fc44e36bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.773 7fc44e36bcc0 [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=736006542, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.773 7fc44e36bcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=736006542, session_epoch=279, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.773 7fc44e36bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278248.382324, idle connection 217614.000000, request 304999.953270 03/23/2026 02:16:21.774 7fc44e36bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278247.991699, idle connection 217614.000000, request 304999.567509 03/23/2026 02:16:21.801 7fc44e36be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278848.635986, idle connection 217624.000000, request 304399.072886 03/23/2026 02:16:21.801 7fc44e36be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 03/23/2026 02:16:21.802 7fc44e36be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.802 7fc44e36be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 285 (601.3619899749756 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1091956160, topics=[]) 03/23/2026 02:16:21.802 7fc44e36be00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1091956160 with 0 response partitions (1 implied) 03/23/2026 02:16:21.829 7fc44e2574a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279540.186523, idle connection 217728.000000, request 304397.791147 03/23/2026 02:16:21.829 7fc44e2574a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 03/23/2026 02:16:21.829 7fc44e2574a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.829 7fc44e2574a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 287 (602.7119159698486 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=987292387, topics=[]) 03/23/2026 02:16:21.829 7fc44e2574a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 987292387 with 0 response partitions (1 implied) 03/23/2026 02:16:21.830 7fc44e36ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278333.722656, idle connection 217565.000000, request 304397.842646 03/23/2026 02:16:21.830 7fc44e36ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 03/23/2026 02:16:21.830 7fc44e36ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.830 7fc44e36ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 280 (602.5526523590088 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1014471641, topics=[]) 03/23/2026 02:16:21.830 7fc44e36ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1014471641 with 0 response partitions (1 implied) 03/23/2026 02:16:21.844 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3995 03/23/2026 02:16:21.844 7fc44c5a6ea0 [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/23/2026 02:16:21.844 7fc44c5a6ea0 [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/23/2026 02:16:21.844 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.844 7fc44c5a6ea0 [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=171809573, session_epoch=413, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3995, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/23/2026 02:16:21.845 7fc44c5a6ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 416 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=171809573, session_epoch=413, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3995, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/23/2026 02:16:21.845 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278521.772461, idle connection 217264.000000, request 304999.949455 03/23/2026 02:16:21.845 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278521.381836, idle connection 217264.000000, request 304999.566555 03/23/2026 02:16:21.852 7fc44c18a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1 03/23/2026 02:16:21.852 7fc44c18a540 [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/23/2026 02:16:21.852 7fc44c18a540 [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/23/2026 02:16:21.853 7fc44c18a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.853 7fc44c18a540 [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=664204336, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.853 7fc44c18a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=664204336, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.853 7fc44c18a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278927.187256, idle connection 217405.000000, request 304999.958038 03/23/2026 02:16:21.853 7fc44e36b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278324.078369, idle connection 217491.000000, request 304397.781610 03/23/2026 02:16:21.853 7fc44c18a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278926.686035, idle connection 217405.000000, request 304999.460459 03/23/2026 02:16:21.854 7fc44e36b4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 273 03/23/2026 02:16:21.854 7fc44e36b4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.854 7fc44e36b4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 273 (602.841854095459 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1996197811, topics=[]) 03/23/2026 02:16:21.854 7fc44e36b4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1996197811 with 0 response partitions (1 implied) 03/23/2026 02:16:21.901 7fc44e257680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 122 03/23/2026 02:16:21.901 7fc44e257680 [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/23/2026 02:16:21.901 7fc44e257680 [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/23/2026 02:16:21.901 7fc44e257680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.901 7fc44e257680 [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=651604046, session_epoch=290, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.901 7fc44e257680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 293 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=651604046, session_epoch=290, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.902 7fc44e257680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278944.997314, idle connection 217640.000000, request 304999.946117 03/23/2026 02:16:21.902 7fc44e257680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278944.535889, idle connection 217640.000000, request 304999.492884 03/23/2026 02:16:21.968 7fc44e36bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 143 03/23/2026 02:16:21.968 7fc44e36bae0 [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/23/2026 02:16:21.969 7fc44e36bae0 [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/23/2026 02:16:21.969 7fc44e36bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:21.969 7fc44e36bae0 [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=1927992269, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.969 7fc44e36bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1927992269, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:21.969 7fc44e36bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278923.528809, idle connection 217508.000000, request 304999.945879 03/23/2026 02:16:21.969 7fc44e36b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278320.257568, idle connection 217386.000000, request 304397.515059 03/23/2026 02:16:21.970 7fc44e36bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278922.594482, idle connection 217507.000000, request 304999.021053 03/23/2026 02:16:21.970 7fc44e36b720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 03/23/2026 02:16:21.970 7fc44e36b720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.970 7fc44e36b720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 278 (603.5473346710205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=213155310, topics=[]) 03/23/2026 02:16:21.970 7fc44e36b720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 213155310 with 0 response partitions (1 implied) 03/23/2026 02:16:21.981 7fc44eee3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278345.286133, idle connection 217185.000000, request 304399.215937 03/23/2026 02:16:21.981 7fc44eee3f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:21.981 7fc44eee3f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:21.981 7fc44eee3f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (601.1838912963867 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725652678, topics=[]) 03/23/2026 02:16:21.981 7fc44eee3f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725652678 with 0 response partitions (1 implied) 03/23/2026 02:16:22.001 7fc44e257180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278842.597656, idle connection 217500.000000, request 304398.949862 03/23/2026 02:16:22.002 7fc44e257180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 301 03/23/2026 02:16:22.002 7fc44e257180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.002 7fc44e257180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 301 (601.586103439331 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=474087266, topics=[]) 03/23/2026 02:16:22.002 7fc44e257180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 474087266 with 0 response partitions (1 implied) 03/23/2026 02:16:22.020 7fc44e36b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278317.339111, idle connection 217300.000000, request 304398.221016 03/23/2026 02:16:22.021 7fc44e36b180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 03/23/2026 02:16:22.021 7fc44e36b180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.021 7fc44e36b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 283 (602.2920608520508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1524502808, topics=[]) 03/23/2026 02:16:22.021 7fc44e36b180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1524502808 with 0 response partitions (1 implied) 03/23/2026 02:16:22.037 7fc44e36bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278352.114990, idle connection 217394.000000, request 304398.657322 03/23/2026 02:16:22.038 7fc44e36bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 03/23/2026 02:16:22.038 7fc44e36bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.038 7fc44e36bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 286 (601.7324924468994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1354711734, topics=[]) 03/23/2026 02:16:22.038 7fc44e36bc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1354711734 with 0 response partitions (1 implied) 03/23/2026 02:16:22.111 7fc44bba5e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 4 03/23/2026 02:16:22.111 7fc44bba5e00 [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/23/2026 02:16:22.111 7fc44bba5e00 [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/23/2026 02:16:22.111 7fc44bba5e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.111 7fc44bba5e00 [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=399975691, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.111 7fc44bba5e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=399975691, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.112 7fc44bba5e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278939.636230, idle connection 217111.000000, request 304999.948740 03/23/2026 02:16:22.112 7fc44bba5e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278939.221924, idle connection 217110.000000, request 304999.541998 03/23/2026 02:16:22.119 7fc44c5a6860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/23/2026 02:16:22.119 7fc44c5a6860 [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/23/2026 02:16:22.120 7fc44c5a6860 [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/23/2026 02:16:22.120 7fc44c5a6860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.120 7fc44c5a6860 [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=1331112178, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.120 7fc44c5a6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1331112178, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.120 7fc44c5a6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277717.174316, idle connection 216975.000000, request 304999.956846 03/23/2026 02:16:22.120 7fc44c5a6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277716.845215, idle connection 216974.000000, request 304999.632359 03/23/2026 02:16:22.120 7fc44e36bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278336.701660, idle connection 217334.000000, request 304397.524595 03/23/2026 02:16:22.121 7fc44e36bea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 301 03/23/2026 02:16:22.121 7fc44e36bea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.121 7fc44e36bea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 301 (602.895975112915 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1646947982, topics=[]) 03/23/2026 02:16:22.121 7fc44e36bea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1646947982 with 0 response partitions (1 implied) 03/23/2026 02:16:22.121 7fc44bba5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278359.128906, idle connection 217114.000000, request 304398.568630 03/23/2026 02:16:22.121 7fc44bba5720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/23/2026 02:16:22.121 7fc44bba5720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.122 7fc44bba5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 271 (601.7768383026123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=67906960, topics=[]) 03/23/2026 02:16:22.122 7fc44bba5720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 67906960 with 0 response partitions (1 implied) 03/23/2026 02:16:22.167 7fc44c5a69a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/23/2026 02:16:22.167 7fc44c5a69a0 [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/23/2026 02:16:22.167 7fc44c5a69a0 [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/23/2026 02:16:22.167 7fc44c5a69a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.167 7fc44c5a69a0 [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=356390323, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.167 7fc44c5a69a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=356390323, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.167 7fc44c5a69a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277744.152832, idle connection 216935.000000, request 304999.953032 03/23/2026 02:16:22.168 7fc44c5a69a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277743.760010, idle connection 216935.000000, request 304999.565125 03/23/2026 02:16:22.183 7fc44c5a6c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 03/23/2026 02:16:22.183 7fc44c5a6c20 [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/23/2026 02:16:22.183 7fc44c5a6c20 [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/23/2026 02:16:22.183 7fc44c5a6c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.183 7fc44c5a6c20 [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=1008941912, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.184 7fc44c5a6c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1008941912, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.184 7fc44c5a6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277640.194092, idle connection 216921.000000, request 304999.956131 03/23/2026 02:16:22.184 7fc44c5a6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277639.841309, idle connection 216921.000000, request 304999.607086 03/23/2026 02:16:22.210 7fc44bba5400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 03/23/2026 02:16:22.210 7fc44bba5400 [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/23/2026 02:16:22.210 7fc44bba5400 [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/23/2026 02:16:22.210 7fc44bba5400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.211 7fc44bba5400 [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=1918797836, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.211 7fc44bba5400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1918797836, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.211 7fc44bba5400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277753.551758, idle connection 216956.000000, request 304999.956608 03/23/2026 02:16:22.211 7fc44bba5400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277753.210693, idle connection 216956.000000, request 304999.620676 03/23/2026 02:16:22.218 7fc44c5a6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277651.095215, idle connection 216883.000000, request 304399.144411 03/23/2026 02:16:22.218 7fc44c5a6ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 03/23/2026 02:16:22.218 7fc44c5a6ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.218 7fc44c5a6ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 282 (601.2330055236816 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1379646182, topics=[]) 03/23/2026 02:16:22.218 7fc44c5a6ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1379646182 with 0 response partitions (1 implied) 03/23/2026 02:16:22.219 7fc44e2577c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 231 03/23/2026 02:16:22.219 7fc44e2577c0 [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/23/2026 02:16:22.219 7fc44e2577c0 [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/23/2026 02:16:22.219 7fc44e2577c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.219 7fc44e2577c0 [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=1295728411, session_epoch=293, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.219 7fc44e2577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1295728411, session_epoch=293, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.219 7fc44e2577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278258.458496, idle connection 217346.000000, request 304999.960899 03/23/2026 02:16:22.219 7fc44e2577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278258.132568, idle connection 217345.000000, request 304999.638081 03/23/2026 02:16:22.232 7fc44e36b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278856.376221, idle connection 217262.000000, request 304399.147511 03/23/2026 02:16:22.232 7fc44e36b360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 298 03/23/2026 02:16:22.232 7fc44e36b360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.232 7fc44e36b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 298 (601.2482643127441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=138193259, topics=[]) 03/23/2026 02:16:22.232 7fc44e36b360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 138193259 with 0 response partitions (1 implied) 03/23/2026 02:16:22.234 7fc44e257720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 293 03/23/2026 02:16:22.234 7fc44e257720 [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/23/2026 02:16:22.234 7fc44e257720 [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/23/2026 02:16:22.234 7fc44e257720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.234 7fc44e257720 [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=1542934703, session_epoch=301, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.234 7fc44e257720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1542934703, session_epoch=301, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.234 7fc44e257720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278959.716309, idle connection 217341.000000, request 304999.963522 03/23/2026 02:16:22.234 7fc44e257720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278959.392578, idle connection 217341.000000, request 304999.641895 03/23/2026 02:16:22.240 7fc44e36b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 28 03/23/2026 02:16:22.240 7fc44e36b7c0 [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/23/2026 02:16:22.240 7fc44e36b7c0 [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/23/2026 02:16:22.240 7fc44e36b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.240 7fc44e36b7c0 [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=406884542, session_epoch=272, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.240 7fc44e36b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=406884542, session_epoch=272, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.240 7fc44e36b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278959.728027, idle connection 217135.000000, request 304999.957085 03/23/2026 02:16:22.241 7fc44e36b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278959.396729, idle connection 217135.000000, request 304999.629021 03/23/2026 02:16:22.269 7fc44c5a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278344.842529, idle connection 216837.000000, request 304399.157763 03/23/2026 02:16:22.270 7fc44c5a6d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 03/23/2026 02:16:22.270 7fc44c5a6d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.270 7fc44c5a6d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 272 (601.2520790100098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=593055773, topics=[]) 03/23/2026 02:16:22.270 7fc44c5a6d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 593055773 with 0 response partitions (1 implied) 03/23/2026 02:16:22.282 7fc44e36b040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 25 03/23/2026 02:16:22.282 7fc44e36b040 [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/23/2026 02:16:22.282 7fc44e36b040 [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/23/2026 02:16:22.283 7fc44e36b040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.283 7fc44e36b040 [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=1650040860, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.283 7fc44e36b040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1650040860, session_epoch=274, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.283 7fc44e36b040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277735.766602, idle connection 217041.000000, request 304999.936581 03/23/2026 02:16:22.283 7fc44e36b040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277735.316650, idle connection 217040.000000, request 304999.499083 03/23/2026 02:16:22.330 7fc44bba5d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 03/23/2026 02:16:22.330 7fc44bba5d60 [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/23/2026 02:16:22.330 7fc44bba5d60 [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/23/2026 02:16:22.330 7fc44bba5d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.330 7fc44bba5d60 [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=1044719715, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.330 7fc44bba5d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1044719715, session_epoch=267, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.330 7fc44bba5d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277746.737305, idle connection 216923.000000, request 304999.945641 03/23/2026 02:16:22.331 7fc44bba5d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277746.278564, idle connection 216923.000000, request 304999.495029 03/23/2026 02:16:22.354 7fc44c18a040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 61 03/23/2026 02:16:22.354 7fc44c18a040 [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/23/2026 02:16:22.354 7fc44c18a040 [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/23/2026 02:16:22.354 7fc44c18a040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.355 7fc44c18a040 [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=1259605411, session_epoch=282, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.355 7fc44c18a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 285 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1259605411, session_epoch=282, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.355 7fc44c18a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277747.693115, idle connection 216948.000000, request 304999.939919 03/23/2026 02:16:22.355 7fc44c18a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277747.327148, idle connection 216948.000000, request 304999.578953 03/23/2026 02:16:22.374 7fc44e36bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277647.520020, idle connection 217013.000000, request 304399.091959 03/23/2026 02:16:22.374 7fc44e36bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 03/23/2026 02:16:22.374 7fc44e36bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.374 7fc44e36bcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 282 (601.3715267181396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=736006542, topics=[]) 03/23/2026 02:16:22.375 7fc44e36bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 736006542 with 0 response partitions (1 implied) 03/23/2026 02:16:22.402 7fc44e36be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 109 03/23/2026 02:16:22.402 7fc44e36be00 [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/23/2026 02:16:22.403 7fc44e36be00 [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/23/2026 02:16:22.403 7fc44e36be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.403 7fc44e36be00 [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=1091956160, session_epoch=283, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.403 7fc44e36be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1091956160, session_epoch=283, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.403 7fc44e36be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278246.853271, idle connection 217022.000000, request 304999.953508 03/23/2026 02:16:22.403 7fc44e36be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278246.483643, idle connection 217022.000000, request 304999.590874 03/23/2026 02:16:22.430 7fc44e2574a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 155 03/23/2026 02:16:22.430 7fc44e2574a0 [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/23/2026 02:16:22.430 7fc44e2574a0 [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/23/2026 02:16:22.430 7fc44e2574a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.430 7fc44e2574a0 [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=987292387, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.430 7fc44e2574a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=987292387, session_epoch=285, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.430 7fc44e2574a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278938.437012, idle connection 217126.000000, request 304999.946833 03/23/2026 02:16:22.431 7fc44e36ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48 03/23/2026 02:16:22.431 7fc44e36ba40 [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/23/2026 02:16:22.431 7fc44e36ba40 [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/23/2026 02:16:22.431 7fc44e36ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.431 7fc44e36ba40 [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=1014471641, session_epoch=278, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.431 7fc44e36ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1014471641, session_epoch=278, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.431 7fc44e36ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277732.132568, idle connection 216963.000000, request 304999.962330 03/23/2026 02:16:22.431 7fc44e2574a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278937.344727, idle connection 217125.000000, request 304998.861790 03/23/2026 02:16:22.432 7fc44e36ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277731.353760, idle connection 216963.000000, request 304999.186993 03/23/2026 02:16:22.446 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277921.020508, idle connection 216664.000000, request 304399.198055 03/23/2026 02:16:22.446 7fc44c5a6ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 416 03/23/2026 02:16:22.446 7fc44c5a6ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.446 7fc44c5a6ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 416 (601.3741493225098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=171809573, topics=[]) 03/23/2026 02:16:22.446 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 171809573 with 0 response partitions (1 implied) 03/23/2026 02:16:22.454 7fc44e36b4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 13 03/23/2026 02:16:22.454 7fc44e36b4a0 [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/23/2026 02:16:22.454 7fc44e36b4a0 [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/23/2026 02:16:22.455 7fc44e36b4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.455 7fc44e36b4a0 [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=1996197811, session_epoch=271, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.455 7fc44e36b4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 274 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1996197811, session_epoch=271, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.455 7fc44e36b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277722.164551, idle connection 216889.000000, request 304999.931812 03/23/2026 02:16:22.455 7fc44c18a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278324.755615, idle connection 216803.000000, request 304397.524834 03/23/2026 02:16:22.456 7fc44e36b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277721.418213, idle connection 216888.000000, request 304999.193907 03/23/2026 02:16:22.456 7fc44c18a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:22.456 7fc44c18a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.456 7fc44c18a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (603.4469604492188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=664204336, topics=[]) 03/23/2026 02:16:22.457 7fc44c18a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 664204336 with 0 response partitions (1 implied) 03/23/2026 02:16:22.503 7fc44e257680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278343.988525, idle connection 217039.000000, request 304398.932934 03/23/2026 02:16:22.503 7fc44e257680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 03/23/2026 02:16:22.503 7fc44e257680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.503 7fc44e257680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 293 (601.7870903015137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=651604046, topics=[]) 03/23/2026 02:16:22.504 7fc44e257680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 651604046 with 0 response partitions (1 implied) 03/23/2026 02:16:22.571 7fc44e36b720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 34 03/23/2026 02:16:22.571 7fc44e36b720 [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/23/2026 02:16:22.571 7fc44e36b720 [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/23/2026 02:16:22.571 7fc44e36b720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.571 7fc44e36b720 [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=213155310, session_epoch=276, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.571 7fc44e36b720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=213155310, session_epoch=276, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.572 7fc44e36b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277717.971924, idle connection 216784.000000, request 304999.948263 03/23/2026 02:16:22.572 7fc44e36bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278320.733398, idle connection 216906.000000, request 304397.158623 03/23/2026 02:16:22.572 7fc44e36b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277717.359619, idle connection 216783.000000, request 304999.344349 03/23/2026 02:16:22.572 7fc44e36bae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 03/23/2026 02:16:22.572 7fc44e36bae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.573 7fc44e36bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 288 (603.611946105957 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927992269, topics=[]) 03/23/2026 02:16:22.573 7fc44e36bae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927992269 with 0 response partitions (1 implied) 03/23/2026 02:16:22.582 7fc44eee3f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2 03/23/2026 02:16:22.582 7fc44eee3f40 [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/23/2026 02:16:22.582 7fc44eee3f40 [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/23/2026 02:16:22.582 7fc44eee3f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.583 7fc44eee3f40 [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=1725652678, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.583 7fc44eee3f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1725652678, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.583 7fc44eee3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277743.225098, idle connection 216582.000000, request 304999.947309 03/23/2026 02:16:22.583 7fc44eee3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277742.775391, idle connection 216582.000000, request 304999.499798 03/23/2026 02:16:22.603 7fc44e257180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 264 03/23/2026 02:16:22.603 7fc44e257180 [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/23/2026 02:16:22.603 7fc44e257180 [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/23/2026 02:16:22.603 7fc44e257180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.604 7fc44e257180 [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=474087266, session_epoch=299, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.604 7fc44e257180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 302 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=474087266, session_epoch=299, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.604 7fc44e257180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278240.083252, idle connection 216897.000000, request 304999.930382 03/23/2026 02:16:22.605 7fc44e257180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278239.489258, idle connection 216896.000000, request 304999.348879 03/23/2026 02:16:22.621 7fc44e36b180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 63 03/23/2026 02:16:22.622 7fc44e36b180 [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/23/2026 02:16:22.622 7fc44e36b180 [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/23/2026 02:16:22.622 7fc44e36b180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.622 7fc44e36b180 [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=1524502808, session_epoch=281, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.622 7fc44e36b180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 284 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1524502808, session_epoch=281, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.622 7fc44e36b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277715.319580, idle connection 216698.000000, request 304999.946117 03/23/2026 02:16:22.623 7fc44e36b180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277714.854004, idle connection 216697.000000, request 304999.485731 03/23/2026 02:16:22.638 7fc44e36bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 87 03/23/2026 02:16:22.638 7fc44e36bc20 [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/23/2026 02:16:22.639 7fc44e36bc20 [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/23/2026 02:16:22.639 7fc44e36bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.639 7fc44e36bc20 [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=1354711734, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.639 7fc44e36bc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1354711734, session_epoch=284, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.639 7fc44e36bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277750.311279, idle connection 216793.000000, request 304999.937296 03/23/2026 02:16:22.640 7fc44e36bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277749.915527, idle connection 216792.000000, request 304999.549866 03/23/2026 02:16:22.712 7fc44bba5e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278338.815186, idle connection 216510.000000, request 304399.127722 03/23/2026 02:16:22.713 7fc44bba5e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/23/2026 02:16:22.713 7fc44bba5e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.713 7fc44bba5e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 271 (601.4127731323242 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=399975691, topics=[]) 03/23/2026 02:16:22.713 7fc44bba5e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 399975691 with 0 response partitions (1 implied) 03/23/2026 02:16:22.721 7fc44c5a6860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277116.276367, idle connection 216374.000000, request 304399.055958 03/23/2026 02:16:22.721 7fc44c5a6860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:22.721 7fc44c5a6860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.721 7fc44c5a6860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (601.4494895935059 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1331112178, topics=[]) 03/23/2026 02:16:22.722 7fc44c5a6860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1331112178 with 0 response partitions (1 implied) 03/23/2026 02:16:22.722 7fc44e36bea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 234 03/23/2026 02:16:22.722 7fc44e36bea0 [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/23/2026 02:16:22.722 7fc44e36bea0 [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/23/2026 02:16:22.722 7fc44e36bea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.722 7fc44e36bea0 [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=1646947982, session_epoch=299, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.722 7fc44e36bea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 302 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1646947982, session_epoch=299, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.722 7fc44e36bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277734.969238, idle connection 216733.000000, request 304999.959946 03/23/2026 02:16:22.722 7fc44bba5720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 03/23/2026 02:16:22.722 7fc44bba5720 [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/23/2026 02:16:22.723 7fc44bba5720 [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/23/2026 02:16:22.723 7fc44bba5720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.723 7fc44bba5720 [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=67906960, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.723 7fc44bba5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=67906960, session_epoch=269, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.723 7fc44bba5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277757.480469, idle connection 216512.000000, request 304999.964476 03/23/2026 02:16:22.723 7fc44e36bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277734.002441, idle connection 216732.000000, request 304998.997211 03/23/2026 02:16:22.724 7fc44bba5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277756.819580, idle connection 216511.000000, request 304999.305964 03/23/2026 02:16:22.768 7fc44c5a69a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277143.328857, idle connection 216334.000000, request 304399.127007 03/23/2026 02:16:22.769 7fc44c5a69a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:22.769 7fc44c5a69a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.769 7fc44c5a69a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (601.3977527618408 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=356390323, topics=[]) 03/23/2026 02:16:22.769 7fc44c5a69a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 356390323 with 0 response partitions (1 implied) 03/23/2026 02:16:22.784 7fc44c5a6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277039.460205, idle connection 216320.000000, request 304399.218321 03/23/2026 02:16:22.785 7fc44c5a6c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 273 03/23/2026 02:16:22.785 7fc44c5a6c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.785 7fc44c5a6c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 273 (601.2496948242188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1008941912, topics=[]) 03/23/2026 02:16:22.785 7fc44c5a6c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1008941912 with 0 response partitions (1 implied) 03/23/2026 02:16:22.812 7fc44bba5400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277152.783203, idle connection 216355.000000, request 304399.185419 03/23/2026 02:16:22.812 7fc44bba5400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:22.812 7fc44bba5400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.812 7fc44bba5400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (601.311206817627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1918797836, topics=[]) 03/23/2026 02:16:22.812 7fc44bba5400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1918797836 with 0 response partitions (1 implied) 03/23/2026 02:16:22.819 7fc44c5a6ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 62 03/23/2026 02:16:22.819 7fc44c5a6ae0 [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/23/2026 02:16:22.819 7fc44c5a6ae0 [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/23/2026 02:16:22.819 7fc44c5a6ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.819 7fc44c5a6ae0 [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=1379646182, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.819 7fc44c5a6ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1379646182, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.819 7fc44c5a6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277049.748779, idle connection 216281.000000, request 304999.956608 03/23/2026 02:16:22.820 7fc44c5a6ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277049.374023, idle connection 216281.000000, request 304999.587297 03/23/2026 02:16:22.820 7fc44e2577c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277657.745850, idle connection 216745.000000, request 304399.250984 03/23/2026 02:16:22.820 7fc44e2577c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 03/23/2026 02:16:22.820 7fc44e2577c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.820 7fc44e2577c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 296 (601.1147499084473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1295728411, topics=[]) 03/23/2026 02:16:22.820 7fc44e2577c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1295728411 with 0 response partitions (1 implied) 03/23/2026 02:16:22.833 7fc44e36b360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 197 03/23/2026 02:16:22.833 7fc44e36b360 [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/23/2026 02:16:22.833 7fc44e36b360 [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/23/2026 02:16:22.833 7fc44e36b360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.833 7fc44e36b360 [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=138193259, session_epoch=296, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.833 7fc44e36b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=138193259, session_epoch=296, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.833 7fc44e36b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278254.991455, idle connection 216661.000000, request 304999.954462 03/23/2026 02:16:22.834 7fc44e36b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278254.619141, idle connection 216660.000000, request 304999.587774 03/23/2026 02:16:22.835 7fc44e257720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278359.108643, idle connection 216741.000000, request 304399.357319 03/23/2026 02:16:22.835 7fc44e257720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 03/23/2026 02:16:22.835 7fc44e257720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.835 7fc44e257720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 304 (600.9683609008789 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1542934703, topics=[]) 03/23/2026 02:16:22.835 7fc44e257720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1542934703 with 0 response partitions (1 implied) 03/23/2026 02:16:22.841 7fc44e36b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278359.085449, idle connection 216535.000000, request 304399.313211 03/23/2026 02:16:22.841 7fc44e36b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 275 03/23/2026 02:16:22.841 7fc44e36b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.841 7fc44e36b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 275 (601.0532379150391 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=406884542, topics=[]) 03/23/2026 02:16:22.841 7fc44e36b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 406884542 with 0 response partitions (1 implied) 03/23/2026 02:16:22.870 7fc44c5a6d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 7 03/23/2026 02:16:22.870 7fc44c5a6d60 [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/23/2026 02:16:22.870 7fc44c5a6d60 [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/23/2026 02:16:22.871 7fc44c5a6d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.871 7fc44c5a6d60 [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=593055773, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.871 7fc44c5a6d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=593055773, session_epoch=270, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.871 7fc44c5a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277743.341553, idle connection 216235.000000, request 304999.953032 03/23/2026 02:16:22.871 7fc44c5a6d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277742.945801, idle connection 216235.000000, request 304999.563694 03/23/2026 02:16:22.884 7fc44e36b040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277134.878662, idle connection 216440.000000, request 304399.055243 03/23/2026 02:16:22.884 7fc44e36b040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 03/23/2026 02:16:22.884 7fc44e36b040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.884 7fc44e36b040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 277 (601.3960838317871 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1650040860, topics=[]) 03/23/2026 02:16:22.884 7fc44e36b040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1650040860 with 0 response partitions (1 implied) 03/23/2026 02:16:22.932 7fc44bba5d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277145.336182, idle connection 216322.000000, request 304398.544550 03/23/2026 02:16:22.932 7fc44bba5d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 03/23/2026 02:16:22.932 7fc44bba5d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.932 7fc44bba5d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 270 (601.9384860992432 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1044719715, topics=[]) 03/23/2026 02:16:22.932 7fc44bba5d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1044719715 with 0 response partitions (1 implied) 03/23/2026 02:16:22.957 7fc44c18a040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277145.479248, idle connection 216346.000000, request 304397.724390 03/23/2026 02:16:22.957 7fc44c18a040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 03/23/2026 02:16:22.957 7fc44c18a040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:22.957 7fc44c18a040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 285 (602.7123928070068 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1259605411, topics=[]) 03/23/2026 02:16:22.958 7fc44c18a040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1259605411 with 0 response partitions (1 implied) 03/23/2026 02:16:22.975 7fc44e36bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44 03/23/2026 02:16:22.975 7fc44e36bcc0 [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/23/2026 02:16:22.975 7fc44e36bcc0 [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/23/2026 02:16:22.975 7fc44e36bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:22.975 7fc44e36bcc0 [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=736006542, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.975 7fc44e36bcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=736006542, session_epoch=280, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:22.976 7fc44e36bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277045.956055, idle connection 216412.000000, request 304999.953508 03/23/2026 02:16:22.976 7fc44e36bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277045.535156, idle connection 216411.000000, request 304999.539614 03/23/2026 02:16:23.004 7fc44e36be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277645.805420, idle connection 216421.000000, request 304398.902178 03/23/2026 02:16:23.004 7fc44e36be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 03/23/2026 02:16:23.004 7fc44e36be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:23.005 7fc44e36be00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 286 (601.6354560852051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1091956160, topics=[]) 03/23/2026 02:16:23.005 7fc44e36be00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1091956160 with 0 response partitions (1 implied) 03/23/2026 02:16:23.033 7fc44e2574a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 278335.520264, idle connection 216523.000000, request 304397.032499 03/23/2026 02:16:23.034 7fc44e36ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277129.712402, idle connection 216361.000000, request 304397.544384 03/23/2026 02:16:23.034 7fc44e2574a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 03/23/2026 02:16:23.034 7fc44e2574a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:23.034 7fc44e2574a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 288 (603.6288738250732 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=987292387, topics=[]) 03/23/2026 02:16:23.034 7fc44e2574a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 987292387 with 0 response partitions (1 implied) 03/23/2026 02:16:23.034 7fc44e36ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 03/23/2026 02:16:23.034 7fc44e36ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:23.034 7fc44e36ba40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 281 (603.3825874328613 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1014471641, topics=[]) 03/23/2026 02:16:23.035 7fc44e36ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1014471641 with 0 response partitions (1 implied) 03/23/2026 02:16:23.047 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3995 03/23/2026 02:16:23.047 7fc44c5a6ea0 [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/23/2026 02:16:23.047 7fc44c5a6ea0 [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/23/2026 02:16:23.047 7fc44c5a6ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:23.047 7fc44c5a6ea0 [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=171809573, session_epoch=414, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.047 7fc44c5a6ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 417 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=171809573, session_epoch=414, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.047 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277319.185547, idle connection 216062.000000, request 304999.949694 03/23/2026 02:16:23.048 7fc44c5a6ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277318.727783, idle connection 216061.000000, request 304999.496698 03/23/2026 02:16:23.057 7fc44c18a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1 03/23/2026 02:16:23.057 7fc44c18a540 [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/23/2026 02:16:23.057 7fc44c18a540 [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/23/2026 02:16:23.057 7fc44c18a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:23.057 7fc44c18a540 [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=664204336, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.058 7fc44c18a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=664204336, session_epoch=268, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.058 7fc44c18a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277722.317383, idle connection 216200.000000, request 304999.947786 03/23/2026 02:16:23.058 7fc44e36b4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277119.162109, idle connection 216286.000000, request 304396.938562 03/23/2026 02:16:23.058 7fc44c18a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277721.641846, idle connection 216199.000000, request 304999.278307 03/23/2026 02:16:23.059 7fc44e36b4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 03/23/2026 02:16:23.059 7fc44e36b4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:23.059 7fc44e36b4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 274 (603.9266586303711 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1996197811, topics=[]) 03/23/2026 02:16:23.059 7fc44e36b4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1996197811 with 0 response partitions (1 implied) 03/23/2026 02:16:23.104 7fc44e257680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 122 03/23/2026 02:16:23.105 7fc44e257680 [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/23/2026 02:16:23.105 7fc44e257680 [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/23/2026 02:16:23.105 7fc44e257680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:23.105 7fc44e257680 [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=651604046, session_epoch=291, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.105 7fc44e257680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=651604046, session_epoch=291, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.105 7fc44e257680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277741.422607, idle connection 216437.000000, request 304999.933243 03/23/2026 02:16:23.106 7fc44e257680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277740.927246, idle connection 216436.000000, request 304999.444962 03/23/2026 02:16:23.173 7fc44e36bae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 143 03/23/2026 02:16:23.173 7fc44e36bae0 [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/23/2026 02:16:23.173 7fc44e36bae0 [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/23/2026 02:16:23.173 7fc44e36bae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/23/2026 02:16:23.174 7fc44e36bae0 [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=1927992269, session_epoch=286, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.174 7fc44e36bae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 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=1927992269, session_epoch=286, topics=[], forgotten_topics_data=[]) 03/23/2026 02:16:23.174 7fc44e36bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277718.725098, idle connection 216304.000000, request 304999.948502 03/23/2026 02:16:23.174 7fc44e36b720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277115.450928, idle connection 216181.000000, request 304397.434235 03/23/2026 02:16:23.174 7fc44e36bae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277718.143311, idle connection 216303.000000, request 304999.376059 03/23/2026 02:16:23.175 7fc44e36b720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 03/23/2026 02:16:23.175 7fc44e36b720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:23.175 7fc44e36b720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 279 (603.2524108886719 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=213155310, topics=[]) 03/23/2026 02:16:23.175 7fc44e36b720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 213155310 with 0 response partitions (1 implied) 03/23/2026 02:16:23.184 7fc44eee3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 277142.245850, idle connection 215981.000000, request 304398.968697 03/23/2026 02:16:23.184 7fc44eee3f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 03/23/2026 02:16:23.184 7fc44eee3f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/23/2026 02:16:23.184 7fc44eee3f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 271 (601.6025543212891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725652678, topics=[]) 03/23/2026 02:16:23.185 7fc44eee3f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725652678 with 0 response partitions (1 implied)