07/28/2025 02:31:17.344 7f6a9b364780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 07/28/2025 02:31:17.346 7f6a9b364780 [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)]) 07/28/2025 02:31:17.346 7f6a9b364780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.346 7f6a9b364780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=555101888, session_epoch=848, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.346 7f6a9b364780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 853 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=555101888, session_epoch=848, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.346 7f6a9b364780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177636.545410, idle connection 53702.000000, request 304999.951601 07/28/2025 02:31:17.346 7f6a99e0eb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178330.437256, idle connection 54708.000000, request 304395.632505 07/28/2025 02:31:17.347 7f6a99e0eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 861 07/28/2025 02:31:17.347 7f6a99e0eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.347 7f6a99e0eb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 861 (604.813814163208 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=89490188, topics=[]) 07/28/2025 02:31:17.347 7f6a99e0eb70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 89490188 with 0 response partitions (1 implied) 07/28/2025 02:31:17.347 7f6a9b364780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177635.399170, idle connection 53701.000000, request 304998.810530 07/28/2025 02:31:17.411 7f6a99a65630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 07/28/2025 02:31:17.411 7f6a99a65630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 07/28/2025 02:31:17.411 7f6a99a65630 [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)]) 07/28/2025 02:31:17.411 7f6a99a65630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.411 7f6a99a65630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1648497799, session_epoch=848, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.412 7f6a99a65630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 853 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1648497799, session_epoch=848, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.412 7f6a99a65630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177572.670166, idle connection 53783.000000, request 304999.946117 07/28/2025 02:31:17.412 7f6a99d85b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 75 07/28/2025 02:31:17.412 7f6a99d85b70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 07/28/2025 02:31:17.412 7f6a99d85b70 [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)]) 07/28/2025 02:31:17.412 7f6a99d85b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.412 7f6a99d85b70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157968263, session_epoch=867, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.412 7f6a99d85b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 872 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=157968263, session_epoch=867, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.412 7f6a99d85b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177776.782227, idle connection 54835.000000, request 304999.956369 07/28/2025 02:31:17.413 7f6a99a65630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177571.532959, idle connection 53781.000000, request 304998.814583 07/28/2025 02:31:17.413 7f6a99d85b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177775.981689, idle connection 54834.000000, request 304999.159336 07/28/2025 02:31:17.426 7f6a99a93ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178273.585449, idle connection 53835.000000, request 304396.775723 07/28/2025 02:31:17.426 7f6a99a93ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 859 07/28/2025 02:31:17.426 7f6a99a93ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.426 7f6a99a93ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 859 (603.6970615386963 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1437064328, topics=[]) 07/28/2025 02:31:17.426 7f6a99a93ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1437064328 with 0 response partitions (1 implied) 07/28/2025 02:31:17.427 7f6a99a8c2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177079.722900, idle connection 53623.000000, request 304397.167683 07/28/2025 02:31:17.427 7f6a99a8c2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 907 07/28/2025 02:31:17.427 7f6a99a8c2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.427 7f6a99a8c2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 907 (603.161096572876 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1370872996, topics=[]) 07/28/2025 02:31:17.427 7f6a99a8c2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1370872996 with 0 response partitions (1 implied) 07/28/2025 02:31:17.450 7f6a99e01e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176943.547852, idle connection 53807.000000, request 304398.906231 07/28/2025 02:31:17.450 7f6a99e01e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1282 07/28/2025 02:31:17.450 7f6a99e01e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.451 7f6a99e01e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 1282 (601.6159057617188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1058351736, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3952, last_stable_offset=3952, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0fo\x00\x00\x01\x00\x00\x00\x00\x00\x02\x08P8\xf7\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\x9a\x03\x00\x00\x00\xdc\x02ObjectDatabaseInfo:cn-jenkins-de...')])]) 07/28/2025 02:31:17.451 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1058351736 with 1 response partitions (0 implied) 07/28/2025 02:31:17.451 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 268 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3951 07/28/2025 02:31:17.451 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3951 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 07/28/2025 02:31:17.451 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3952 (leader epoch 0) 07/28/2025 02:31:17.463 7f6a9947eac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177888.629639, idle connection 54791.000000, request 304397.440195 07/28/2025 02:31:17.464 7f6a9947eac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 924 07/28/2025 02:31:17.464 7f6a9947eac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.464 7f6a9947eac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 924 (602.9782295227051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=328045800, topics=[]) 07/28/2025 02:31:17.464 7f6a9947eac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 328045800 with 0 response partitions (1 implied) 07/28/2025 02:31:17.464 7f6a98b3a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177044.404053, idle connection 54035.000000, request 304397.386312 07/28/2025 02:31:17.464 7f6a98b3a588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 963 07/28/2025 02:31:17.464 7f6a98b3a588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.465 7f6a98b3a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 963 (602.9322147369385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=480146368, topics=[]) 07/28/2025 02:31:17.465 7f6a98b3a588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 480146368 with 0 response partitions (1 implied) 07/28/2025 02:31:17.474 7f6a99535c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178325.803223, idle connection 54549.000000, request 304399.127245 07/28/2025 02:31:17.474 7f6a99535c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 862 07/28/2025 02:31:17.474 7f6a99535c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.474 7f6a99535c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 862 (601.2184619903564 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1531535360, topics=[]) 07/28/2025 02:31:17.474 7f6a99535c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1531535360 with 0 response partitions (1 implied) 07/28/2025 02:31:17.481 7f6a986b7c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 155 07/28/2025 02:31:17.481 7f6a986b7c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 07/28/2025 02:31:17.481 7f6a986b7c18 [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)]) 07/28/2025 02:31:17.481 7f6a986b7c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.481 7f6a986b7c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650914720, session_epoch=881, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.481 7f6a986b7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 886 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650914720, session_epoch=881, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.481 7f6a986b7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179251.914062, idle connection 54495.000000, request 304999.947548 07/28/2025 02:31:17.482 7f6a97dee0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 48 07/28/2025 02:31:17.482 7f6a97dee0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 07/28/2025 02:31:17.482 7f6a97dee0f0 [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)]) 07/28/2025 02:31:17.482 7f6a97dee0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.482 7f6a97dee0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1960381469, session_epoch=863, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.482 7f6a97dee0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 868 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1960381469, session_epoch=863, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.482 7f6a97dee0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177714.152100, idle connection 54795.000000, request 304999.958515 07/28/2025 02:31:17.483 7f6a986b7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179250.801758, idle connection 54494.000000, request 304998.839617 07/28/2025 02:31:17.483 7f6a97dee0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177713.440186, idle connection 54795.000000, request 304999.249935 07/28/2025 02:31:17.525 7f6a995ae8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 51 07/28/2025 02:31:17.525 7f6a995ae8d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 07/28/2025 02:31:17.525 7f6a995ae8d0 [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)]) 07/28/2025 02:31:17.525 7f6a995ae8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.525 7f6a995ae8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=508153101, session_epoch=861, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.525 7f6a995ae8d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 866 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=508153101, session_epoch=861, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.525 7f6a995ae8d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177765.559082, idle connection 53994.000000, request 304999.942780 07/28/2025 02:31:17.526 7f6a994da588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 107 07/28/2025 02:31:17.526 7f6a994da588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 07/28/2025 02:31:17.526 7f6a994da588 [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)]) 07/28/2025 02:31:17.526 7f6a994da588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.526 7f6a994da588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1616706675, session_epoch=879, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.526 7f6a994da588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 884 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1616706675, session_epoch=879, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.526 7f6a994da588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176724.406982, idle connection 53894.000000, request 304999.958992 07/28/2025 02:31:17.527 7f6a995ae8d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177764.474609, idle connection 53993.000000, request 304998.863459 07/28/2025 02:31:17.527 7f6a994da588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176723.662842, idle connection 53894.000000, request 304999.217987 07/28/2025 02:31:17.552 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3952 07/28/2025 02:31:17.552 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 07/28/2025 02:31:17.552 7f6a99e01e10 [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)]) 07/28/2025 02:31:17.552 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.552 7f6a99e01e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1058351736, session_epoch=1278, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3952, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:17.552 7f6a99e01e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 1283 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1058351736, session_epoch=1278, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3952, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:17.553 7f6a99e01e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176841.107422, idle connection 53705.000000, request 304999.947071 07/28/2025 02:31:17.553 7f6a99e01e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176840.721680, idle connection 53704.000000, request 304999.567032 07/28/2025 02:31:17.570 7f6a99d87e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178810.141113, idle connection 54679.000000, request 304398.689508 07/28/2025 02:31:17.570 7f6a99d87e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 871 07/28/2025 02:31:17.570 7f6a99d87e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.570 7f6a99d87e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 871 (601.7754077911377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=352734145, topics=[]) 07/28/2025 02:31:17.570 7f6a99d87e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 352734145 with 0 response partitions (1 implied) 07/28/2025 02:31:17.589 7f6a99e12c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 65 07/28/2025 02:31:17.589 7f6a99e12c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 07/28/2025 02:31:17.589 7f6a99e12c18 [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)]) 07/28/2025 02:31:17.589 7f6a99e12c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.589 7f6a99e12c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1623503256, session_epoch=862, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.589 7f6a99e12c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 867 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1623503256, session_epoch=862, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.590 7f6a99e12c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177806.141113, idle connection 54354.000000, request 304999.942780 07/28/2025 02:31:17.590 7f6a99e12c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177805.698242, idle connection 54353.000000, request 304999.507904 07/28/2025 02:31:17.796 7f6a98b3ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178333.903076, idle connection 54272.000000, request 304397.170305 07/28/2025 02:31:17.796 7f6a98b3ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 903 07/28/2025 02:31:17.796 7f6a98b3ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.796 7f6a98b3ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 903 (603.386402130127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=840498331, topics=[]) 07/28/2025 02:31:17.797 7f6a98b3ccc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 840498331 with 0 response partitions (1 implied) 07/28/2025 02:31:17.797 7f6a9957c2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177977.849121, idle connection 54749.000000, request 304397.293329 07/28/2025 02:31:17.797 7f6a9957c2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 930 07/28/2025 02:31:17.797 7f6a9957c2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.797 7f6a9957c2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 930 (603.0209064483643 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1169177150, topics=[]) 07/28/2025 02:31:17.797 7f6a9957c2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1169177150 with 0 response partitions (1 implied) 07/28/2025 02:31:17.914 7f6a99457588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176780.463135, idle connection 53833.000000, request 304398.695707 07/28/2025 02:31:17.914 7f6a99457588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 892 07/28/2025 02:31:17.914 7f6a99457588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.914 7f6a99457588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 892 (601.8106937408447 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=824455135, topics=[]) 07/28/2025 02:31:17.914 7f6a99457588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 824455135 with 0 response partitions (1 implied) 07/28/2025 02:31:17.932 7f6a98b088d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 300 07/28/2025 02:31:17.932 7f6a98b088d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 07/28/2025 02:31:17.932 7f6a98b088d0 [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)]) 07/28/2025 02:31:17.932 7f6a98b088d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.932 7f6a98b088d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683410800, session_epoch=906, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.932 7f6a98b088d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 911 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683410800, session_epoch=906, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.932 7f6a98b088d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177239.017578, idle connection 53533.000000, request 304999.943018 07/28/2025 02:31:17.932 7f6a99e130f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 25 07/28/2025 02:31:17.932 7f6a99e130f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 07/28/2025 02:31:17.933 7f6a99e130f0 [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)]) 07/28/2025 02:31:17.933 7f6a99e130f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.933 7f6a99e130f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=14884412, session_epoch=859, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.933 7f6a99e130f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 864 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=14884412, session_epoch=859, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.933 7f6a99e130f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177598.601562, idle connection 54275.000000, request 304999.956131 07/28/2025 02:31:17.933 7f6a98b088d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177237.878662, idle connection 53532.000000, request 304998.810053 07/28/2025 02:31:17.933 7f6a99e05f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 17 07/28/2025 02:31:17.934 7f6a99e05f60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 07/28/2025 02:31:17.934 7f6a99e05f60 [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)]) 07/28/2025 02:31:17.934 7f6a99e05f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.934 7f6a99e05f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=600492810, session_epoch=856, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.934 7f6a99e05f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 861 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=600492810, session_epoch=856, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.934 7f6a99e05f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177599.509766, idle connection 53584.000000, request 304999.958754 07/28/2025 02:31:17.934 7f6a99e130f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177597.205078, idle connection 54274.000000, request 304998.562574 07/28/2025 02:31:17.935 7f6a99e05f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177598.787109, idle connection 53584.000000, request 304999.228954 07/28/2025 02:31:17.936 7f6a99e40c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178121.140625, idle connection 53810.000000, request 304397.571564 07/28/2025 02:31:17.936 7f6a99e40c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 906 07/28/2025 02:31:17.936 7f6a99e40c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.936 7f6a99e40c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 906 (602.7920246124268 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1750829314, topics=[]) 07/28/2025 02:31:17.936 7f6a99e40c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1750829314 with 0 response partitions (1 implied) 07/28/2025 02:31:17.937 7f6a99d85e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177036.004150, idle connection 53639.000000, request 304397.212744 07/28/2025 02:31:17.937 7f6a99d85e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 856 07/28/2025 02:31:17.937 7f6a99d85e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.937 7f6a99d85e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 856 (603.1079292297363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=743164482, topics=[]) 07/28/2025 02:31:17.937 7f6a99d85e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 743164482 with 0 response partitions (1 implied) 07/28/2025 02:31:17.938 7f6a99e1c4e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176911.678711, idle connection 54230.000000, request 304397.218943 07/28/2025 02:31:17.938 7f6a99e1c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 906 07/28/2025 02:31:17.938 7f6a99e1c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.938 7f6a99e1c4e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 906 (603.0879020690918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=733028330, topics=[]) 07/28/2025 02:31:17.938 7f6a99e1c4e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 733028330 with 0 response partitions (1 implied) 07/28/2025 02:31:17.938 7f6a99e1c390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177038.226074, idle connection 53914.000000, request 304397.646427 07/28/2025 02:31:17.939 7f6a99e1c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 866 07/28/2025 02:31:17.939 7f6a99e1c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.939 7f6a99e1c390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 866 (602.6608943939209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=574811034, topics=[]) 07/28/2025 02:31:17.939 7f6a99e1c390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 574811034 with 0 response partitions (1 implied) 07/28/2025 02:31:17.939 7f6a99dbf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 9 07/28/2025 02:31:17.939 7f6a99dbf978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 07/28/2025 02:31:17.939 7f6a99dbf978 [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)]) 07/28/2025 02:31:17.939 7f6a99dbf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.939 7f6a99dbf978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1506026263, session_epoch=852, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.939 7f6a99dbf978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 857 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1506026263, session_epoch=852, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.940 7f6a99dbf978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177724.735352, idle connection 53805.000000, request 304999.958277 07/28/2025 02:31:17.940 7f6a99a8f8d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177038.958496, idle connection 53286.000000, request 304397.434711 07/28/2025 02:31:17.940 7f6a99a8f8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 863 07/28/2025 02:31:17.940 7f6a99a8f8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.940 7f6a99a8f8d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 863 (602.8900146484375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=227838368, topics=[]) 07/28/2025 02:31:17.940 7f6a99a8f8d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 227838368 with 0 response partitions (1 implied) 07/28/2025 02:31:17.940 7f6a99542cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177345.890137, idle connection 53579.000000, request 304399.104357 07/28/2025 02:31:17.941 7f6a99dbf978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177723.571533, idle connection 53804.000000, request 304998.797417 07/28/2025 02:31:17.941 7f6a99542cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 883 07/28/2025 02:31:17.941 7f6a99542cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.941 7f6a99542cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 883 (601.5417575836182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=346585024, topics=[]) 07/28/2025 02:31:17.941 7f6a99542cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 346585024 with 0 response partitions (1 implied) 07/28/2025 02:31:17.947 7f6a99d7d978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177034.300293, idle connection 53800.000000, request 304397.296667 07/28/2025 02:31:17.947 7f6a99d7d978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 861 07/28/2025 02:31:17.947 7f6a99d7d978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.947 7f6a99d7d978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 861 (603.062629699707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=729925832, topics=[]) 07/28/2025 02:31:17.947 7f6a99d7d978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 729925832 with 0 response partitions (1 implied) 07/28/2025 02:31:17.947 7f6a99e0eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 37 07/28/2025 02:31:17.947 7f6a99e0eb70 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 07/28/2025 02:31:17.947 7f6a99e0eb70 [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)]) 07/28/2025 02:31:17.947 7f6a99e0eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:17.948 7f6a99e0eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=89490188, session_epoch=857, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.948 7f6a99e0eb70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 862 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=89490188, session_epoch=857, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:17.948 7f6a99e0eb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177728.981201, idle connection 54107.000000, request 304999.957323 07/28/2025 02:31:17.948 7f6a9b364780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177034.663818, idle connection 53101.000000, request 304398.074389 07/28/2025 02:31:17.948 7f6a99e0eb70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177728.469482, idle connection 54106.000000, request 304999.448776 07/28/2025 02:31:17.948 7f6a9b364780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 853 07/28/2025 02:31:17.949 7f6a9b364780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:17.949 7f6a9b364780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 853 (602.5636196136475 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=555101888, topics=[]) 07/28/2025 02:31:17.949 7f6a9b364780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 555101888 with 0 response partitions (1 implied) 07/28/2025 02:31:18.014 7f6a99a65630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176970.660645, idle connection 53181.000000, request 304397.932768 07/28/2025 02:31:18.014 7f6a99a65630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 853 07/28/2025 02:31:18.014 7f6a99a65630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.014 7f6a99a65630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 853 (602.5147438049316 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1648497799, topics=[]) 07/28/2025 02:31:18.014 7f6a99a65630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1648497799 with 0 response partitions (1 implied) 07/28/2025 02:31:18.015 7f6a99d85b70 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177174.675293, idle connection 54233.000000, request 304397.851706 07/28/2025 02:31:18.015 7f6a99d85b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 872 07/28/2025 02:31:18.015 7f6a99d85b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.015 7f6a99d85b70 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 872 (602.4742126464844 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=157968263, topics=[]) 07/28/2025 02:31:18.015 7f6a99d85b70 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 157968263 with 0 response partitions (1 implied) 07/28/2025 02:31:18.027 7f6a99a93ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 18 07/28/2025 02:31:18.027 7f6a99a93ac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 07/28/2025 02:31:18.027 7f6a99a93ac8 [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)]) 07/28/2025 02:31:18.027 7f6a99a93ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.027 7f6a99a93ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1437064328, session_epoch=855, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.027 7f6a99a93ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 860 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1437064328, session_epoch=855, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.027 7f6a99a93ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177671.857178, idle connection 53233.000000, request 304999.945164 07/28/2025 02:31:18.028 7f6a99a8c2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 242 07/28/2025 02:31:18.028 7f6a99a8c2e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 07/28/2025 02:31:18.028 7f6a99a8c2e8 [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)]) 07/28/2025 02:31:18.028 7f6a99a8c2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.028 7f6a99a8c2e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1370872996, session_epoch=903, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.028 7f6a99a8c2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 908 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1370872996, session_epoch=903, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.028 7f6a99a8c2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176478.129150, idle connection 53021.000000, request 304999.954700 07/28/2025 02:31:18.029 7f6a99a93ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177670.751953, idle connection 53232.000000, request 304998.846054 07/28/2025 02:31:18.029 7f6a99a8c2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176477.449463, idle connection 53021.000000, request 304999.280453 07/28/2025 02:31:18.064 7f6a9947eac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 289 07/28/2025 02:31:18.064 7f6a9947eac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 07/28/2025 02:31:18.065 7f6a9947eac8 [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)]) 07/28/2025 02:31:18.065 7f6a9947eac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.065 7f6a9947eac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=328045800, session_epoch=920, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.065 7f6a9947eac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 925 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=328045800, session_epoch=920, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.065 7f6a9947eac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177287.033691, idle connection 54189.000000, request 304999.940634 07/28/2025 02:31:18.065 7f6a98b3a588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 491 07/28/2025 02:31:18.065 7f6a98b3a588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 07/28/2025 02:31:18.065 7f6a98b3a588 [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)]) 07/28/2025 02:31:18.065 7f6a98b3a588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.066 7f6a98b3a588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=480146368, session_epoch=959, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.066 7f6a98b3a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 964 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=480146368, session_epoch=959, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.066 7f6a98b3a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176442.861816, idle connection 53433.000000, request 304999.952793 07/28/2025 02:31:18.066 7f6a9947eac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177285.916748, idle connection 54188.000000, request 304998.832464 07/28/2025 02:31:18.066 7f6a98b3a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176442.160156, idle connection 53433.000000, request 304999.257088 07/28/2025 02:31:18.075 7f6a99535c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 37 07/28/2025 02:31:18.075 7f6a99535c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 07/28/2025 02:31:18.075 7f6a99535c18 [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)]) 07/28/2025 02:31:18.075 7f6a99535c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.075 7f6a99535c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1531535360, session_epoch=858, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.075 7f6a99535c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 863 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1531535360, session_epoch=858, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.075 7f6a99535c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177724.443848, idle connection 53948.000000, request 304999.951124 07/28/2025 02:31:18.076 7f6a99535c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177724.066406, idle connection 53947.000000, request 304999.577522 07/28/2025 02:31:18.083 7f6a986b7c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178650.176514, idle connection 53893.000000, request 304398.214102 07/28/2025 02:31:18.083 7f6a986b7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 886 07/28/2025 02:31:18.083 7f6a986b7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.084 7f6a986b7c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 886 (602.170467376709 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=650914720, topics=[]) 07/28/2025 02:31:18.084 7f6a986b7c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 650914720 with 0 response partitions (1 implied) 07/28/2025 02:31:18.084 7f6a97dee0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177112.349609, idle connection 54194.000000, request 304398.157835 07/28/2025 02:31:18.084 7f6a97dee0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 868 07/28/2025 02:31:18.084 7f6a97dee0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.084 7f6a97dee0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 868 (602.168083190918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1960381469, topics=[]) 07/28/2025 02:31:18.084 7f6a97dee0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1960381469 with 0 response partitions (1 implied) 07/28/2025 02:31:18.127 7f6a995ae8d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177163.628906, idle connection 53392.000000, request 304398.009300 07/28/2025 02:31:18.128 7f6a995ae8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 866 07/28/2025 02:31:18.128 7f6a995ae8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.128 7f6a995ae8d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 866 (602.5047302246094 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=508153101, topics=[]) 07/28/2025 02:31:18.128 7f6a995ae8d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 508153101 with 0 response partitions (1 implied) 07/28/2025 02:31:18.128 7f6a994da588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176122.260498, idle connection 53292.000000, request 304397.812366 07/28/2025 02:31:18.128 7f6a994da588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 884 07/28/2025 02:31:18.129 7f6a994da588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.129 7f6a994da588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 884 (602.5114059448242 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1616706675, topics=[]) 07/28/2025 02:31:18.129 7f6a994da588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1616706675 with 0 response partitions (1 implied) 07/28/2025 02:31:18.153 7f6a99e01e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176240.350098, idle connection 53104.000000, request 304399.185896 07/28/2025 02:31:18.154 7f6a99e01e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1283 07/28/2025 02:31:18.154 7f6a99e01e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.154 7f6a99e01e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 1283 (601.3438701629639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1058351736, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3953, last_stable_offset=3953, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0fp\x00\x00\x01\x05\x00\x00\x00\x00\x02\xb3\x16\xbe\xbf\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 07/28/2025 02:31:18.154 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1058351736 with 1 response partitions (0 implied) 07/28/2025 02:31:18.154 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3952 07/28/2025 02:31:18.154 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3952 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 07/28/2025 02:31:18.155 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3953 (leader epoch 0) 07/28/2025 02:31:18.170 7f6a99d87e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 46 07/28/2025 02:31:18.171 7f6a99d87e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 07/28/2025 02:31:18.171 7f6a99d87e10 [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)]) 07/28/2025 02:31:18.171 7f6a99d87e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.171 7f6a99d87e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=352734145, session_epoch=867, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.171 7f6a99d87e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 872 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=352734145, session_epoch=867, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:18.171 7f6a99d87e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178208.617920, idle connection 54077.000000, request 304999.940872 07/28/2025 02:31:18.171 7f6a99d87e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178208.186035, idle connection 54077.000000, request 304999.516487 07/28/2025 02:31:18.190 7f6a99e12c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177205.343994, idle connection 53753.000000, request 304399.149895 07/28/2025 02:31:18.191 7f6a99e12c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 867 07/28/2025 02:31:18.191 7f6a99e12c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:18.191 7f6a99e12c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Response 867 (601.3205051422119 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1623503256, topics=[]) 07/28/2025 02:31:18.191 7f6a99e12c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1623503256 with 0 response partitions (1 implied) 07/28/2025 02:31:18.256 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3953 07/28/2025 02:31:18.256 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 07/28/2025 02:31:18.256 7f6a99e01e10 [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)]) 07/28/2025 02:31:18.256 7f6a99e01e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:18.256 7f6a99e01e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1058351736, session_epoch=1279, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3953, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:18.257 7f6a99e01e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.254', 9092)]>: Request 1284 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1058351736, session_epoch=1279, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3953, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:18.257 7f6a99e01e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176136.717773, idle connection 53000.000000, request 304999.933481 07/28/2025 02:31:18.257 7f6a99e01e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176136.235840, idle connection 53000.000000, request 304999.459267