06/01/2026 02:03:27.285 7f2232af0ae0 [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=508963226, session_epoch=293, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.285 7f2232af0ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=508963226, session_epoch=293, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.285 7f2232af0ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281849.529541, idle connection 220021.000000, request 304999.948978 06/01/2026 02:03:27.285 7f2233330a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 41 06/01/2026 02:03:27.285 7f2233330a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/01/2026 02:03:27.285 7f2233330a40 [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)]) 06/01/2026 02:03:27.285 7f2233330a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.286 7f2233330a40 [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=1346239678, session_epoch=277, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.286 7f2233330a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1346239678, session_epoch=277, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.286 7f2233330a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281350.415039, idle connection 219837.000000, request 304999.967337 06/01/2026 02:03:27.286 7f2232af0ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281848.531006, idle connection 220020.000000, request 304998.957396 06/01/2026 02:03:27.286 7f2233330a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281349.800049, idle connection 219836.000000, request 304999.354601 06/01/2026 02:03:27.337 7f2232af0400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281246.470215, idle connection 219899.000000, request 304398.028612 06/01/2026 02:03:27.337 7f2232af0400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 06/01/2026 02:03:27.337 7f2232af0400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.337 7f2232af0400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 292 (602.4303436279297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1522637316, topics=[]) 06/01/2026 02:03:27.337 7f2232af0400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1522637316 with 0 response partitions (1 implied) 06/01/2026 02:03:27.338 7f2233330680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280743.314209, idle connection 219802.000000, request 304398.047924 06/01/2026 02:03:27.338 7f2233330680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 06/01/2026 02:03:27.338 7f2233330680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.338 7f2233330680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 276 (602.2272109985352 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1650633335, topics=[]) 06/01/2026 02:03:27.338 7f2233330680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1650633335 with 0 response partitions (1 implied) 06/01/2026 02:03:27.353 7f223141bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280536.518066, idle connection 219553.000000, request 304399.096727 06/01/2026 02:03:27.353 7f223141bf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 415 06/01/2026 02:03:27.353 7f223141bf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.354 7f223141bf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 415 (601.2728214263916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=23301185, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4213, last_stable_offset=4213, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10t\x00\x00\x01\x04\x00\x00\x00\x00\x02\x1d\xce\xcb\xf1\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...')])]) 06/01/2026 02:03:27.354 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 23301185 with 1 response partitions (0 implied) 06/01/2026 02:03:27.354 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4212 06/01/2026 02:03:27.354 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4212 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/01/2026 02:03:27.354 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4213 (leader epoch 0) 06/01/2026 02:03:27.364 7f2232a3a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280742.313232, idle connection 219668.000000, request 304398.288250 06/01/2026 02:03:27.364 7f2232a3a0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 06/01/2026 02:03:27.364 7f2232a3a0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.365 7f2232a3a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 272 (602.0820140838623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2115711820, topics=[]) 06/01/2026 02:03:27.365 7f2232a3a0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2115711820 with 0 response partitions (1 implied) 06/01/2026 02:03:27.365 7f2233330360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280744.552002, idle connection 219551.000000, request 304398.251295 06/01/2026 02:03:27.365 7f2233330360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 06/01/2026 02:03:27.365 7f2233330360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.365 7f2233330360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 279 (602.0593643188477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=696774841, topics=[]) 06/01/2026 02:03:27.365 7f2233330360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 696774841 with 0 response partitions (1 implied) 06/01/2026 02:03:27.408 7f223129b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280755.642822, idle connection 219687.000000, request 304399.067640 06/01/2026 02:03:27.408 7f223129b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 06/01/2026 02:03:27.408 7f223129b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.409 7f223129b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 268 (601.318359375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=827257133, topics=[]) 06/01/2026 02:03:27.409 7f223129b860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 827257133 with 0 response partitions (1 implied) 06/01/2026 02:03:27.416 7f2232af0680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 252 06/01/2026 02:03:27.416 7f2232af0680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 06/01/2026 02:03:27.417 7f2232af0680 [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)]) 06/01/2026 02:03:27.417 7f2232af0680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.417 7f2232af0680 [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=1908218613, session_epoch=295, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.417 7f2232af0680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1908218613, session_epoch=295, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.417 7f2232af0680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281362.094238, idle connection 219848.000000, request 304999.955893 06/01/2026 02:03:27.417 7f2232af0680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281361.706055, idle connection 219848.000000, request 304999.572277 06/01/2026 02:03:27.425 7f2232af07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281260.734131, idle connection 219844.000000, request 304398.966789 06/01/2026 02:03:27.425 7f2232af07c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 06/01/2026 02:03:27.425 7f2232af07c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.425 7f2232af07c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 295 (601.3965606689453 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=129266434, topics=[]) 06/01/2026 02:03:27.425 7f2232af07c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 129266434 with 0 response partitions (1 implied) 06/01/2026 02:03:27.449 7f2232af02c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 87 06/01/2026 02:03:27.449 7f2232af02c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/01/2026 02:03:27.449 7f2232af02c0 [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)]) 06/01/2026 02:03:27.449 7f2232af02c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.449 7f2232af02c0 [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=1805998205, session_epoch=287, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.449 7f2232af02c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 290 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1805998205, session_epoch=287, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.449 7f2232af02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281353.522949, idle connection 219817.000000, request 304999.934673 06/01/2026 02:03:27.450 7f2232af02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281352.985840, idle connection 219817.000000, request 304999.407291 06/01/2026 02:03:27.455 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4213 06/01/2026 02:03:27.455 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/01/2026 02:03:27.455 7f223141bf40 [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)]) 06/01/2026 02:03:27.455 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.455 7f223141bf40 [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=23301185, session_epoch=413, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4213, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:03:27.456 7f223141bf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=23301185, session_epoch=413, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4213, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:03:27.456 7f223141bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280433.949951, idle connection 219450.000000, request 304999.927998 06/01/2026 02:03:27.456 7f223141bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280433.421631, idle connection 219449.000000, request 304999.408484 06/01/2026 02:03:27.534 7f2232af0f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280755.610840, idle connection 219840.000000, request 304399.105072 06/01/2026 02:03:27.534 7f2232af0f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 06/01/2026 02:03:27.534 7f2232af0f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.535 7f2232af0f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 283 (601.3936996459961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1107962257, topics=[]) 06/01/2026 02:03:27.535 7f2232af0f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1107962257 with 0 response partitions (1 implied) 06/01/2026 02:03:27.617 7f22333307c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 52 06/01/2026 02:03:27.617 7f22333307c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/01/2026 02:03:27.617 7f22333307c0 [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)]) 06/01/2026 02:03:27.618 7f22333307c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.618 7f22333307c0 [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=1299511626, session_epoch=279, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.618 7f22333307c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1299511626, session_epoch=279, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.618 7f22333307c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280137.414795, idle connection 219492.000000, request 304999.932766 06/01/2026 02:03:27.619 7f22333307c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280136.893799, idle connection 219491.000000, request 304999.421835 06/01/2026 02:03:27.621 7f2232af0040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280737.682373, idle connection 219594.000000, request 304398.663282 06/01/2026 02:03:27.621 7f2232af0040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 06/01/2026 02:03:27.621 7f2232af0040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.622 7f2232af0040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 280 (601.945161819458 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050855878, topics=[]) 06/01/2026 02:03:27.622 7f2232af0040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1050855878 with 0 response partitions (1 implied) 06/01/2026 02:03:27.629 7f22333300e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 06/01/2026 02:03:27.629 7f22333300e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/01/2026 02:03:27.629 7f22333300e0 [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)]) 06/01/2026 02:03:27.629 7f22333300e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.630 7f22333300e0 [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=457098299, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.630 7f22333300e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 268 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=457098299, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.630 7f22333300e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280132.482178, idle connection 219280.000000, request 304999.953508 06/01/2026 02:03:27.630 7f22333302c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/01/2026 02:03:27.630 7f22333302c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/01/2026 02:03:27.630 7f22333302c0 [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)]) 06/01/2026 02:03:27.630 7f22333302c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.630 7f22333302c0 [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=934959855, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.630 7f22333302c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 268 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=934959855, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.630 7f22333302c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280143.647217, idle connection 219298.000000, request 304999.964237 06/01/2026 02:03:27.631 7f22333300e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280131.474854, idle connection 219279.000000, request 304998.951674 06/01/2026 02:03:27.631 7f2232a3a540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 06/01/2026 02:03:27.631 7f2232a3a540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/01/2026 02:03:27.631 7f2232a3a540 [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)]) 06/01/2026 02:03:27.631 7f2232a3a540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.631 7f2232a3a540 [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=1389387401, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.631 7f2232a3a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 268 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389387401, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.631 7f2232a3a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280144.290039, idle connection 219389.000000, request 304999.968290 06/01/2026 02:03:27.632 7f22333302c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280142.427979, idle connection 219297.000000, request 304998.748541 06/01/2026 02:03:27.632 7f2232a3a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280143.700439, idle connection 219389.000000, request 304999.381065 06/01/2026 02:03:27.703 7f2233330c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 30 06/01/2026 02:03:27.703 7f2233330c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/01/2026 02:03:27.703 7f2233330c20 [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)]) 06/01/2026 02:03:27.703 7f2233330c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.703 7f2233330c20 [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=120157812, session_epoch=274, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.703 7f2233330c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=120157812, session_epoch=274, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.703 7f2233330c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280099.024902, idle connection 219461.000000, request 304999.955654 06/01/2026 02:03:27.703 7f2233330d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 56 06/01/2026 02:03:27.704 7f2233330d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 06/01/2026 02:03:27.704 7f2233330d60 [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)]) 06/01/2026 02:03:27.704 7f2233330d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.704 7f2233330d60 [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=727118585, session_epoch=280, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.704 7f2233330d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=727118585, session_epoch=280, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.704 7f2233330d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281305.879395, idle connection 219491.000000, request 304999.967098 06/01/2026 02:03:27.704 7f2233330c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280098.077393, idle connection 219460.000000, request 304999.013662 06/01/2026 02:03:27.704 7f2233330d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281305.295410, idle connection 219490.000000, request 304999.385357 06/01/2026 02:03:27.711 7f2232a3a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280758.943359, idle connection 219336.000000, request 304399.193525 06/01/2026 02:03:27.711 7f2232a3a4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 06/01/2026 02:03:27.711 7f2232a3a4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.712 7f2232a3a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 270 (601.158857345581 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=18659508, topics=[]) 06/01/2026 02:03:27.712 7f2232a3a4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 18659508 with 0 response partitions (1 implied) 06/01/2026 02:03:27.721 7f2232af0180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 155 06/01/2026 02:03:27.721 7f2232af0180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/01/2026 02:03:27.721 7f2232af0180 [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)]) 06/01/2026 02:03:27.721 7f2232af0180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.721 7f2232af0180 [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=1301840714, session_epoch=278, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.721 7f2232af0180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1301840714, session_epoch=278, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.721 7f2232af0180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280153.723877, idle connection 219505.000000, request 304999.958277 06/01/2026 02:03:27.722 7f2232af0540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281251.787842, idle connection 219622.000000, request 304397.875309 06/01/2026 02:03:27.722 7f2232af0180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280153.224609, idle connection 219505.000000, request 304999.463797 06/01/2026 02:03:27.722 7f2232af0540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 06/01/2026 02:03:27.722 7f2232af0540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.722 7f2232af0540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 300 (602.7565002441406 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1005895647, topics=[]) 06/01/2026 02:03:27.722 7f2232af0540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1005895647 with 0 response partitions (1 implied) 06/01/2026 02:03:27.805 7f2232af0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280697.802490, idle connection 219522.000000, request 304399.152517 06/01/2026 02:03:27.806 7f2232af0e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 06/01/2026 02:03:27.806 7f2232af0e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.806 7f2232af0e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 294 (601.2709140777588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=547709474, topics=[]) 06/01/2026 02:03:27.806 7f2232af0e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 547709474 with 0 response partitions (1 implied) 06/01/2026 02:03:27.807 7f223129bea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 06/01/2026 02:03:27.807 7f223129bea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/01/2026 02:03:27.807 7f223129bea0 [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)]) 06/01/2026 02:03:27.807 7f223129bea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.807 7f223129bea0 [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=515664096, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.807 7f223129bea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 268 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515664096, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.807 7f223129bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280122.734619, idle connection 219249.000000, request 304999.961138 06/01/2026 02:03:27.807 7f223129bea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280122.393799, idle connection 219249.000000, request 304999.622822 06/01/2026 02:03:27.808 7f223129b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 06/01/2026 02:03:27.808 7f223129b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/01/2026 02:03:27.808 7f223129b7c0 [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)]) 06/01/2026 02:03:27.808 7f223129b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.808 7f223129b7c0 [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=604219321, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.808 7f223129b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 268 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=604219321, session_epoch=265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.808 7f223129b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280123.076904, idle connection 219266.000000, request 304999.967575 06/01/2026 02:03:27.808 7f223129b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280122.787842, idle connection 219265.000000, request 304999.680281 06/01/2026 02:03:27.809 7f2233330900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280705.546875, idle connection 219346.000000, request 304399.357319 06/01/2026 02:03:27.809 7f2233330900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 06/01/2026 02:03:27.809 7f2233330900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.810 7f2233330900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 274 (600.9469032287598 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1900749437, topics=[]) 06/01/2026 02:03:27.810 7f2233330900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1900749437 with 0 response partitions (1 implied) 06/01/2026 02:03:27.810 7f2230bb1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280737.091064, idle connection 219194.000000, request 304399.439335 06/01/2026 02:03:27.810 7f2230bb1180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 06/01/2026 02:03:27.810 7f2230bb1180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.811 7f2230bb1180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 268 (600.8386611938477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1696458894, topics=[]) 06/01/2026 02:03:27.811 7f2230bb1180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1696458894 with 0 response partitions (1 implied) 06/01/2026 02:03:27.811 7f2230bb1e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280737.407471, idle connection 219186.000000, request 304399.355173 06/01/2026 02:03:27.812 7f2230bb1e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 06/01/2026 02:03:27.812 7f2230bb1e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.812 7f2230bb1e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 269 (600.9266376495361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217177441, topics=[]) 06/01/2026 02:03:27.812 7f2230bb1e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217177441 with 0 response partitions (1 implied) 06/01/2026 02:03:27.812 7f2232af0a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 240 06/01/2026 02:03:27.812 7f2232af0a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 06/01/2026 02:03:27.812 7f2232af0a40 [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)]) 06/01/2026 02:03:27.812 7f2232af0a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.812 7f2232af0a40 [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=1462548079, session_epoch=296, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.813 7f2232af0a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1462548079, session_epoch=296, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.813 7f2232af0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281362.830078, idle connection 219571.000000, request 304999.968290 06/01/2026 02:03:27.813 7f2232af0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281362.550537, idle connection 219570.000000, request 304999.690294 06/01/2026 02:03:27.854 7f2233330f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 43 06/01/2026 02:03:27.855 7f2233330f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/01/2026 02:03:27.855 7f2233330f40 [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)]) 06/01/2026 02:03:27.855 7f2233330f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.855 7f2233330f40 [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=455879733, session_epoch=277, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.855 7f2233330f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=455879733, session_epoch=277, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.855 7f2233330f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280154.207764, idle connection 219324.000000, request 304999.953032 06/01/2026 02:03:27.856 7f2233330f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280153.796143, idle connection 219323.000000, request 304999.547005 06/01/2026 02:03:27.887 7f2232af0ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281247.899170, idle connection 219419.000000, request 304398.323059 06/01/2026 02:03:27.887 7f2232af0ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 06/01/2026 02:03:27.887 7f2232af0ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.887 7f2232af0ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 296 (602.0638942718506 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=508963226, topics=[]) 06/01/2026 02:03:27.887 7f2232af0ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 508963226 with 0 response partitions (1 implied) 06/01/2026 02:03:27.887 7f2233330a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280748.721680, idle connection 219235.000000, request 304398.273945 06/01/2026 02:03:27.888 7f2233330a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 06/01/2026 02:03:27.888 7f2233330a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:27.888 7f2233330a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 280 (602.0033359527588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1346239678, topics=[]) 06/01/2026 02:03:27.888 7f2233330a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1346239678 with 0 response partitions (1 implied) 06/01/2026 02:03:27.938 7f2232af0400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 211 06/01/2026 02:03:27.938 7f2232af0400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 06/01/2026 02:03:27.938 7f2232af0400 [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)]) 06/01/2026 02:03:27.938 7f2232af0400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.938 7f2232af0400 [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=1522637316, session_epoch=290, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.938 7f2232af0400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1522637316, session_epoch=290, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.938 7f2232af0400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280644.967285, idle connection 219297.000000, request 304999.954700 06/01/2026 02:03:27.938 7f2233330680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 37 06/01/2026 02:03:27.938 7f2233330680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 06/01/2026 02:03:27.939 7f2233330680 [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)]) 06/01/2026 02:03:27.939 7f2233330680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.939 7f2233330680 [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=1650633335, session_epoch=274, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.939 7f2233330680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1650633335, session_epoch=274, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.939 7f2233330680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280141.955811, idle connection 219200.000000, request 304999.966860 06/01/2026 02:03:27.939 7f2232af0400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280643.968750, idle connection 219296.000000, request 304998.961926 06/01/2026 02:03:27.940 7f2233330680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280141.340820, idle connection 219200.000000, request 304999.355555 06/01/2026 02:03:27.965 7f2232a3a0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 10 06/01/2026 02:03:27.965 7f2232a3a0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/01/2026 02:03:27.965 7f2232a3a0e0 [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)]) 06/01/2026 02:03:27.965 7f2232a3a0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.965 7f2232a3a0e0 [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=2115711820, session_epoch=270, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.965 7f2232a3a0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=2115711820, session_epoch=270, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.966 7f2232a3a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280140.924316, idle connection 219067.000000, request 304999.956608 06/01/2026 02:03:27.966 7f2233330360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 06/01/2026 02:03:27.966 7f2233330360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 06/01/2026 02:03:27.966 7f2233330360 [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)]) 06/01/2026 02:03:27.966 7f2233330360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:27.966 7f2233330360 [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=696774841, session_epoch=277, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.966 7f2233330360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=696774841, session_epoch=277, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:27.966 7f2233330360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280143.228027, idle connection 218949.000000, request 304999.955893 06/01/2026 02:03:27.966 7f2232a3a0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280140.011719, idle connection 219066.000000, request 304999.047518 06/01/2026 02:03:27.967 7f2233330360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280142.689453, idle connection 218949.000000, request 304999.419689 06/01/2026 02:03:28.009 7f223129b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 2 06/01/2026 02:03:28.009 7f223129b860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/01/2026 02:03:28.009 7f223129b860 [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)]) 06/01/2026 02:03:28.009 7f223129b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.009 7f223129b860 [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=827257133, session_epoch=266, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.010 7f223129b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=827257133, session_epoch=266, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.010 7f223129b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280154.200439, idle connection 219085.000000, request 304999.956131 06/01/2026 02:03:28.010 7f223129b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280153.865723, idle connection 219085.000000, request 304999.624968 06/01/2026 02:03:28.018 7f2232af0680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280761.400391, idle connection 219248.000000, request 304399.265766 06/01/2026 02:03:28.018 7f2232af0680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 298 06/01/2026 02:03:28.018 7f2232af0680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.018 7f2232af0680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 298 (601.1006832122803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1908218613, topics=[]) 06/01/2026 02:03:28.018 7f2232af0680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1908218613 with 0 response partitions (1 implied) 06/01/2026 02:03:28.025 7f2232af07c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 205 06/01/2026 02:03:28.025 7f2232af07c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 06/01/2026 02:03:28.025 7f2232af07c0 [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)]) 06/01/2026 02:03:28.026 7f2232af07c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.026 7f2232af07c0 [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=129266434, session_epoch=293, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.026 7f2232af07c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=129266434, session_epoch=293, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.026 7f2232af07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280659.475098, idle connection 219243.000000, request 304999.957561 06/01/2026 02:03:28.026 7f2232af07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280659.125977, idle connection 219242.000000, request 304999.612093 06/01/2026 02:03:28.050 7f2232af02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280752.530273, idle connection 219217.000000, request 304398.949385 06/01/2026 02:03:28.051 7f2232af02c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 06/01/2026 02:03:28.051 7f2232af02c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.051 7f2232af02c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 290 (601.4814376831055 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1805998205, topics=[]) 06/01/2026 02:03:28.051 7f2232af02c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1805998205 with 0 response partitions (1 implied) 06/01/2026 02:03:28.057 7f223141bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279833.066406, idle connection 218849.000000, request 304399.052858 06/01/2026 02:03:28.057 7f223141bf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 416 06/01/2026 02:03:28.057 7f223141bf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.057 7f223141bf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 416 (601.3457775115967 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=23301185, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4214, last_stable_offset=4214, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10u\x00\x00\x01\x04\x00\x00\x00\x00\x02\xbf\xa4\xc6\xec\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...')])]) 06/01/2026 02:03:28.057 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 23301185 with 1 response partitions (0 implied) 06/01/2026 02:03:28.057 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4213 06/01/2026 02:03:28.057 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4213 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/01/2026 02:03:28.058 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4214 (leader epoch 0) 06/01/2026 02:03:28.135 7f2232af0f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 95 06/01/2026 02:03:28.135 7f2232af0f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/01/2026 02:03:28.135 7f2232af0f40 [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)]) 06/01/2026 02:03:28.135 7f2232af0f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.135 7f2232af0f40 [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=1107962257, session_epoch=281, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.136 7f2232af0f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1107962257, session_epoch=281, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.136 7f2232af0f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280153.936523, idle connection 219238.000000, request 304999.944687 06/01/2026 02:03:28.136 7f2232af0f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280153.526123, idle connection 219238.000000, request 304999.533176 06/01/2026 02:03:28.158 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4214 06/01/2026 02:03:28.159 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/01/2026 02:03:28.159 7f223141bf40 [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)]) 06/01/2026 02:03:28.159 7f223141bf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.159 7f223141bf40 [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=23301185, session_epoch=414, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4214, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:03:28.159 7f223141bf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=23301185, session_epoch=414, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4214, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:03:28.159 7f223141bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279730.633057, idle connection 218747.000000, request 304999.952555 06/01/2026 02:03:28.160 7f223141bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279730.200439, idle connection 218746.000000, request 304999.525785 06/01/2026 02:03:28.219 7f22333307c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279536.355957, idle connection 218891.000000, request 304398.873568 06/01/2026 02:03:28.220 7f22333307c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 06/01/2026 02:03:28.220 7f22333307c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.220 7f22333307c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 282 (601.6886234283447 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1299511626, topics=[]) 06/01/2026 02:03:28.220 7f22333307c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1299511626 with 0 response partitions (1 implied) 06/01/2026 02:03:28.223 7f2232af0040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48 06/01/2026 02:03:28.223 7f2232af0040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/01/2026 02:03:28.223 7f2232af0040 [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)]) 06/01/2026 02:03:28.223 7f2232af0040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.223 7f2232af0040 [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=1050855878, session_epoch=278, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.223 7f2232af0040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1050855878, session_epoch=278, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.223 7f2232af0040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280135.377686, idle connection 218992.000000, request 304999.954939 06/01/2026 02:03:28.224 7f2232af0040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280134.996826, idle connection 218991.000000, request 304999.578476 06/01/2026 02:03:28.232 7f22333300e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279530.259521, idle connection 218678.000000, request 304397.733688 06/01/2026 02:03:28.232 7f22333300e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 06/01/2026 02:03:28.232 7f22333300e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.232 7f22333300e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 268 (602.6918888092041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=457098299, topics=[]) 06/01/2026 02:03:28.233 7f22333300e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 457098299 with 0 response partitions (1 implied) 06/01/2026 02:03:28.233 7f22333302c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279541.342529, idle connection 218696.000000, request 304397.661448 06/01/2026 02:03:28.233 7f2232a3a540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279542.807861, idle connection 218788.000000, request 304398.487568 06/01/2026 02:03:28.233 7f22333302c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 06/01/2026 02:03:28.233 7f22333302c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.233 7f22333302c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 268 (602.7750968933105 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=934959855, topics=[]) 06/01/2026 02:03:28.233 7f22333302c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 934959855 with 0 response partitions (1 implied) 06/01/2026 02:03:28.234 7f2232a3a540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 06/01/2026 02:03:28.234 7f2232a3a540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.234 7f2232a3a540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 268 (602.2915840148926 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1389387401, topics=[]) 06/01/2026 02:03:28.234 7f2232a3a540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1389387401 with 0 response partitions (1 implied) 06/01/2026 02:03:28.305 7f2233330c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279497.441162, idle connection 218859.000000, request 304398.368359 06/01/2026 02:03:28.305 7f2233330c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 06/01/2026 02:03:28.305 7f2233330c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.305 7f2233330c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 277 (602.1754741668701 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=120157812, topics=[]) 06/01/2026 02:03:28.306 7f2233330c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 120157812 with 0 response partitions (1 implied) 06/01/2026 02:03:28.306 7f2233330d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280704.020020, idle connection 218889.000000, request 304398.107052 06/01/2026 02:03:28.306 7f2233330d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 06/01/2026 02:03:28.306 7f2233330d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.306 7f2233330d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 283 (602.1931171417236 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=727118585, topics=[]) 06/01/2026 02:03:28.306 7f2233330d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 727118585 with 0 response partitions (1 implied) 06/01/2026 02:03:28.312 7f2232a3a4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 06/01/2026 02:03:28.312 7f2232a3a4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 06/01/2026 02:03:28.312 7f2232a3a4a0 [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)]) 06/01/2026 02:03:28.312 7f2232a3a4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.312 7f2232a3a4a0 [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=18659508, session_epoch=268, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.313 7f2232a3a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=18659508, session_epoch=268, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.313 7f2232a3a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280157.378662, idle connection 218734.000000, request 304999.953985 06/01/2026 02:03:28.313 7f2232a3a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280156.978760, idle connection 218734.000000, request 304999.558926 06/01/2026 02:03:28.324 7f2232af0540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 223 06/01/2026 02:03:28.324 7f2232af0540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/01/2026 02:03:28.324 7f2232af0540 [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)]) 06/01/2026 02:03:28.324 7f2232af0540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:03:28.324 7f2232af0540 [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=1005895647, session_epoch=298, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.324 7f2232af0540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 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=1005895647, session_epoch=298, topics=[], forgotten_topics_data=[]) 06/01/2026 02:03:28.324 7f2232af0540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280649.211914, idle connection 219019.000000, request 304999.954700 06/01/2026 02:03:28.324 7f2232af0180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 279550.712646, idle connection 218902.000000, request 304396.949768 06/01/2026 02:03:28.325 7f2232af0540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 280648.633545, idle connection 219018.000000, request 304999.382257 06/01/2026 02:03:28.325 7f2232af0180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 06/01/2026 02:03:28.325 7f2232af0180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:03:28.325 7f2232af0180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 281 (603.7836074829102 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1301840714, topics=[]) 06/01/2026 02:03:28.325 7f2232af0180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1301840714 with 0 response partitions (1 implied)