08/26/2025 00:16:52.361 7f1a10164a20 [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=1940314572, session_epoch=435, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4029, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/26/2025 00:16:52.361 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 438 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1940314572, session_epoch=435, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4029, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/26/2025 00:16:52.362 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284936.151855, idle connection 223786.000000, request 304999.933004 08/26/2025 00:16:52.362 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284935.727783, idle connection 223786.000000, request 304999.520063 08/26/2025 00:16:52.367 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 164 08/26/2025 00:16:52.367 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/26/2025 00:16:52.367 7f1a0d9c30f0 [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)]) 08/26/2025 00:16:52.367 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.368 7f1a0d9c30f0 [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=990538155, session_epoch=295, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.368 7f1a0d9c30f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=990538155, session_epoch=295, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.368 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284880.756348, idle connection 224202.000000, request 304999.952316 08/26/2025 00:16:52.368 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 180 08/26/2025 00:16:52.368 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 08/26/2025 00:16:52.368 7f1a0da236d8 [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)]) 08/26/2025 00:16:52.368 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.368 7f1a0da236d8 [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=252887164, session_epoch=287, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.368 7f1a0da236d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=252887164, session_epoch=287, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.369 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284885.715576, idle connection 224110.000000, request 304999.954700 08/26/2025 00:16:52.369 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284879.691162, idle connection 224201.000000, request 304998.890400 08/26/2025 00:16:52.369 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284885.039307, idle connection 224110.000000, request 304999.281645 08/26/2025 00:16:52.376 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 144 08/26/2025 00:16:52.376 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/26/2025 00:16:52.376 7f1a0eb09780 [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)]) 08/26/2025 00:16:52.376 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.376 7f1a0eb09780 [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=747538721, session_epoch=285, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.376 7f1a0eb09780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=747538721, session_epoch=285, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.376 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284879.637939, idle connection 224167.000000, request 304999.951124 08/26/2025 00:16:52.377 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285498.098633, idle connection 223831.000000, request 304396.866083 08/26/2025 00:16:52.377 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285519.372559, idle connection 224030.000000, request 304397.507191 08/26/2025 00:16:52.377 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284878.995605, idle connection 224166.000000, request 304999.313116 08/26/2025 00:16:52.377 7f1a0ebe7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:52.377 7f1a0ebe7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.378 7f1a0ebe7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (603.9443016052246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1293647306, topics=[]) 08/26/2025 00:16:52.378 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1293647306 with 0 response partitions (1 implied) 08/26/2025 00:16:52.378 7f1a0da37978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 08/26/2025 00:16:52.378 7f1a0da37978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.378 7f1a0da37978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 272 (603.6646366119385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1519939297, topics=[]) 08/26/2025 00:16:52.378 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1519939297 with 0 response partitions (1 implied) 08/26/2025 00:16:52.466 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285483.955566, idle connection 223990.000000, request 304399.011850 08/26/2025 00:16:52.466 7f1a0e81d6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 08/26/2025 00:16:52.466 7f1a0e81d6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.466 7f1a0e81d6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 276 (601.5622615814209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=951938395, topics=[]) 08/26/2025 00:16:52.467 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 951938395 with 0 response partitions (1 implied) 08/26/2025 00:16:52.471 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 147 08/26/2025 00:16:52.471 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 08/26/2025 00:16:52.471 7f1a0eb472e8 [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)]) 08/26/2025 00:16:52.471 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.471 7f1a0eb472e8 [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=253312791, session_epoch=289, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.471 7f1a0eb472e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 292 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=253312791, session_epoch=289, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.471 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284865.185547, idle connection 224052.000000, request 304999.946117 08/26/2025 00:16:52.472 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284864.651611, idle connection 224051.000000, request 304999.416351 08/26/2025 00:16:52.475 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 08/26/2025 00:16:52.475 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 08/26/2025 00:16:52.475 7f1a0e491eb8 [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)]) 08/26/2025 00:16:52.475 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.475 7f1a0e491eb8 [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=876895786, session_epoch=275, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.475 7f1a0e491eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=876895786, session_epoch=275, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.475 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284905.148438, idle connection 223693.000000, request 304999.952078 08/26/2025 00:16:52.475 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 08/26/2025 00:16:52.475 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/26/2025 00:16:52.476 7f1a0ec18390 [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)]) 08/26/2025 00:16:52.476 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.476 7f1a0ec18390 [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=1857057960, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.476 7f1a0ec18390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 265 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1857057960, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.476 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284913.171387, idle connection 223784.000000, request 304999.958515 08/26/2025 00:16:52.476 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285984.072754, idle connection 224138.000000, request 304396.955013 08/26/2025 00:16:52.476 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284903.928467, idle connection 223691.000000, request 304998.736382 08/26/2025 00:16:52.477 7f1a0da23ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 08/26/2025 00:16:52.477 7f1a0da23ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.477 7f1a0da23ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 295 (603.7347316741943 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2055726456, topics=[]) 08/26/2025 00:16:52.477 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2055726456 with 0 response partitions (1 implied) 08/26/2025 00:16:52.477 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284911.796143, idle connection 223782.000000, request 304998.586178 08/26/2025 00:16:52.498 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 08/26/2025 00:16:52.498 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 08/26/2025 00:16:52.498 7f1a0eac9b70 [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)]) 08/26/2025 00:16:52.498 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.498 7f1a0eac9b70 [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=835716862, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.499 7f1a0eac9b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 265 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=835716862, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.499 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284923.041504, idle connection 223781.000000, request 304999.932528 08/26/2025 00:16:52.499 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285527.339355, idle connection 223725.000000, request 304386.343241 08/26/2025 00:16:52.499 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285529.983154, idle connection 223950.000000, request 304386.946440 08/26/2025 00:16:52.500 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284922.231689, idle connection 223781.000000, request 304999.129295 08/26/2025 00:16:52.500 7f1a0ebdc630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:52.500 7f1a0ebdc630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.500 7f1a0ebdc630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (614.6194934844971 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1476187865, topics=[]) 08/26/2025 00:16:52.500 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1476187865 with 0 response partitions (1 implied) 08/26/2025 00:16:52.500 7f1a0da74198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 08/26/2025 00:16:52.500 7f1a0da74198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.501 7f1a0da74198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 272 (614.4256591796875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1234340878, topics=[]) 08/26/2025 00:16:52.501 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1234340878 with 0 response partitions (1 implied) 08/26/2025 00:16:52.531 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285548.607910, idle connection 224136.000000, request 304397.612333 08/26/2025 00:16:52.532 7f1a0d7c60f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 305 08/26/2025 00:16:52.532 7f1a0d7c60f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.532 7f1a0d7c60f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 305 (602.9031276702881 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=3198684, topics=[]) 08/26/2025 00:16:52.532 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 3198684 with 0 response partitions (1 implied) 08/26/2025 00:16:52.532 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285550.040039, idle connection 223824.000000, request 304397.631168 08/26/2025 00:16:52.532 7f1a0ebfbb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 270 08/26/2025 00:16:52.533 7f1a0ebfbb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.533 7f1a0ebfbb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 270 (602.6875972747803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=388406621, topics=[]) 08/26/2025 00:16:52.533 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 388406621 with 0 response partitions (1 implied) 08/26/2025 00:16:52.558 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285532.108154, idle connection 223945.000000, request 304397.907972 08/26/2025 00:16:52.558 7f1a0d9de198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 08/26/2025 00:16:52.558 7f1a0d9de198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.559 7f1a0d9de198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 292 (602.7054786682129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1406289851, topics=[]) 08/26/2025 00:16:52.559 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1406289851 with 0 response partitions (1 implied) 08/26/2025 00:16:52.559 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285533.615723, idle connection 223749.000000, request 304397.711277 08/26/2025 00:16:52.559 7f1a100c2588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 264 08/26/2025 00:16:52.559 7f1a100c2588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.559 7f1a100c2588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 264 (602.665901184082 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1853566743, topics=[]) 08/26/2025 00:16:52.560 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1853566743 with 0 response partitions (1 implied) 08/26/2025 00:16:52.583 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285559.572021, idle connection 223749.000000, request 304398.649931 08/26/2025 00:16:52.584 7f1a0eb506d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:52.584 7f1a0eb506d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.584 7f1a0eb506d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (601.7959117889404 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=292544232, topics=[]) 08/26/2025 00:16:52.584 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 292544232 with 0 response partitions (1 implied) 08/26/2025 00:16:52.653 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 5 08/26/2025 00:16:52.654 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/26/2025 00:16:52.654 7f1a0ebe00f0 [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)]) 08/26/2025 00:16:52.654 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.654 7f1a0ebe00f0 [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=677063064, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.654 7f1a0ebe00f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=677063064, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.654 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284944.788574, idle connection 223591.000000, request 304999.942541 08/26/2025 00:16:52.655 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284944.320557, idle connection 223590.000000, request 304999.481678 08/26/2025 00:16:52.655 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284330.138428, idle connection 223585.000000, request 304399.108648 08/26/2025 00:16:52.655 7f1a0e8510f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:52.655 7f1a0e8510f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.655 7f1a0e8510f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (601.2387275695801 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140686728, topics=[]) 08/26/2025 00:16:52.655 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 140686728 with 0 response partitions (1 implied) 08/26/2025 00:16:52.683 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 44 08/26/2025 00:16:52.683 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 08/26/2025 00:16:52.683 7f1a0da83b70 [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)]) 08/26/2025 00:16:52.683 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.683 7f1a0da83b70 [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=460370517, session_epoch=273, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.684 7f1a0da83b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=460370517, session_epoch=273, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.684 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284945.072998, idle connection 223659.000000, request 304999.940395 08/26/2025 00:16:52.684 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 108 08/26/2025 00:16:52.684 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 08/26/2025 00:16:52.684 7f1a0d830eb8 [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)]) 08/26/2025 00:16:52.684 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.684 7f1a0d830eb8 [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=1207306993, session_epoch=281, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.684 7f1a0d830eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1207306993, session_epoch=281, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.685 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284946.207764, idle connection 223961.000000, request 304999.953508 08/26/2025 00:16:52.685 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284943.854248, idle connection 223658.000000, request 304998.731852 08/26/2025 00:16:52.685 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284945.385742, idle connection 223961.000000, request 304999.133348 08/26/2025 00:16:52.719 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284332.453125, idle connection 223440.000000, request 304397.787571 08/26/2025 00:16:52.719 7f1a0ebe3eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 264 08/26/2025 00:16:52.719 7f1a0ebe3eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.719 7f1a0ebe3eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 264 (602.7655601501465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=29023917, topics=[]) 08/26/2025 00:16:52.719 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 29023917 with 0 response partitions (1 implied) 08/26/2025 00:16:52.720 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284336.549316, idle connection 223467.000000, request 304397.585392 08/26/2025 00:16:52.720 7f1a0ebd72e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 264 08/26/2025 00:16:52.720 7f1a0ebd72e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.720 7f1a0ebd72e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 264 (602.8130054473877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1222259810, topics=[]) 08/26/2025 00:16:52.720 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1222259810 with 0 response partitions (1 implied) 08/26/2025 00:16:52.750 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285535.987061, idle connection 223887.000000, request 304393.752337 08/26/2025 00:16:52.750 7f1a0d870390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 08/26/2025 00:16:52.750 7f1a0d870390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.750 7f1a0d870390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 300 (606.848955154419 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=911149617, topics=[]) 08/26/2025 00:16:52.751 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 911149617 with 0 response partitions (1 implied) 08/26/2025 00:16:52.751 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284329.081543, idle connection 223639.000000, request 304393.594027 08/26/2025 00:16:52.751 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285538.886719, idle connection 223681.000000, request 304394.136429 08/26/2025 00:16:52.751 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285441.052490, idle connection 223840.000000, request 304397.027016 08/26/2025 00:16:52.751 7f1a0da24588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 275 08/26/2025 00:16:52.751 7f1a0da24588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.751 7f1a0da24588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 275 (607.0480346679688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462372297, topics=[]) 08/26/2025 00:16:52.752 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462372297 with 0 response partitions (1 implied) 08/26/2025 00:16:52.752 7f1a0da5c978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 08/26/2025 00:16:52.752 7f1a0da5c978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.752 7f1a0da5c978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 285 (606.8689823150635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1752450253, topics=[]) 08/26/2025 00:16:52.752 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1752450253 with 0 response partitions (1 implied) 08/26/2025 00:16:52.752 7f1a0d85b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 08/26/2025 00:16:52.752 7f1a0d85b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.752 7f1a0d85b828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 307 (604.3353080749512 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1997162522, topics=[]) 08/26/2025 00:16:52.753 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1997162522 with 0 response partitions (1 implied) 08/26/2025 00:16:52.792 7f1a0da37390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284358.948730, idle connection 223583.000000, request 304398.934841 08/26/2025 00:16:52.792 7f1a0da37390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 08/26/2025 00:16:52.792 7f1a0da37390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.792 7f1a0da37390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 268 (601.6485691070557 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=676987511, topics=[]) 08/26/2025 00:16:52.793 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 676987511 with 0 response partitions (1 implied) 08/26/2025 00:16:52.963 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284335.174561, idle connection 223185.000000, request 304398.958921 08/26/2025 00:16:52.963 7f1a10164a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 438 08/26/2025 00:16:52.963 7f1a10164a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.963 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 438 (601.5818119049072 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1940314572, topics=[]) 08/26/2025 00:16:52.963 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1940314572 with 0 response partitions (1 implied) 08/26/2025 00:16:52.970 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284278.887939, idle connection 223600.000000, request 304398.081303 08/26/2025 00:16:52.970 7f1a0d9c30f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 298 08/26/2025 00:16:52.970 7f1a0d9c30f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.970 7f1a0d9c30f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 298 (602.3805141448975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=990538155, topics=[]) 08/26/2025 00:16:52.970 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 990538155 with 0 response partitions (1 implied) 08/26/2025 00:16:52.971 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284283.734863, idle connection 223509.000000, request 304397.975922 08/26/2025 00:16:52.971 7f1a0da236d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 08/26/2025 00:16:52.971 7f1a0da236d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.971 7f1a0da236d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 290 (602.4234294891357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=252887164, topics=[]) 08/26/2025 00:16:52.971 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 252887164 with 0 response partitions (1 implied) 08/26/2025 00:16:52.978 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2 08/26/2025 00:16:52.978 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/26/2025 00:16:52.978 7f1a0ebe7c18 [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)]) 08/26/2025 00:16:52.978 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.978 7f1a0ebe7c18 [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=1293647306, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.979 7f1a0ebe7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1293647306, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.979 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284896.030762, idle connection 223229.000000, request 304999.929190 08/26/2025 00:16:52.979 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 33 08/26/2025 00:16:52.979 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/26/2025 00:16:52.979 7f1a0da37978 [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)]) 08/26/2025 00:16:52.979 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:52.979 7f1a0da37978 [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=1519939297, session_epoch=270, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.979 7f1a0da37978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1519939297, session_epoch=270, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:52.980 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284916.623779, idle connection 223427.000000, request 304999.956608 08/26/2025 00:16:52.980 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284276.337891, idle connection 223563.000000, request 304396.653891 08/26/2025 00:16:52.980 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284894.714355, idle connection 223227.000000, request 304998.622417 08/26/2025 00:16:52.980 7f1a0eb09780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 08/26/2025 00:16:52.980 7f1a0eb09780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:52.981 7f1a0eb09780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 288 (604.0706634521484 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=747538721, topics=[]) 08/26/2025 00:16:52.981 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 747538721 with 0 response partitions (1 implied) 08/26/2025 00:16:52.981 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284915.230225, idle connection 223426.000000, request 304998.566389 08/26/2025 00:16:53.067 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44 08/26/2025 00:16:53.067 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 08/26/2025 00:16:53.067 7f1a0e81d6d8 [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)]) 08/26/2025 00:16:53.067 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.067 7f1a0e81d6d8 [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=951938395, session_epoch=274, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.067 7f1a0e81d6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=951938395, session_epoch=274, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.068 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284882.149902, idle connection 223388.000000, request 304999.941349 08/26/2025 00:16:53.068 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284881.726074, idle connection 223388.000000, request 304999.524832 08/26/2025 00:16:53.072 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284264.244629, idle connection 223451.000000, request 304399.007082 08/26/2025 00:16:53.072 7f1a0eb472e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 08/26/2025 00:16:53.073 7f1a0eb472e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.073 7f1a0eb472e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 292 (601.4149188995361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=253312791, topics=[]) 08/26/2025 00:16:53.073 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 253312791 with 0 response partitions (1 implied) 08/26/2025 00:16:53.077 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 162 08/26/2025 00:16:53.077 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/26/2025 00:16:53.077 7f1a0da23ac8 [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)]) 08/26/2025 00:16:53.077 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.078 7f1a0da23ac8 [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=2055726456, session_epoch=293, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.078 7f1a0da23ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=2055726456, session_epoch=293, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.078 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285382.342529, idle connection 223536.000000, request 304999.951601 08/26/2025 00:16:53.078 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284302.259521, idle connection 223090.000000, request 304397.065163 08/26/2025 00:16:53.078 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284310.850342, idle connection 223181.000000, request 304397.639751 08/26/2025 00:16:53.079 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 285381.490234, idle connection 223536.000000, request 304999.102592 08/26/2025 00:16:53.079 7f1a0e491eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 08/26/2025 00:16:53.079 7f1a0e491eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.079 7f1a0e491eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 278 (603.9149761199951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876895786, topics=[]) 08/26/2025 00:16:53.079 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876895786 with 0 response partitions (1 implied) 08/26/2025 00:16:53.079 7f1a0ec18390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:53.080 7f1a0ec18390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.080 7f1a0ec18390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (603.7063598632812 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1857057960, topics=[]) 08/26/2025 00:16:53.080 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1857057960 with 0 response partitions (1 implied) 08/26/2025 00:16:53.101 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4 08/26/2025 00:16:53.101 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 08/26/2025 00:16:53.101 7f1a0ebdc630 [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)]) 08/26/2025 00:16:53.101 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.101 7f1a0ebdc630 [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=1476187865, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.101 7f1a0ebdc630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1476187865, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.101 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284925.107422, idle connection 223123.000000, request 304999.931574 08/26/2025 00:16:53.101 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 30 08/26/2025 00:16:53.102 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 08/26/2025 00:16:53.102 7f1a0da74198 [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)]) 08/26/2025 00:16:53.102 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.102 7f1a0da74198 [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=1234340878, session_epoch=270, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.102 7f1a0da74198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1234340878, session_epoch=270, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.102 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284927.105713, idle connection 223347.000000, request 304999.955654 08/26/2025 00:16:53.102 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284319.531982, idle connection 223178.000000, request 304396.428823 08/26/2025 00:16:53.103 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284923.730469, idle connection 223122.000000, request 304998.573303 08/26/2025 00:16:53.103 7f1a0eac9b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:53.103 7f1a0eac9b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.103 7f1a0eac9b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (604.3384075164795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=835716862, topics=[]) 08/26/2025 00:16:53.103 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 835716862 with 0 response partitions (1 implied) 08/26/2025 00:16:53.104 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284925.591797, idle connection 223346.000000, request 304998.446226 08/26/2025 00:16:53.133 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 250 08/26/2025 00:16:53.133 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/26/2025 00:16:53.133 7f1a0d7c60f0 [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)]) 08/26/2025 00:16:53.133 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.134 7f1a0d7c60f0 [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=3198684, session_epoch=303, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.134 7f1a0d7c60f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 306 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=3198684, session_epoch=303, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.134 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284946.117432, idle connection 223533.000000, request 304999.940872 08/26/2025 00:16:53.134 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 30 08/26/2025 00:16:53.134 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/26/2025 00:16:53.134 7f1a0ebfbb70 [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)]) 08/26/2025 00:16:53.134 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.134 7f1a0ebfbb70 [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=388406621, session_epoch=268, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.135 7f1a0ebfbb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=388406621, session_epoch=268, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.135 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284947.631592, idle connection 223222.000000, request 304999.949932 08/26/2025 00:16:53.135 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284944.866699, idle connection 223532.000000, request 304998.698711 08/26/2025 00:16:53.135 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284946.911621, idle connection 223221.000000, request 304999.229670 08/26/2025 00:16:53.159 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 153 08/26/2025 00:16:53.159 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 08/26/2025 00:16:53.159 7f1a0d9de198 [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)]) 08/26/2025 00:16:53.159 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.159 7f1a0d9de198 [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=1406289851, session_epoch=290, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.160 7f1a0d9de198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1406289851, session_epoch=290, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.160 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284930.281006, idle connection 223343.000000, request 304999.943256 08/26/2025 00:16:53.160 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1 08/26/2025 00:16:53.160 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 08/26/2025 00:16:53.160 7f1a100c2588 [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)]) 08/26/2025 00:16:53.161 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.161 7f1a100c2588 [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=1853566743, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.161 7f1a100c2588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 265 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1853566743, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.161 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284931.530762, idle connection 223147.000000, request 304999.952078 08/26/2025 00:16:53.162 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284928.513672, idle connection 223341.000000, request 304998.183012 08/26/2025 00:16:53.162 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284930.706299, idle connection 223146.000000, request 304999.131680 08/26/2025 00:16:53.185 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 08/26/2025 00:16:53.185 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 08/26/2025 00:16:53.185 7f1a0eb506d8 [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)]) 08/26/2025 00:16:53.186 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.186 7f1a0eb506d8 [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=292544232, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.186 7f1a0eb506d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=292544232, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.186 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284957.127197, idle connection 223146.000000, request 304999.943256 08/26/2025 00:16:53.186 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284956.712158, idle connection 223146.000000, request 304999.454021 08/26/2025 00:16:53.255 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284343.870117, idle connection 222990.000000, request 304399.024963 08/26/2025 00:16:53.255 7f1a0ebe00f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:53.255 7f1a0ebe00f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.256 7f1a0ebe00f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (601.5231609344482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=677063064, topics=[]) 08/26/2025 00:16:53.256 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 677063064 with 0 response partitions (1 implied) 08/26/2025 00:16:53.256 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 4 08/26/2025 00:16:53.256 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/26/2025 00:16:53.256 7f1a0e8510f0 [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)]) 08/26/2025 00:16:53.256 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.256 7f1a0e8510f0 [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=140686728, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.256 7f1a0e8510f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140686728, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.256 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283728.509277, idle connection 222984.000000, request 304999.950647 08/26/2025 00:16:53.257 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283728.127686, idle connection 222983.000000, request 304999.572992 08/26/2025 00:16:53.286 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284342.926514, idle connection 223057.000000, request 304397.798300 08/26/2025 00:16:53.286 7f1a0da83b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 08/26/2025 00:16:53.286 7f1a0da83b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.286 7f1a0da83b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 276 (602.6959419250488 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=460370517, topics=[]) 08/26/2025 00:16:53.287 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 460370517 with 0 response partitions (1 implied) 08/26/2025 00:16:53.287 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284344.004150, idle connection 223359.000000, request 304397.752285 08/26/2025 00:16:53.287 7f1a0d830eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 08/26/2025 00:16:53.287 7f1a0d830eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.287 7f1a0d830eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 284 (602.5574207305908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1207306993, topics=[]) 08/26/2025 00:16:53.287 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1207306993 with 0 response partitions (1 implied) 08/26/2025 00:16:53.322 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 08/26/2025 00:16:53.323 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 08/26/2025 00:16:53.323 7f1a0ebe3eb8 [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)]) 08/26/2025 00:16:53.323 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.323 7f1a0ebe3eb8 [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=29023917, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.323 7f1a0ebe3eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 265 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29023917, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.323 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283727.769531, idle connection 222835.000000, request 304999.940395 08/26/2025 00:16:53.323 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/26/2025 00:16:53.324 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/26/2025 00:16:53.324 7f1a0ebd72e8 [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)]) 08/26/2025 00:16:53.324 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.324 7f1a0ebd72e8 [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=1222259810, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.324 7f1a0ebd72e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 265 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222259810, session_epoch=262, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.324 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283732.118652, idle connection 222862.000000, request 304999.956369 08/26/2025 00:16:53.324 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283726.587158, idle connection 222834.000000, request 304998.765469 08/26/2025 00:16:53.325 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283731.366699, idle connection 222862.000000, request 304999.208689 08/26/2025 00:16:53.352 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 301 08/26/2025 00:16:53.352 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/26/2025 00:16:53.352 7f1a0d870390 [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)]) 08/26/2025 00:16:53.353 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.353 7f1a0d870390 [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=911149617, session_epoch=298, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.353 7f1a0d870390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=911149617, session_epoch=298, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.353 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284932.754639, idle connection 223284.000000, request 304999.936819 08/26/2025 00:16:53.353 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284932.285156, idle connection 223283.000000, request 304999.474764 08/26/2025 00:16:53.356 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 32 08/26/2025 00:16:53.356 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 08/26/2025 00:16:53.356 7f1a0da24588 [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)]) 08/26/2025 00:16:53.356 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.356 7f1a0da24588 [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=1462372297, session_epoch=273, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.356 7f1a0da24588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1462372297, session_epoch=273, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.357 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283723.359131, idle connection 223033.000000, request 304999.950171 08/26/2025 00:16:53.357 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 78 08/26/2025 00:16:53.357 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 08/26/2025 00:16:53.357 7f1a0da5c978 [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)]) 08/26/2025 00:16:53.357 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.357 7f1a0da5c978 [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=1752450253, session_epoch=283, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.357 7f1a0da5c978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1752450253, session_epoch=283, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.357 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284932.638184, idle connection 223074.000000, request 304999.959230 08/26/2025 00:16:53.357 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 240 08/26/2025 00:16:53.357 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 08/26/2025 00:16:53.357 7f1a0d85b828 [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)]) 08/26/2025 00:16:53.358 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.358 7f1a0d85b828 [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=1997162522, session_epoch=305, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.358 7f1a0d85b828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 308 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1997162522, session_epoch=305, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.358 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284834.246826, idle connection 223233.000000, request 304999.958277 08/26/2025 00:16:53.358 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283721.395020, idle connection 223031.000000, request 304997.988462 08/26/2025 00:16:53.359 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284931.019043, idle connection 223073.000000, request 304998.343229 08/26/2025 00:16:53.359 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284833.015869, idle connection 223232.000000, request 304998.730183 08/26/2025 00:16:53.394 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 22 08/26/2025 00:16:53.394 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 08/26/2025 00:16:53.394 7f1a0da37390 [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)]) 08/26/2025 00:16:53.394 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.395 7f1a0da37390 [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=676987511, session_epoch=266, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.395 7f1a0da37390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=676987511, session_epoch=266, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.395 7f1a0da37390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283755.877197, idle connection 222980.000000, request 304999.922991 08/26/2025 00:16:53.395 7f1a0da37390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283755.365967, idle connection 222979.000000, request 304999.420404 08/26/2025 00:16:53.564 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4029 08/26/2025 00:16:53.564 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 08/26/2025 00:16:53.564 7f1a10164a20 [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)]) 08/26/2025 00:16:53.564 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.564 7f1a10164a20 [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=1940314572, session_epoch=436, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.564 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 439 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1940314572, session_epoch=436, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.565 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283733.236816, idle connection 222583.000000, request 304999.940395 08/26/2025 00:16:53.565 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283732.803223, idle connection 222583.000000, request 304999.514103 08/26/2025 00:16:53.571 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 164 08/26/2025 00:16:53.571 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/26/2025 00:16:53.571 7f1a0d9c30f0 [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)]) 08/26/2025 00:16:53.571 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.571 7f1a0d9c30f0 [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=990538155, session_epoch=296, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.571 7f1a0d9c30f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=990538155, session_epoch=296, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.571 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283677.341553, idle connection 222999.000000, request 304999.950886 08/26/2025 00:16:53.571 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 180 08/26/2025 00:16:53.571 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 08/26/2025 00:16:53.572 7f1a0da236d8 [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)]) 08/26/2025 00:16:53.572 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.572 7f1a0da236d8 [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=252887164, session_epoch=288, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.572 7f1a0da236d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 291 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=252887164, session_epoch=288, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.572 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283682.299805, idle connection 222907.000000, request 304999.957323 08/26/2025 00:16:53.572 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283676.254395, idle connection 222998.000000, request 304998.841047 08/26/2025 00:16:53.573 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283681.607422, idle connection 222906.000000, request 304999.268770 08/26/2025 00:16:53.581 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 144 08/26/2025 00:16:53.581 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/26/2025 00:16:53.581 7f1a0eb09780 [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)]) 08/26/2025 00:16:53.581 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.581 7f1a0eb09780 [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=747538721, session_epoch=286, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.582 7f1a0eb09780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=747538721, session_epoch=286, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.582 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283674.473389, idle connection 222962.000000, request 304999.949455 08/26/2025 00:16:53.582 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284292.905029, idle connection 222626.000000, request 304396.810770 08/26/2025 00:16:53.582 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284314.143799, idle connection 222825.000000, request 304397.479296 08/26/2025 00:16:53.582 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283673.699219, idle connection 222961.000000, request 304999.180794 08/26/2025 00:16:53.583 7f1a0ebe7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:53.583 7f1a0ebe7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.583 7f1a0ebe7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (604.1064262390137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1293647306, topics=[]) 08/26/2025 00:16:53.583 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1293647306 with 0 response partitions (1 implied) 08/26/2025 00:16:53.583 7f1a0da37978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 273 08/26/2025 00:16:53.583 7f1a0da37978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.583 7f1a0da37978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 273 (603.9245128631592 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1519939297, topics=[]) 08/26/2025 00:16:53.584 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1519939297 with 0 response partitions (1 implied) 08/26/2025 00:16:53.669 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284281.207520, idle connection 222787.000000, request 304398.998976 08/26/2025 00:16:53.669 7f1a0e81d6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 08/26/2025 00:16:53.669 7f1a0e81d6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.669 7f1a0e81d6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 277 (601.5548706054688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=951938395, topics=[]) 08/26/2025 00:16:53.669 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 951938395 with 0 response partitions (1 implied) 08/26/2025 00:16:53.673 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 147 08/26/2025 00:16:53.673 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 08/26/2025 00:16:53.673 7f1a0eb472e8 [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)]) 08/26/2025 00:16:53.673 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.673 7f1a0eb472e8 [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=253312791, session_epoch=290, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.674 7f1a0eb472e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=253312791, session_epoch=290, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.674 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283662.661865, idle connection 222849.000000, request 304999.939680 08/26/2025 00:16:53.674 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283662.040283, idle connection 222849.000000, request 304999.325514 08/26/2025 00:16:53.680 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 08/26/2025 00:16:53.680 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 08/26/2025 00:16:53.680 7f1a0e491eb8 [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)]) 08/26/2025 00:16:53.680 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.680 7f1a0e491eb8 [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=876895786, session_epoch=276, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.680 7f1a0e491eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=876895786, session_epoch=276, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.680 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283700.093750, idle connection 222488.000000, request 304999.943972 08/26/2025 00:16:53.680 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 08/26/2025 00:16:53.681 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/26/2025 00:16:53.681 7f1a0ec18390 [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)]) 08/26/2025 00:16:53.681 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.681 7f1a0ec18390 [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=1857057960, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.681 7f1a0ec18390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1857057960, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.681 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283708.089844, idle connection 222578.000000, request 304999.957085 08/26/2025 00:16:53.681 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284778.987061, idle connection 222933.000000, request 304396.599770 08/26/2025 00:16:53.682 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283698.841309, idle connection 222486.000000, request 304998.705149 08/26/2025 00:16:53.682 7f1a0da23ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 08/26/2025 00:16:53.682 7f1a0da23ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.682 7f1a0da23ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 296 (604.1066646575928 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2055726456, topics=[]) 08/26/2025 00:16:53.682 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2055726456 with 0 response partitions (1 implied) 08/26/2025 00:16:53.682 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283706.691650, idle connection 222577.000000, request 304998.562574 08/26/2025 00:16:53.704 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 08/26/2025 00:16:53.704 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 08/26/2025 00:16:53.704 7f1a0eac9b70 [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)]) 08/26/2025 00:16:53.704 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.704 7f1a0eac9b70 [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=835716862, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.704 7f1a0eac9b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=835716862, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.704 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283717.508545, idle connection 222576.000000, request 304999.922276 08/26/2025 00:16:53.705 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284321.804688, idle connection 222520.000000, request 304396.646500 08/26/2025 00:16:53.705 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284324.449463, idle connection 222745.000000, request 304397.302866 08/26/2025 00:16:53.705 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283716.805664, idle connection 222575.000000, request 304999.227285 08/26/2025 00:16:53.705 7f1a0ebdc630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 267 08/26/2025 00:16:53.705 7f1a0ebdc630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.705 7f1a0ebdc630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 267 (604.1791439056396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1476187865, topics=[]) 08/26/2025 00:16:53.706 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1476187865 with 0 response partitions (1 implied) 08/26/2025 00:16:53.706 7f1a0da74198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 273 08/26/2025 00:16:53.706 7f1a0da74198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.706 7f1a0da74198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 273 (603.9066314697266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1234340878, topics=[]) 08/26/2025 00:16:53.706 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1234340878 with 0 response partitions (1 implied) 08/26/2025 00:16:53.736 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284343.967285, idle connection 222931.000000, request 304397.791862 08/26/2025 00:16:53.736 7f1a0d7c60f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 08/26/2025 00:16:53.736 7f1a0d7c60f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.737 7f1a0d7c60f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 306 (602.7240753173828 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=3198684, topics=[]) 08/26/2025 00:16:53.737 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 3198684 with 0 response partitions (1 implied) 08/26/2025 00:16:53.737 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284345.445068, idle connection 222619.000000, request 304397.767544 08/26/2025 00:16:53.737 7f1a0ebfbb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 271 08/26/2025 00:16:53.737 7f1a0ebfbb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.737 7f1a0ebfbb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 271 (602.548360824585 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=388406621, topics=[]) 08/26/2025 00:16:53.737 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 388406621 with 0 response partitions (1 implied) 08/26/2025 00:16:53.762 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284327.742920, idle connection 222740.000000, request 304397.404909 08/26/2025 00:16:53.763 7f1a0d9de198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 08/26/2025 00:16:53.763 7f1a0d9de198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.763 7f1a0d9de198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 293 (603.0795574188232 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1406289851, topics=[]) 08/26/2025 00:16:53.763 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1406289851 with 0 response partitions (1 implied) 08/26/2025 00:16:53.763 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284329.408691, idle connection 222545.000000, request 304397.831202 08/26/2025 00:16:53.763 7f1a100c2588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:53.763 7f1a100c2588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.764 7f1a100c2588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (602.4854183197021 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1853566743, topics=[]) 08/26/2025 00:16:53.764 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1853566743 with 0 response partitions (1 implied) 08/26/2025 00:16:53.788 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284355.552734, idle connection 222545.000000, request 304398.367167 08/26/2025 00:16:53.788 7f1a0eb506d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:53.788 7f1a0eb506d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.788 7f1a0eb506d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (602.1149158477783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=292544232, topics=[]) 08/26/2025 00:16:53.788 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 292544232 with 0 response partitions (1 implied) 08/26/2025 00:16:53.858 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 5 08/26/2025 00:16:53.858 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/26/2025 00:16:53.858 7f1a0ebe00f0 [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)]) 08/26/2025 00:16:53.859 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.859 7f1a0ebe00f0 [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=677063064, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.859 7f1a0ebe00f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=677063064, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.859 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283739.987549, idle connection 222386.000000, request 304999.942541 08/26/2025 00:16:53.859 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283125.852295, idle connection 222381.000000, request 304397.296429 08/26/2025 00:16:53.859 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283739.391113, idle connection 222385.000000, request 304999.355078 08/26/2025 00:16:53.860 7f1a0e8510f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 267 08/26/2025 00:16:53.860 7f1a0e8510f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.860 7f1a0e8510f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 267 (603.3995151519775 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140686728, topics=[]) 08/26/2025 00:16:53.860 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 140686728 with 0 response partitions (1 implied) 08/26/2025 00:16:53.888 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 44 08/26/2025 00:16:53.888 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 08/26/2025 00:16:53.888 7f1a0da83b70 [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)]) 08/26/2025 00:16:53.888 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.888 7f1a0da83b70 [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=460370517, session_epoch=274, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.888 7f1a0da83b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=460370517, session_epoch=274, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.889 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283740.209473, idle connection 222454.000000, request 304999.945879 08/26/2025 00:16:53.889 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 108 08/26/2025 00:16:53.889 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 08/26/2025 00:16:53.889 7f1a0d830eb8 [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)]) 08/26/2025 00:16:53.889 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:53.889 7f1a0d830eb8 [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=1207306993, session_epoch=282, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.889 7f1a0d830eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1207306993, session_epoch=282, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:53.889 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283741.426025, idle connection 222757.000000, request 304999.946594 08/26/2025 00:16:53.890 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283739.041016, idle connection 222453.000000, request 304998.783350 08/26/2025 00:16:53.890 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283740.695557, idle connection 222756.000000, request 304999.220371 08/26/2025 00:16:53.926 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283124.931396, idle connection 222232.000000, request 304397.105455 08/26/2025 00:16:53.926 7f1a0ebe3eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:53.926 7f1a0ebe3eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.927 7f1a0ebe3eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (603.3673286437988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=29023917, topics=[]) 08/26/2025 00:16:53.927 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 29023917 with 0 response partitions (1 implied) 08/26/2025 00:16:53.927 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283129.165771, idle connection 222260.000000, request 304397.006512 08/26/2025 00:16:53.927 7f1a0ebd72e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 265 08/26/2025 00:16:53.927 7f1a0ebd72e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.927 7f1a0ebd72e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 265 (603.2984256744385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1222259810, topics=[]) 08/26/2025 00:16:53.927 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1222259810 with 0 response partitions (1 implied) 08/26/2025 00:16:53.954 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284331.411621, idle connection 222682.000000, request 304398.597956 08/26/2025 00:16:53.955 7f1a0d870390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 301 08/26/2025 00:16:53.955 7f1a0d870390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.955 7f1a0d870390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 301 (601.8149852752686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=911149617, topics=[]) 08/26/2025 00:16:53.955 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 911149617 with 0 response partitions (1 implied) 08/26/2025 00:16:53.961 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283119.333496, idle connection 222429.000000, request 304395.924330 08/26/2025 00:16:53.961 7f1a0da24588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 08/26/2025 00:16:53.961 7f1a0da24588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.961 7f1a0da24588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 276 (604.4290065765381 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462372297, topics=[]) 08/26/2025 00:16:53.961 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462372297 with 0 response partitions (1 implied) 08/26/2025 00:16:53.961 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284328.575928, idle connection 222470.000000, request 304395.899057 08/26/2025 00:16:53.961 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284230.729492, idle connection 222630.000000, request 304396.443367 08/26/2025 00:16:53.962 7f1a0da5c978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 08/26/2025 00:16:53.962 7f1a0da5c978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.962 7f1a0da5c978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 286 (604.5398712158203 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1752450253, topics=[]) 08/26/2025 00:16:53.962 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1752450253 with 0 response partitions (1 implied) 08/26/2025 00:16:53.962 7f1a0d85b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 308 08/26/2025 00:16:53.962 7f1a0d85b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.962 7f1a0d85b828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 308 (604.3121814727783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1997162522, topics=[]) 08/26/2025 00:16:53.962 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1997162522 with 0 response partitions (1 implied) 08/26/2025 00:16:53.996 7f1a0da37390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283154.860107, idle connection 222379.000000, request 304398.909569 08/26/2025 00:16:53.996 7f1a0da37390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 269 08/26/2025 00:16:53.996 7f1a0da37390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:53.996 7f1a0da37390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 269 (601.5615463256836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=676987511, topics=[]) 08/26/2025 00:16:53.997 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 676987511 with 0 response partitions (1 implied) 08/26/2025 00:16:54.166 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283132.244873, idle connection 221982.000000, request 304398.947001 08/26/2025 00:16:54.166 7f1a10164a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 439 08/26/2025 00:16:54.166 7f1a10164a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.166 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 439 (601.5985012054443 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1940314572, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4030, last_stable_offset=4030, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\xbd\x00\x00\x01\x04\x00\x00\x00\x00\x02O\\P\xb1\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...')])]) 08/26/2025 00:16:54.166 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1940314572 with 1 response partitions (0 implied) 08/26/2025 00:16:54.167 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4029 08/26/2025 00:16:54.167 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4029 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 08/26/2025 00:16:54.167 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4030 (leader epoch 0) 08/26/2025 00:16:54.173 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283075.531982, idle connection 222397.000000, request 304398.139954 08/26/2025 00:16:54.173 7f1a0d9c30f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 08/26/2025 00:16:54.173 7f1a0d9c30f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.173 7f1a0d9c30f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 299 (602.2586822509766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=990538155, topics=[]) 08/26/2025 00:16:54.174 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 990538155 with 0 response partitions (1 implied) 08/26/2025 00:16:54.174 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283080.486572, idle connection 222305.000000, request 304398.144722 08/26/2025 00:16:54.174 7f1a0da236d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 08/26/2025 00:16:54.174 7f1a0da236d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.174 7f1a0da236d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 291 (602.1595001220703 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=252887164, topics=[]) 08/26/2025 00:16:54.174 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 252887164 with 0 response partitions (1 implied) 08/26/2025 00:16:54.183 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2 08/26/2025 00:16:54.183 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/26/2025 00:16:54.183 7f1a0ebe7c18 [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)]) 08/26/2025 00:16:54.184 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.184 7f1a0ebe7c18 [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=1293647306, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.184 7f1a0ebe7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1293647306, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.184 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283690.872559, idle connection 222023.000000, request 304999.947309 08/26/2025 00:16:54.184 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 33 08/26/2025 00:16:54.184 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/26/2025 00:16:54.184 7f1a0da37978 [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)]) 08/26/2025 00:16:54.184 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.184 7f1a0da37978 [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=1519939297, session_epoch=271, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.185 7f1a0da37978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1519939297, session_epoch=271, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.185 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283711.481201, idle connection 222222.000000, request 304999.954462 08/26/2025 00:16:54.185 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283071.194092, idle connection 222358.000000, request 304396.675348 08/26/2025 00:16:54.185 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283689.561768, idle connection 222022.000000, request 304998.638153 08/26/2025 00:16:54.185 7f1a0eb09780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 08/26/2025 00:16:54.186 7f1a0eb09780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.186 7f1a0eb09780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 289 (604.04372215271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=747538721, topics=[]) 08/26/2025 00:16:54.186 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 747538721 with 0 response partitions (1 implied) 08/26/2025 00:16:54.186 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283710.098877, idle connection 222221.000000, request 304998.576164 08/26/2025 00:16:54.268 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4030 08/26/2025 00:16:54.268 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 08/26/2025 00:16:54.268 7f1a10164a20 [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)]) 08/26/2025 00:16:54.268 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.268 7f1a10164a20 [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=1940314572, session_epoch=437, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4030, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/26/2025 00:16:54.268 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 440 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1940314572, session_epoch=437, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4030, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/26/2025 00:16:54.268 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283029.438232, idle connection 221879.000000, request 304999.933958 08/26/2025 00:16:54.269 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283029.007568, idle connection 221879.000000, request 304999.513149 08/26/2025 00:16:54.270 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44 08/26/2025 00:16:54.270 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 08/26/2025 00:16:54.270 7f1a0e81d6d8 [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)]) 08/26/2025 00:16:54.270 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.270 7f1a0e81d6d8 [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=951938395, session_epoch=275, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.270 7f1a0e81d6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=951938395, session_epoch=275, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.270 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283679.583252, idle connection 222185.000000, request 304999.955416 08/26/2025 00:16:54.271 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283679.226318, idle connection 222185.000000, request 304999.601603 08/26/2025 00:16:54.275 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283061.675781, idle connection 222248.000000, request 304398.959160 08/26/2025 00:16:54.275 7f1a0eb472e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 08/26/2025 00:16:54.275 7f1a0eb472e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.275 7f1a0eb472e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 293 (601.4561653137207 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=253312791, topics=[]) 08/26/2025 00:16:54.275 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 253312791 with 0 response partitions (1 implied) 08/26/2025 00:16:54.282 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 162 08/26/2025 00:16:54.282 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/26/2025 00:16:54.282 7f1a0da23ac8 [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)]) 08/26/2025 00:16:54.283 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.283 7f1a0da23ac8 [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=2055726456, session_epoch=294, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.283 7f1a0da23ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 297 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2055726456, session_epoch=294, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.283 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284177.297852, idle connection 222331.000000, request 304999.951601 08/26/2025 00:16:54.283 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283097.265625, idle connection 221885.000000, request 304397.127628 08/26/2025 00:16:54.283 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283105.859375, idle connection 221976.000000, request 304397.729635 08/26/2025 00:16:54.284 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 284176.633545, idle connection 222331.000000, request 304999.287844 08/26/2025 00:16:54.284 7f1a0e491eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 08/26/2025 00:16:54.284 7f1a0e491eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.284 7f1a0e491eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 279 (603.701114654541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876895786, topics=[]) 08/26/2025 00:16:54.284 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876895786 with 0 response partitions (1 implied) 08/26/2025 00:16:54.284 7f1a0ec18390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:54.284 7f1a0ec18390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.285 7f1a0ec18390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (603.5687923431396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1857057960, topics=[]) 08/26/2025 00:16:54.285 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1857057960 with 0 response partitions (1 implied) 08/26/2025 00:16:54.306 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4 08/26/2025 00:16:54.306 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 08/26/2025 00:16:54.306 7f1a0ebdc630 [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)]) 08/26/2025 00:16:54.306 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.306 7f1a0ebdc630 [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=1476187865, session_epoch=265, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.307 7f1a0ebdc630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1476187865, session_epoch=265, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.307 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283719.668213, idle connection 221918.000000, request 304999.935389 08/26/2025 00:16:54.307 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 30 08/26/2025 00:16:54.307 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 08/26/2025 00:16:54.307 7f1a0da74198 [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)]) 08/26/2025 00:16:54.307 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.307 7f1a0da74198 [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=1234340878, session_epoch=271, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.307 7f1a0da74198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1234340878, session_epoch=271, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.308 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283721.606689, idle connection 222142.000000, request 304999.952078 08/26/2025 00:16:54.308 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283114.031494, idle connection 221972.000000, request 304396.451235 08/26/2025 00:16:54.308 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283718.189697, idle connection 221916.000000, request 304998.466492 08/26/2025 00:16:54.308 7f1a0eac9b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:54.309 7f1a0eac9b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.309 7f1a0eac9b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (604.3763160705566 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=835716862, topics=[]) 08/26/2025 00:16:54.309 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 835716862 with 0 response partitions (1 implied) 08/26/2025 00:16:54.309 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283719.988281, idle connection 222140.000000, request 304998.338461 08/26/2025 00:16:54.337 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 250 08/26/2025 00:16:54.337 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/26/2025 00:16:54.337 7f1a0d7c60f0 [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)]) 08/26/2025 00:16:54.337 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.338 7f1a0d7c60f0 [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=3198684, session_epoch=304, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.338 7f1a0d7c60f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 307 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=3198684, session_epoch=304, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.338 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283742.083984, idle connection 222329.000000, request 304999.937534 08/26/2025 00:16:54.338 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 30 08/26/2025 00:16:54.338 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/26/2025 00:16:54.338 7f1a0ebfbb70 [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)]) 08/26/2025 00:16:54.338 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.338 7f1a0ebfbb70 [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=388406621, session_epoch=269, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.339 7f1a0ebfbb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=388406621, session_epoch=269, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.339 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283743.617432, idle connection 222018.000000, request 304999.936104 08/26/2025 00:16:54.339 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283740.744873, idle connection 222328.000000, request 304998.607397 08/26/2025 00:16:54.340 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283742.766602, idle connection 222017.000000, request 304999.089956 08/26/2025 00:16:54.363 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 153 08/26/2025 00:16:54.363 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 08/26/2025 00:16:54.364 7f1a0d9de198 [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)]) 08/26/2025 00:16:54.364 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.364 7f1a0d9de198 [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=1406289851, session_epoch=291, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.364 7f1a0d9de198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1406289851, session_epoch=291, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.364 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283725.963623, idle connection 222139.000000, request 304999.927044 08/26/2025 00:16:54.364 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1 08/26/2025 00:16:54.365 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 08/26/2025 00:16:54.365 7f1a100c2588 [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)]) 08/26/2025 00:16:54.365 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.365 7f1a100c2588 [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=1853566743, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.365 7f1a100c2588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1853566743, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.365 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283727.565918, idle connection 221943.000000, request 304999.952316 08/26/2025 00:16:54.365 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283724.593506, idle connection 222137.000000, request 304998.561621 08/26/2025 00:16:54.366 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283726.756348, idle connection 221942.000000, request 304999.147892 08/26/2025 00:16:54.390 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 08/26/2025 00:16:54.390 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 08/26/2025 00:16:54.390 7f1a0eb506d8 [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)]) 08/26/2025 00:16:54.390 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.390 7f1a0eb506d8 [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=292544232, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.390 7f1a0eb506d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=292544232, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.390 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283752.665039, idle connection 221942.000000, request 304999.941111 08/26/2025 00:16:54.391 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283752.206055, idle connection 221942.000000, request 304999.489069 08/26/2025 00:16:54.460 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 4 08/26/2025 00:16:54.461 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/26/2025 00:16:54.461 7f1a0e8510f0 [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)]) 08/26/2025 00:16:54.461 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.461 7f1a0e8510f0 [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=140686728, session_epoch=265, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.461 7f1a0e8510f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=140686728, session_epoch=265, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.461 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282523.815430, idle connection 221779.000000, request 304999.935150 08/26/2025 00:16:54.462 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283137.374023, idle connection 221783.000000, request 304397.334337 08/26/2025 00:16:54.462 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282523.126953, idle connection 221778.000000, request 304999.256134 08/26/2025 00:16:54.462 7f1a0ebe00f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 267 08/26/2025 00:16:54.462 7f1a0ebe00f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.462 7f1a0ebe00f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 267 (603.6086082458496 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=677063064, topics=[]) 08/26/2025 00:16:54.463 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 677063064 with 0 response partitions (1 implied) 08/26/2025 00:16:54.491 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283138.254150, idle connection 221852.000000, request 304397.989273 08/26/2025 00:16:54.491 7f1a0da83b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 08/26/2025 00:16:54.491 7f1a0da83b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.491 7f1a0da83b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 277 (602.536678314209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=460370517, topics=[]) 08/26/2025 00:16:54.491 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 460370517 with 0 response partitions (1 implied) 08/26/2025 00:16:54.492 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283139.208496, idle connection 222154.000000, request 304397.730112 08/26/2025 00:16:54.492 7f1a0d830eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 08/26/2025 00:16:54.492 7f1a0d830eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.492 7f1a0d830eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 285 (602.6794910430908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1207306993, topics=[]) 08/26/2025 00:16:54.492 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1207306993 with 0 response partitions (1 implied) 08/26/2025 00:16:54.527 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 08/26/2025 00:16:54.527 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 08/26/2025 00:16:54.527 7f1a0ebe3eb8 [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)]) 08/26/2025 00:16:54.528 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.528 7f1a0ebe3eb8 [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=29023917, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.528 7f1a0ebe3eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29023917, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.528 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282522.979736, idle connection 221630.000000, request 304999.914169 08/26/2025 00:16:54.528 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/26/2025 00:16:54.528 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/26/2025 00:16:54.528 7f1a0ebd72e8 [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)]) 08/26/2025 00:16:54.529 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.529 7f1a0ebd72e8 [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=1222259810, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.529 7f1a0ebd72e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222259810, session_epoch=263, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.529 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282527.116699, idle connection 221657.000000, request 304999.934435 08/26/2025 00:16:54.529 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282521.588623, idle connection 221629.000000, request 304998.539209 08/26/2025 00:16:54.530 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282526.310059, idle connection 221657.000000, request 304999.137163 08/26/2025 00:16:54.555 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 301 08/26/2025 00:16:54.555 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/26/2025 00:16:54.556 7f1a0d870390 [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)]) 08/26/2025 00:16:54.556 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.556 7f1a0d870390 [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=911149617, session_epoch=299, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.556 7f1a0d870390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=911149617, session_epoch=299, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.556 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283729.743896, idle connection 222081.000000, request 304999.942064 08/26/2025 00:16:54.556 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283729.297852, idle connection 222080.000000, request 304999.503374 08/26/2025 00:16:54.561 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 32 08/26/2025 00:16:54.561 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 08/26/2025 00:16:54.561 7f1a0da24588 [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)]) 08/26/2025 00:16:54.562 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.562 7f1a0da24588 [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=1462372297, session_epoch=274, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.562 7f1a0da24588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1462372297, session_epoch=274, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.562 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282517.946045, idle connection 221827.000000, request 304999.952793 08/26/2025 00:16:54.562 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 78 08/26/2025 00:16:54.562 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 08/26/2025 00:16:54.562 7f1a0da5c978 [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)]) 08/26/2025 00:16:54.562 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.562 7f1a0da5c978 [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=1752450253, session_epoch=284, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.562 7f1a0da5c978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1752450253, session_epoch=284, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.563 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283727.207520, idle connection 221869.000000, request 304999.958277 08/26/2025 00:16:54.563 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282516.932617, idle connection 221826.000000, request 304998.942137 08/26/2025 00:16:54.563 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 240 08/26/2025 00:16:54.563 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 08/26/2025 00:16:54.563 7f1a0d85b828 [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)]) 08/26/2025 00:16:54.563 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.563 7f1a0d85b828 [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=1997162522, session_epoch=306, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.563 7f1a0d85b828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 309 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1997162522, session_epoch=306, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.564 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283628.517090, idle connection 222027.000000, request 304999.958754 08/26/2025 00:16:54.564 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283725.806641, idle connection 221867.000000, request 304998.559713 08/26/2025 00:16:54.564 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283627.716797, idle connection 222027.000000, request 304999.161243 08/26/2025 00:16:54.597 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 22 08/26/2025 00:16:54.597 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 08/26/2025 00:16:54.597 7f1a0da37390 [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)]) 08/26/2025 00:16:54.597 7f1a0da37390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.598 7f1a0da37390 [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=676987511, session_epoch=267, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.598 7f1a0da37390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=676987511, session_epoch=267, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.598 7f1a0da37390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282552.913818, idle connection 221777.000000, request 304999.937773 08/26/2025 00:16:54.598 7f1a0da37390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282552.429443, idle connection 221776.000000, request 304999.459743 08/26/2025 00:16:54.774 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 164 08/26/2025 00:16:54.774 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/26/2025 00:16:54.774 7f1a0d9c30f0 [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)]) 08/26/2025 00:16:54.774 7f1a0d9c30f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.774 7f1a0d9c30f0 [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=990538155, session_epoch=297, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.775 7f1a0d9c30f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 300 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=990538155, session_epoch=297, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.775 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282473.829346, idle connection 221795.000000, request 304999.935865 08/26/2025 00:16:54.775 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 180 08/26/2025 00:16:54.775 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 08/26/2025 00:16:54.775 7f1a0da236d8 [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)]) 08/26/2025 00:16:54.775 7f1a0da236d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.775 7f1a0da236d8 [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=252887164, session_epoch=289, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.775 7f1a0da236d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 292 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=252887164, session_epoch=289, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.775 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282478.766602, idle connection 221704.000000, request 304999.955416 08/26/2025 00:16:54.776 7f1a0d9c30f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282472.675781, idle connection 221794.000000, request 304998.791218 08/26/2025 00:16:54.776 7f1a0da236d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282477.910400, idle connection 221703.000000, request 304999.102831 08/26/2025 00:16:54.786 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 144 08/26/2025 00:16:54.786 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/26/2025 00:16:54.786 7f1a0eb09780 [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)]) 08/26/2025 00:16:54.786 7f1a0eb09780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.786 7f1a0eb09780 [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=747538721, session_epoch=287, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.787 7f1a0eb09780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=747538721, session_epoch=287, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.787 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282469.392090, idle connection 221757.000000, request 304999.948978 08/26/2025 00:16:54.787 7f1a0ebe7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283087.829834, idle connection 221420.000000, request 304396.907806 08/26/2025 00:16:54.787 7f1a0da37978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283109.087891, idle connection 221620.000000, request 304397.565126 08/26/2025 00:16:54.788 7f1a0eb09780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282468.443604, idle connection 221756.000000, request 304999.001265 08/26/2025 00:16:54.788 7f1a0ebe7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 267 08/26/2025 00:16:54.788 7f1a0ebe7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.788 7f1a0ebe7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 267 (604.2509078979492 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1293647306, topics=[]) 08/26/2025 00:16:54.788 7f1a0ebe7c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1293647306 with 0 response partitions (1 implied) 08/26/2025 00:16:54.789 7f1a0da37978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 08/26/2025 00:16:54.789 7f1a0da37978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.789 7f1a0da37978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 274 (604.0298938751221 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1519939297, topics=[]) 08/26/2025 00:16:54.789 7f1a0da37978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1519939297 with 0 response partitions (1 implied) 08/26/2025 00:16:54.869 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282428.517822, idle connection 221278.000000, request 304399.015188 08/26/2025 00:16:54.870 7f1a10164a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 440 08/26/2025 00:16:54.870 7f1a10164a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.870 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 440 (601.6368865966797 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1940314572, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4031, last_stable_offset=4031, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\xbe\x00\x00\x01\x04\x00\x00\x00\x00\x024\t\x04*\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...')])]) 08/26/2025 00:16:54.870 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1940314572 with 1 response partitions (0 implied) 08/26/2025 00:16:54.870 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4030 08/26/2025 00:16:54.871 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4030 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 08/26/2025 00:16:54.871 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4031 (leader epoch 0) 08/26/2025 00:16:54.871 7f1a0e81d6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283078.732178, idle connection 221585.000000, request 304399.100065 08/26/2025 00:16:54.871 7f1a0e81d6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 08/26/2025 00:16:54.871 7f1a0e81d6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.871 7f1a0e81d6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 278 (601.311206817627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=951938395, topics=[]) 08/26/2025 00:16:54.872 7f1a0e81d6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 951938395 with 0 response partitions (1 implied) 08/26/2025 00:16:54.876 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 147 08/26/2025 00:16:54.876 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 08/26/2025 00:16:54.876 7f1a0eb472e8 [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)]) 08/26/2025 00:16:54.876 7f1a0eb472e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.876 7f1a0eb472e8 [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=253312791, session_epoch=291, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.876 7f1a0eb472e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=253312791, session_epoch=291, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.876 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282460.217773, idle connection 221647.000000, request 304999.939919 08/26/2025 00:16:54.877 7f1a0eb472e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282459.758057, idle connection 221646.000000, request 304999.484301 08/26/2025 00:16:54.884 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 08/26/2025 00:16:54.884 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 08/26/2025 00:16:54.885 7f1a0e491eb8 [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)]) 08/26/2025 00:16:54.885 7f1a0e491eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.885 7f1a0e491eb8 [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=876895786, session_epoch=277, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.885 7f1a0e491eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=876895786, session_epoch=277, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.885 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282495.279297, idle connection 221283.000000, request 304999.947071 08/26/2025 00:16:54.885 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 08/26/2025 00:16:54.885 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/26/2025 00:16:54.885 7f1a0ec18390 [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)]) 08/26/2025 00:16:54.885 7f1a0ec18390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.886 7f1a0ec18390 [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=1857057960, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.886 7f1a0ec18390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1857057960, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.886 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282503.293213, idle connection 221374.000000, request 304999.956846 08/26/2025 00:16:54.886 7f1a0da23ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283574.118408, idle connection 221728.000000, request 304396.769285 08/26/2025 00:16:54.886 7f1a0e491eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282493.967041, idle connection 221281.000000, request 304998.639107 08/26/2025 00:16:54.887 7f1a0da23ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 08/26/2025 00:16:54.887 7f1a0da23ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.887 7f1a0da23ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 297 (603.9116382598877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2055726456, topics=[]) 08/26/2025 00:16:54.887 7f1a0da23ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2055726456 with 0 response partitions (1 implied) 08/26/2025 00:16:54.887 7f1a0ec18390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282501.785645, idle connection 221372.000000, request 304998.452902 08/26/2025 00:16:54.909 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 08/26/2025 00:16:54.909 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 08/26/2025 00:16:54.910 7f1a0eac9b70 [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)]) 08/26/2025 00:16:54.910 7f1a0eac9b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.910 7f1a0eac9b70 [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=835716862, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.910 7f1a0eac9b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=835716862, session_epoch=264, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:54.910 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282511.832031, idle connection 221370.000000, request 304999.943495 08/26/2025 00:16:54.910 7f1a0ebdc630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283116.125732, idle connection 221314.000000, request 304396.401405 08/26/2025 00:16:54.910 7f1a0da74198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283118.745361, idle connection 221539.000000, request 304397.091150 08/26/2025 00:16:54.911 7f1a0eac9b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282511.025391, idle connection 221369.000000, request 304999.146223 08/26/2025 00:16:54.911 7f1a0ebdc630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 08/26/2025 00:16:54.911 7f1a0ebdc630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.911 7f1a0ebdc630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 268 (604.5353412628174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1476187865, topics=[]) 08/26/2025 00:16:54.911 7f1a0ebdc630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1476187865 with 0 response partitions (1 implied) 08/26/2025 00:16:54.912 7f1a0da74198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 08/26/2025 00:16:54.912 7f1a0da74198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.912 7f1a0da74198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 274 (604.3000221252441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1234340878, topics=[]) 08/26/2025 00:16:54.912 7f1a0da74198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1234340878 with 0 response partitions (1 implied) 08/26/2025 00:16:54.940 7f1a0d7c60f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283139.792236, idle connection 221727.000000, request 304397.626877 08/26/2025 00:16:54.941 7f1a0d7c60f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 08/26/2025 00:16:54.941 7f1a0d7c60f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.941 7f1a0d7c60f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 307 (602.9181480407715 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=3198684, topics=[]) 08/26/2025 00:16:54.941 7f1a0d7c60f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 3198684 with 0 response partitions (1 implied) 08/26/2025 00:16:54.941 7f1a0ebfbb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283141.185059, idle connection 221415.000000, request 304397.504568 08/26/2025 00:16:54.941 7f1a0ebfbb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 272 08/26/2025 00:16:54.941 7f1a0ebfbb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.942 7f1a0ebfbb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 272 (602.8759479522705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=388406621, topics=[]) 08/26/2025 00:16:54.942 7f1a0ebfbb70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 388406621 with 0 response partitions (1 implied) 08/26/2025 00:16:54.966 7f1a0d9de198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283123.765137, idle connection 221536.000000, request 304397.727728 08/26/2025 00:16:54.967 7f1a0d9de198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 08/26/2025 00:16:54.967 7f1a0d9de198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.967 7f1a0d9de198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 294 (602.755069732666 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1406289851, topics=[]) 08/26/2025 00:16:54.967 7f1a0d9de198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1406289851 with 0 response partitions (1 implied) 08/26/2025 00:16:54.967 7f1a100c2588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283125.423584, idle connection 221341.000000, request 304397.812366 08/26/2025 00:16:54.967 7f1a100c2588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:54.967 7f1a100c2588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.968 7f1a100c2588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (602.5128364562988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1853566743, topics=[]) 08/26/2025 00:16:54.968 7f1a100c2588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1853566743 with 0 response partitions (1 implied) 08/26/2025 00:16:54.971 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4031 08/26/2025 00:16:54.971 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 08/26/2025 00:16:54.971 7f1a10164a20 [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)]) 08/26/2025 00:16:54.971 7f1a10164a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:54.972 7f1a10164a20 [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=1940314572, session_epoch=438, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4031, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/26/2025 00:16:54.972 7f1a10164a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 441 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1940314572, session_epoch=438, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4031, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/26/2025 00:16:54.972 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282325.989502, idle connection 221176.000000, request 304999.950647 08/26/2025 00:16:54.972 7f1a10164a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282325.524414, idle connection 221175.000000, request 304999.488354 08/26/2025 00:16:54.992 7f1a0eb506d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283151.269287, idle connection 221341.000000, request 304398.549080 08/26/2025 00:16:54.992 7f1a0eb506d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 267 08/26/2025 00:16:54.992 7f1a0eb506d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:54.992 7f1a0eb506d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 267 (601.921558380127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=292544232, topics=[]) 08/26/2025 00:16:54.992 7f1a0eb506d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 292544232 with 0 response partitions (1 implied) 08/26/2025 00:16:55.064 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 5 08/26/2025 00:16:55.064 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/26/2025 00:16:55.064 7f1a0ebe00f0 [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)]) 08/26/2025 00:16:55.064 7f1a0ebe00f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:55.064 7f1a0ebe00f0 [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=677063064, session_epoch=265, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:55.064 7f1a0ebe00f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=677063064, session_epoch=265, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:55.065 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282534.258545, idle connection 221180.000000, request 304999.925613 08/26/2025 00:16:55.065 7f1a0e8510f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281920.069580, idle connection 221175.000000, request 304396.193266 08/26/2025 00:16:55.065 7f1a0ebe00f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282533.481445, idle connection 221179.000000, request 304999.155760 08/26/2025 00:16:55.066 7f1a0e8510f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 268 08/26/2025 00:16:55.066 7f1a0e8510f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.066 7f1a0e8510f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 268 (604.6476364135742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140686728, topics=[]) 08/26/2025 00:16:55.066 7f1a0e8510f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 140686728 with 0 response partitions (1 implied) 08/26/2025 00:16:55.092 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 44 08/26/2025 00:16:55.092 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 08/26/2025 00:16:55.092 7f1a0da83b70 [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)]) 08/26/2025 00:16:55.092 7f1a0da83b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:55.092 7f1a0da83b70 [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=460370517, session_epoch=275, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:55.092 7f1a0da83b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=460370517, session_epoch=275, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:55.092 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282536.367676, idle connection 221250.000000, request 304999.941349 08/26/2025 00:16:55.093 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 108 08/26/2025 00:16:55.093 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 08/26/2025 00:16:55.093 7f1a0d830eb8 [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)]) 08/26/2025 00:16:55.093 7f1a0d830eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/26/2025 00:16:55.093 7f1a0d830eb8 [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=1207306993, session_epoch=283, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:55.093 7f1a0d830eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 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=1207306993, session_epoch=283, topics=[], forgotten_topics_data=[]) 08/26/2025 00:16:55.093 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282537.593506, idle connection 221553.000000, request 304999.958754 08/26/2025 00:16:55.093 7f1a0da83b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282535.255371, idle connection 221249.000000, request 304998.837948 08/26/2025 00:16:55.094 7f1a0d830eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 282536.822998, idle connection 221552.000000, request 304999.191523 08/26/2025 00:16:55.130 7f1a0ebe3eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281920.662109, idle connection 221028.000000, request 304397.606373 08/26/2025 00:16:55.131 7f1a0ebe3eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:55.131 7f1a0ebe3eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.131 7f1a0ebe3eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (602.9043197631836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=29023917, topics=[]) 08/26/2025 00:16:55.131 7f1a0ebe3eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 29023917 with 0 response partitions (1 implied) 08/26/2025 00:16:55.131 7f1a0ebd72e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281924.837158, idle connection 221055.000000, request 304397.661924 08/26/2025 00:16:55.131 7f1a0ebd72e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 266 08/26/2025 00:16:55.131 7f1a0ebd72e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.132 7f1a0ebd72e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 266 (602.6699542999268 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1222259810, topics=[]) 08/26/2025 00:16:55.132 7f1a0ebd72e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1222259810 with 0 response partitions (1 implied) 08/26/2025 00:16:55.157 7f1a0d870390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283128.819824, idle connection 221480.000000, request 304399.020195 08/26/2025 00:16:55.157 7f1a0d870390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 302 08/26/2025 00:16:55.157 7f1a0d870390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.157 7f1a0d870390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 302 (601.4120578765869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=911149617, topics=[]) 08/26/2025 00:16:55.158 7f1a0d870390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 911149617 with 0 response partitions (1 implied) 08/26/2025 00:16:55.164 7f1a0da24588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 281915.434570, idle connection 221225.000000, request 304397.439480 08/26/2025 00:16:55.165 7f1a0da24588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 08/26/2025 00:16:55.165 7f1a0da24588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.165 7f1a0da24588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 277 (602.9212474822998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462372297, topics=[]) 08/26/2025 00:16:55.165 7f1a0da24588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462372297 with 0 response partitions (1 implied) 08/26/2025 00:16:55.165 7f1a0da5c978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283124.672607, idle connection 221266.000000, request 304397.424221 08/26/2025 00:16:55.165 7f1a0d85b828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 283026.828613, idle connection 221426.000000, request 304398.272038 08/26/2025 00:16:55.165 7f1a0da5c978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 08/26/2025 00:16:55.166 7f1a0da5c978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.166 7f1a0da5c978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 287 (603.0216217041016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1752450253, topics=[]) 08/26/2025 00:16:55.166 7f1a0da5c978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1752450253 with 0 response partitions (1 implied) 08/26/2025 00:16:55.166 7f1a0d85b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 309 08/26/2025 00:16:55.166 7f1a0d85b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/26/2025 00:16:55.166 7f1a0d85b828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 309 (602.5052070617676 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1997162522, topics=[]) 08/26/2025 00:16:55.166 7f1a0d85b828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1997162522 with 0 response partitions (1 implied)