06/01/2026 02:26:31.416 7f732eca05e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2347 06/01/2026 02:26:31.417 7f732eca05e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.418 7f732eca05e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2347 (602.9481887817383 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1037427446, topics=[]) 06/01/2026 02:26:31.418 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1037427446 with 0 response partitions (1 implied) 06/01/2026 02:26:31.468 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 204 06/01/2026 02:26:31.468 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 06/01/2026 02:26:31.468 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 06/01/2026 02:26:31.468 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.468 7f732d70a9a0 [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=1370503873, session_epoch=2299, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.468 7f732d70a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2310 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1370503873, session_epoch=2299, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.468 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269143.102539, idle connection 497096.000000, request 304999.929190 06/01/2026 02:26:31.469 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269142.592285, idle connection 497095.000000, request 304999.429703 06/01/2026 02:26:31.570 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 6 06/01/2026 02:26:31.570 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 06/01/2026 02:26:31.570 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 06/01/2026 02:26:31.571 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.571 7f732d70a220 [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=121104449, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.571 7f732d70a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=121104449, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.571 7f732d70a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267989.245361, idle connection 494735.000000, request 304999.938011 06/01/2026 02:26:31.571 7f732d046180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268434.340576, idle connection 498796.000000, request 304397.268295 06/01/2026 02:26:31.572 7f732d70a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267988.568848, idle connection 494734.000000, request 304999.274254 06/01/2026 02:26:31.572 7f732d046180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2323 06/01/2026 02:26:31.572 7f732d046180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.572 7f732d046180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2323 (603.5597324371338 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1330167754, topics=[]) 06/01/2026 02:26:31.572 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1330167754 with 0 response partitions (1 implied) 06/01/2026 02:26:31.608 7f732d70a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268498.327393, idle connection 497659.000000, request 304398.922682 06/01/2026 02:26:31.608 7f732d70a860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2349 06/01/2026 02:26:31.609 7f732d70a860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.609 7f732d70a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2349 (601.7594337463379 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=359244489, topics=[]) 06/01/2026 02:26:31.609 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 359244489 with 0 response partitions (1 implied) 06/01/2026 02:26:31.651 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 97 06/01/2026 02:26:31.651 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 06/01/2026 02:26:31.651 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 06/01/2026 02:26:31.651 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.651 7f732eca07c0 [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=1813109497, session_epoch=2309, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.652 7f732eca07c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2320 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1813109497, session_epoch=2309, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.652 7f732eca07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267258.279297, idle connection 496423.000000, request 304999.944210 06/01/2026 02:26:31.652 7f732eca07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267257.829590, idle connection 496422.000000, request 304999.501944 06/01/2026 02:26:31.692 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267843.805908, idle connection 498197.000000, request 304398.939133 06/01/2026 02:26:31.693 7f732d70acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2354 06/01/2026 02:26:31.693 7f732d70acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.693 7f732d70acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2354 (601.7012596130371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1355545729, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=325, last_stable_offset=325, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01C\x00\x00\x01\xed\x00\x00\x00\x00\x02\x0e\x15\x88R\x00\x00\x00\x00\x00\x01\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\x02\xb8\x03\x00\x00\x00\xfa\x02ObjectGeneratorInfo:cn-jenkins-d...')])]) 06/01/2026 02:26:31.693 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1355545729 with 1 response partitions (0 implied) 06/01/2026 02:26:31.693 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 505 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 323 06/01/2026 02:26:31.693 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 323 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 06/01/2026 02:26:31.694 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 325 (leader epoch 0) 06/01/2026 02:26:31.698 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 06/01/2026 02:26:31.698 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 06/01/2026 02:26:31.698 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 06/01/2026 02:26:31.698 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.698 7f732eca0360 [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=645957174, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.698 7f732eca0360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=645957174, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.698 7f732eca0360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266865.052246, idle connection 494794.000000, request 304999.950647 06/01/2026 02:26:31.699 7f732eca0360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266864.616455, idle connection 494794.000000, request 304999.521017 06/01/2026 02:26:31.707 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 06/01/2026 02:26:31.707 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/01/2026 02:26:31.707 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/01/2026 02:26:31.707 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.707 7f732eca00e0 [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=509054728, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.707 7f732eca00e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=509054728, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.708 7f732eca00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269269.876465, idle connection 494786.000000, request 304999.948978 06/01/2026 02:26:31.708 7f732eca00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269269.501953, idle connection 494786.000000, request 304999.580860 06/01/2026 02:26:31.711 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 06/01/2026 02:26:31.711 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 06/01/2026 02:26:31.711 7f732eca0900 [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)]) 06/01/2026 02:26:31.711 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.711 7f732eca0900 [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=1276031713, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.711 7f732eca0900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1276031713, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.711 7f732eca0900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269267.774414, idle connection 495989.000000, request 304999.956608 06/01/2026 02:26:31.712 7f732eca0900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269267.408203, idle connection 495989.000000, request 304999.593258 06/01/2026 02:26:31.712 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 146 06/01/2026 02:26:31.712 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/01/2026 02:26:31.712 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/01/2026 02:26:31.712 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.712 7f732d0460e0 [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=769421207, session_epoch=2318, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.713 7f732d0460e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=769421207, session_epoch=2318, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.713 7f732d0460e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267770.369873, idle connection 498130.000000, request 304999.958992 06/01/2026 02:26:31.713 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 326 06/01/2026 02:26:31.713 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/01/2026 02:26:31.713 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/01/2026 02:26:31.713 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.713 7f732d70a360 [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=1150949948, session_epoch=2336, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.713 7f732d70a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2347 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1150949948, session_epoch=2336, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.713 7f732d70a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269073.639404, idle connection 498230.000000, request 304999.953747 06/01/2026 02:26:31.714 7f732d0460e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267769.439209, idle connection 498129.000000, request 304999.031305 06/01/2026 02:26:31.714 7f732d70a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269073.022461, idle connection 498229.000000, request 304999.339104 06/01/2026 02:26:31.790 7f732d70aa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268951.894775, idle connection 498101.000000, request 304398.743868 06/01/2026 02:26:31.790 7f732d70aa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2363 06/01/2026 02:26:31.790 7f732d70aa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.791 7f732d70aa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2363 (601.9341945648193 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1023076342, topics=[]) 06/01/2026 02:26:31.791 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1023076342 with 0 response partitions (1 implied) 06/01/2026 02:26:31.794 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 325 06/01/2026 02:26:31.794 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/01/2026 02:26:31.794 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/01/2026 02:26:31.794 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.795 7f732d70acc0 [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=1355545729, session_epoch=2344, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=325, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:26:31.795 7f732d70acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1355545729, session_epoch=2344, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=325, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:26:31.795 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267741.123535, idle connection 498095.000000, request 304999.942303 06/01/2026 02:26:31.795 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267740.597412, idle connection 498094.000000, request 304999.424458 06/01/2026 02:26:31.798 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 610 06/01/2026 02:26:31.798 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 06/01/2026 02:26:31.798 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 06/01/2026 02:26:31.798 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.798 7f732d70ac20 [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=1921926985, session_epoch=2385, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.798 7f732d70ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2396 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1921926985, session_epoch=2385, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.798 7f732d70ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268218.723877, idle connection 498583.000000, request 304999.950886 06/01/2026 02:26:31.799 7f732d70ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268218.324707, idle connection 498582.000000, request 304999.555826 06/01/2026 02:26:31.836 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265699.933594, idle connection 497951.000000, request 304398.874760 06/01/2026 02:26:31.836 7f732b9fdf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3140 06/01/2026 02:26:31.837 7f732b9fdf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.837 7f732b9fdf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 3140 (601.9332408905029 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=251155574, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2700, last_stable_offset=2700, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\n\x8b\x00\x00\x00\xfb\x00\x00\x00\x00\x02e\r&E\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\x90\x03\x00\x00\x00\xd2\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/01/2026 02:26:31.837 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 251155574 with 1 response partitions (0 implied) 06/01/2026 02:26:31.837 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 263 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2699 06/01/2026 02:26:31.837 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2699 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/01/2026 02:26:31.837 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 2700 (leader epoch 0) 06/01/2026 02:26:31.893 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 06/01/2026 02:26:31.893 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/01/2026 02:26:31.893 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/01/2026 02:26:31.893 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.893 7f732b7c7e00 [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=1621498013, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.893 7f732b7c7e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1621498013, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.893 7f732b7c7e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269216.679199, idle connection 495969.000000, request 304999.928951 06/01/2026 02:26:31.894 7f732b7c7e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269216.104004, idle connection 495968.000000, request 304999.363899 06/01/2026 02:26:31.897 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 06/01/2026 02:26:31.897 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 06/01/2026 02:26:31.897 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 06/01/2026 02:26:31.897 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.897 7f732ed28400 [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=146964436, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.898 7f732ed28400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=146964436, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.898 7f732ed28400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269280.006348, idle connection 496012.000000, request 304999.950171 06/01/2026 02:26:31.898 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 06/01/2026 02:26:31.898 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/01/2026 02:26:31.898 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/01/2026 02:26:31.898 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.898 7f732ed280e0 [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=1896486775, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.898 7f732ed280e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1896486775, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.899 7f732ed280e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269281.111328, idle connection 494808.000000, request 304999.960184 06/01/2026 02:26:31.899 7f732ed28400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269278.870605, idle connection 496011.000000, request 304998.819590 06/01/2026 02:26:31.899 7f732ed280e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269280.280762, idle connection 494807.000000, request 304999.132633 06/01/2026 02:26:31.920 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 06/01/2026 02:26:31.920 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 06/01/2026 02:26:31.921 7f732eca04a0 [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)]) 06/01/2026 02:26:31.921 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.921 7f732eca04a0 [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=1560197631, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.921 7f732eca04a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1560197631, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.921 7f732eca04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268054.383057, idle connection 495991.000000, request 304999.940395 06/01/2026 02:26:31.922 7f732eca04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268053.915283, idle connection 495990.000000, request 304999.482632 06/01/2026 02:26:31.924 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 06/01/2026 02:26:31.924 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/01/2026 02:26:31.924 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/01/2026 02:26:31.924 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.924 7f732ed28cc0 [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=596196020, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.924 7f732ed28cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=596196020, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.924 7f732ed28cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268063.997559, idle connection 497225.000000, request 304999.948025 06/01/2026 02:26:31.925 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 06/01/2026 02:26:31.925 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/01/2026 02:26:31.925 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/01/2026 02:26:31.925 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.925 7f732ed3c860 [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=517456141, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.925 7f732ed3c860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=517456141, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.925 7f732ed3c860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268065.088379, idle connection 497225.000000, request 304999.960423 06/01/2026 02:26:31.926 7f732ed28cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268062.853027, idle connection 497224.000000, request 304998.808384 06/01/2026 02:26:31.926 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0 06/01/2026 02:26:31.926 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/01/2026 02:26:31.926 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/01/2026 02:26:31.926 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.926 7f732eca02c0 [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=1401613560, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.926 7f732eca02c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1401613560, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.926 7f732eca02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269268.575439, idle connection 497224.000000, request 304999.958277 06/01/2026 02:26:31.927 7f732ed3c860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268063.543701, idle connection 497223.000000, request 304998.416185 06/01/2026 02:26:31.927 7f732eca02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269267.768555, idle connection 497224.000000, request 304999.155521 06/01/2026 02:26:31.928 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 06/01/2026 02:26:31.928 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/01/2026 02:26:31.928 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/01/2026 02:26:31.928 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.928 7f732ed3c180 [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=842303458, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.928 7f732ed3c180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=842303458, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:31.928 7f732ed3c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268074.457275, idle connection 497234.000000, request 304999.960661 06/01/2026 02:26:31.929 7f732ed3c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268074.081787, idle connection 497234.000000, request 304999.588728 06/01/2026 02:26:31.930 7f732eca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269860.607422, idle connection 496614.000000, request 304390.915632 06/01/2026 02:26:31.930 7f732eca0ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.930 7f732eca0ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.930 7f732eca0ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (609.4825267791748 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2133717391, topics=[]) 06/01/2026 02:26:31.930 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2133717391 with 0 response partitions (1 implied) 06/01/2026 02:26:31.931 7f732eca0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269863.142334, idle connection 496616.000000, request 304396.037102 06/01/2026 02:26:31.931 7f732eca0860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.931 7f732eca0860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.931 7f732eca0860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (604.3980121612549 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=114998294, topics=[]) 06/01/2026 02:26:31.931 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 114998294 with 0 response partitions (1 implied) 06/01/2026 02:26:31.931 7f732d70a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269873.838623, idle connection 496616.000000, request 304396.895647 06/01/2026 02:26:31.932 7f732eca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268671.890381, idle connection 495420.000000, request 304397.542000 06/01/2026 02:26:31.932 7f732d70a4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.932 7f732d70a4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.932 7f732d70a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (603.5723686218262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=917817629, topics=[]) 06/01/2026 02:26:31.932 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 917817629 with 0 response partitions (1 implied) 06/01/2026 02:26:31.932 7f732eca0b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.932 7f732eca0b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.932 7f732eca0b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (603.31130027771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=349379054, topics=[]) 06/01/2026 02:26:31.933 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 349379054 with 0 response partitions (1 implied) 06/01/2026 02:26:31.938 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2700 06/01/2026 02:26:31.938 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/01/2026 02:26:31.938 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/01/2026 02:26:31.938 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:31.938 7f732b9fdf40 [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=251155574, session_epoch=3130, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2700, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:26:31.939 7f732b9fdf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 3141 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=251155574, session_epoch=3130, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2700, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:26:31.939 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265597.114258, idle connection 497848.000000, request 304999.941826 06/01/2026 02:26:31.939 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265596.651855, idle connection 497848.000000, request 304999.484539 06/01/2026 02:26:31.960 7f732d70a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268649.787109, idle connection 495395.000000, request 304397.278786 06/01/2026 02:26:31.960 7f732d70a180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.960 7f732d70a180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.960 7f732d70a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (603.3694744110107 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=586133260, topics=[]) 06/01/2026 02:26:31.960 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 586133260 with 0 response partitions (1 implied) 06/01/2026 02:26:31.961 7f732d70a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269853.201904, idle connection 496599.000000, request 304396.887064 06/01/2026 02:26:31.961 7f732ed3c040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267451.690430, idle connection 496604.000000, request 304397.859573 06/01/2026 02:26:31.961 7f732d70a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.961 7f732d70a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.961 7f732d70a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (603.593111038208 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864505218, topics=[]) 06/01/2026 02:26:31.961 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1864505218 with 0 response partitions (1 implied) 06/01/2026 02:26:31.962 7f732ed3c040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2274 06/01/2026 02:26:31.962 7f732ed3c040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:31.962 7f732ed3c040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2274 (602.9934883117676 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1237287070, topics=[]) 06/01/2026 02:26:31.962 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1237287070 with 0 response partitions (1 implied) 06/01/2026 02:26:32.018 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 347 06/01/2026 02:26:32.018 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/01/2026 02:26:32.018 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/01/2026 02:26:32.019 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.019 7f732eca05e0 [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=1037427446, session_epoch=2337, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.019 7f732eca05e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2348 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1037427446, session_epoch=2337, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.019 7f732eca05e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266547.642578, idle connection 495681.000000, request 304999.942303 06/01/2026 02:26:32.019 7f732eca05e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266547.160156, idle connection 495680.000000, request 304999.467134 06/01/2026 02:26:32.070 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268541.990479, idle connection 496494.000000, request 304398.810625 06/01/2026 02:26:32.070 7f732d70a9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2310 06/01/2026 02:26:32.070 7f732d70a9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.071 7f732d70a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2310 (602.0903587341309 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1370503873, topics=[]) 06/01/2026 02:26:32.071 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1370503873 with 0 response partitions (1 implied) 06/01/2026 02:26:32.173 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 97 06/01/2026 02:26:32.173 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 06/01/2026 02:26:32.173 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 06/01/2026 02:26:32.173 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.173 7f732d046180 [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=1330167754, session_epoch=2313, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.173 7f732d046180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2324 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1330167754, session_epoch=2313, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.173 7f732d046180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267832.167236, idle connection 498193.000000, request 304999.941587 06/01/2026 02:26:32.174 7f732d70a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267386.532227, idle connection 494132.000000, request 304397.237778 06/01/2026 02:26:32.174 7f732d046180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267831.544922, idle connection 498193.000000, request 304999.330282 06/01/2026 02:26:32.174 7f732d70a220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.174 7f732d70a220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.174 7f732d70a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (603.5454273223877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=121104449, topics=[]) 06/01/2026 02:26:32.175 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 121104449 with 0 response partitions (1 implied) 06/01/2026 02:26:32.209 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 377 06/01/2026 02:26:32.209 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/01/2026 02:26:32.209 7f732d70a860 [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)]) 06/01/2026 02:26:32.210 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.210 7f732d70a860 [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=359244489, session_epoch=2339, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.210 7f732d70a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=359244489, session_epoch=2339, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.210 7f732d70a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267896.265137, idle connection 497056.000000, request 304999.935389 06/01/2026 02:26:32.210 7f732d70a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267895.756592, idle connection 497056.000000, request 304999.439001 06/01/2026 02:26:32.253 7f732eca07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266657.200195, idle connection 495821.000000, request 304398.863554 06/01/2026 02:26:32.253 7f732eca07c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2320 06/01/2026 02:26:32.253 7f732eca07c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.253 7f732eca07c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2320 (601.7682552337646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1813109497, topics=[]) 06/01/2026 02:26:32.254 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1813109497 with 0 response partitions (1 implied) 06/01/2026 02:26:32.299 7f732eca0360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266264.125488, idle connection 494193.000000, request 304399.020433 06/01/2026 02:26:32.300 7f732eca0360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.300 7f732eca0360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.300 7f732eca0360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (601.5822887420654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=645957174, topics=[]) 06/01/2026 02:26:32.300 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 645957174 with 0 response partitions (1 implied) 06/01/2026 02:26:32.309 7f732eca00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268668.952881, idle connection 494185.000000, request 304399.024010 06/01/2026 02:26:32.309 7f732eca00e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.309 7f732eca00e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.309 7f732eca00e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (601.5198230743408 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=509054728, topics=[]) 06/01/2026 02:26:32.309 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 509054728 with 0 response partitions (1 implied) 06/01/2026 02:26:32.312 7f732eca0900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268666.989258, idle connection 495388.000000, request 304399.168015 06/01/2026 02:26:32.312 7f732eca0900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.312 7f732eca0900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.312 7f732eca0900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (601.2656688690186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1276031713, topics=[]) 06/01/2026 02:26:32.313 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1276031713 with 0 response partitions (1 implied) 06/01/2026 02:26:32.314 7f732d0460e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267168.763428, idle connection 497528.000000, request 304398.347616 06/01/2026 02:26:32.314 7f732d0460e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2329 06/01/2026 02:26:32.315 7f732d0460e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.315 7f732d0460e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2329 (601.9997596740723 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=769421207, topics=[]) 06/01/2026 02:26:32.315 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 769421207 with 0 response partitions (1 implied) 06/01/2026 02:26:32.315 7f732d70a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268471.993408, idle connection 497628.000000, request 304398.308754 06/01/2026 02:26:32.315 7f732d70a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2347 06/01/2026 02:26:32.315 7f732d70a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.315 7f732d70a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2347 (602.1108627319336 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1150949948, topics=[]) 06/01/2026 02:26:32.315 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1150949948 with 0 response partitions (1 implied) 06/01/2026 02:26:32.391 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 352 06/01/2026 02:26:32.391 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/01/2026 02:26:32.391 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/01/2026 02:26:32.392 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.392 7f732d70aa40 [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=1023076342, session_epoch=2353, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.392 7f732d70aa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1023076342, session_epoch=2353, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.392 7f732d70aa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268349.795654, idle connection 497499.000000, request 304999.937534 06/01/2026 02:26:32.392 7f732d70aa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268349.276611, idle connection 497498.000000, request 304999.428988 06/01/2026 02:26:32.396 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267140.169922, idle connection 497494.000000, request 304398.995399 06/01/2026 02:26:32.396 7f732d70acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2355 06/01/2026 02:26:32.396 7f732d70acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.396 7f732d70acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2355 (601.5255451202393 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1355545729, topics=[]) 06/01/2026 02:26:32.397 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1355545729 with 0 response partitions (1 implied) 06/01/2026 02:26:32.399 7f732d70ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267617.808838, idle connection 497982.000000, request 304399.036646 06/01/2026 02:26:32.399 7f732d70ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2396 06/01/2026 02:26:32.400 7f732d70ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.400 7f732d70ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2396 (601.353645324707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1921926985, topics=[]) 06/01/2026 02:26:32.400 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1921926985 with 0 response partitions (1 implied) 06/01/2026 02:26:32.495 7f732b7c7e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268615.474365, idle connection 495368.000000, request 304398.722410 06/01/2026 02:26:32.495 7f732b7c7e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.495 7f732b7c7e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.495 7f732b7c7e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (601.9539833068848 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1621498013, topics=[]) 06/01/2026 02:26:32.496 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1621498013 with 0 response partitions (1 implied) 06/01/2026 02:26:32.500 7f732ed28400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268677.885986, idle connection 495410.000000, request 304397.828817 06/01/2026 02:26:32.500 7f732ed28400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.500 7f732ed28400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.500 7f732ed28400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (602.6673316955566 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=146964436, topics=[]) 06/01/2026 02:26:32.501 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 146964436 with 0 response partitions (1 implied) 06/01/2026 02:26:32.501 7f732ed280e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268678.852783, idle connection 494205.000000, request 304397.702932 06/01/2026 02:26:32.501 7f732ed280e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.501 7f732ed280e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.501 7f732ed280e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (602.7135848999023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1896486775, topics=[]) 06/01/2026 02:26:32.501 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1896486775 with 0 response partitions (1 implied) 06/01/2026 02:26:32.522 7f732eca04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267453.354980, idle connection 495390.000000, request 304398.908615 06/01/2026 02:26:32.523 7f732eca04a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.523 7f732eca04a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.523 7f732eca04a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (601.7510890960693 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1560197631, topics=[]) 06/01/2026 02:26:32.523 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1560197631 with 0 response partitions (1 implied) 06/01/2026 02:26:32.527 7f732ed28cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267461.290039, idle connection 496622.000000, request 304397.236109 06/01/2026 02:26:32.528 7f732ed28cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.528 7f732ed28cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.528 7f732ed28cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (603.2838821411133 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=596196020, topics=[]) 06/01/2026 02:26:32.528 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 596196020 with 0 response partitions (1 implied) 06/01/2026 02:26:32.528 7f732ed3c860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267462.172363, idle connection 496622.000000, request 304397.045374 06/01/2026 02:26:32.528 7f732eca02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268666.671387, idle connection 496623.000000, request 304398.056984 06/01/2026 02:26:32.529 7f732ed3c860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.529 7f732ed3c860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.529 7f732ed3c860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (603.4839153289795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=517456141, topics=[]) 06/01/2026 02:26:32.529 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 517456141 with 0 response partitions (1 implied) 06/01/2026 02:26:32.529 7f732eca02c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.529 7f732eca02c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.529 7f732eca02c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (602.8149127960205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1401613560, topics=[]) 06/01/2026 02:26:32.529 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1401613560 with 0 response partitions (1 implied) 06/01/2026 02:26:32.530 7f732ed3c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267473.263184, idle connection 496633.000000, request 304398.767710 06/01/2026 02:26:32.530 7f732ed3c180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:32.530 7f732ed3c180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.530 7f732ed3c180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (601.5627384185791 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=842303458, topics=[]) 06/01/2026 02:26:32.530 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 842303458 with 0 response partitions (1 implied) 06/01/2026 02:26:32.531 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0 06/01/2026 02:26:32.531 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 06/01/2026 02:26:32.531 7f732eca0ea0 [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)]) 06/01/2026 02:26:32.531 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.531 7f732eca0ea0 [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=2133717391, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.531 7f732eca0ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2133717391, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.531 7f732eca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269259.157959, idle connection 496013.000000, request 304999.950647 06/01/2026 02:26:32.531 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 06/01/2026 02:26:32.531 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/01/2026 02:26:32.532 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/01/2026 02:26:32.532 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.532 7f732eca0860 [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=114998294, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.532 7f732eca0860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=114998294, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.532 7f732eca0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269261.770020, idle connection 496014.000000, request 304999.959230 06/01/2026 02:26:32.532 7f732eca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269257.966553, idle connection 496011.000000, request 304998.761177 06/01/2026 02:26:32.533 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0 06/01/2026 02:26:32.533 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/01/2026 02:26:32.533 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/01/2026 02:26:32.533 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.533 7f732d70a4a0 [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=917817629, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.533 7f732d70a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=917817629, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.533 7f732d70a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269272.083984, idle connection 496014.000000, request 304999.960184 06/01/2026 02:26:32.533 7f732eca0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269260.216309, idle connection 496013.000000, request 304998.409033 06/01/2026 02:26:32.534 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0 06/01/2026 02:26:32.534 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/01/2026 02:26:32.534 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/01/2026 02:26:32.534 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.534 7f732eca0b80 [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=349379054, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.534 7f732eca0b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349379054, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.534 7f732eca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268069.154541, idle connection 494818.000000, request 304999.951839 06/01/2026 02:26:32.535 7f732d70a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269270.625732, idle connection 496012.000000, request 304998.505592 06/01/2026 02:26:32.535 7f732eca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268068.447754, idle connection 494817.000000, request 304999.258757 06/01/2026 02:26:32.540 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264996.120117, idle connection 497247.000000, request 304398.949385 06/01/2026 02:26:32.540 7f732b9fdf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3141 06/01/2026 02:26:32.540 7f732b9fdf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.540 7f732b9fdf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 3141 (601.560115814209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=251155574, topics=[]) 06/01/2026 02:26:32.540 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 251155574 with 0 response partitions (1 implied) 06/01/2026 02:26:32.562 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0 06/01/2026 02:26:32.562 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 06/01/2026 02:26:32.562 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 06/01/2026 02:26:32.562 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.563 7f732d70a180 [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=586133260, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.563 7f732d70a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=586133260, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.563 7f732d70a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268046.528809, idle connection 494792.000000, request 304999.930859 06/01/2026 02:26:32.563 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 0 06/01/2026 02:26:32.563 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/01/2026 02:26:32.563 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/01/2026 02:26:32.563 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.563 7f732d70a720 [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=1864505218, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.563 7f732d70a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864505218, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.564 7f732d70a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269250.347168, idle connection 495996.000000, request 304999.960661 06/01/2026 02:26:32.564 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0 06/01/2026 02:26:32.564 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/01/2026 02:26:32.565 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/01/2026 02:26:32.565 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.565 7f732ed3c040 [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=1237287070, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.565 7f732ed3c040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2275 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1237287070, session_epoch=2264, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.565 7f732ed3c040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266847.577393, idle connection 496000.000000, request 304999.950886 06/01/2026 02:26:32.575 7f732d70a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268034.603271, idle connection 494780.000000, request 304988.015890 06/01/2026 02:26:32.575 7f732d70a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 269238.776855, idle connection 495985.000000, request 304988.392353 06/01/2026 02:26:32.580 7f732ed3c040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266832.411377, idle connection 495985.000000, request 304984.785795 06/01/2026 02:26:32.620 7f732eca05e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265946.588867, idle connection 495080.000000, request 304398.887634 06/01/2026 02:26:32.621 7f732eca05e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2348 06/01/2026 02:26:32.621 7f732eca05e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.621 7f732eca05e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2348 (601.839542388916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1037427446, topics=[]) 06/01/2026 02:26:32.621 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1037427446 with 0 response partitions (1 implied) 06/01/2026 02:26:32.672 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 204 06/01/2026 02:26:32.672 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 06/01/2026 02:26:32.672 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 06/01/2026 02:26:32.672 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.672 7f732d70a9a0 [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=1370503873, session_epoch=2300, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.673 7f732d70a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2311 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1370503873, session_epoch=2300, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.673 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267938.777100, idle connection 495891.000000, request 304999.933720 06/01/2026 02:26:32.674 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267938.064209, idle connection 495891.000000, request 304999.232769 06/01/2026 02:26:32.775 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 6 06/01/2026 02:26:32.775 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 06/01/2026 02:26:32.775 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 06/01/2026 02:26:32.775 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.775 7f732d70a220 [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=121104449, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.776 7f732d70a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=121104449, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.776 7f732d70a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266784.391602, idle connection 493530.000000, request 304999.935389 06/01/2026 02:26:32.776 7f732d046180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267229.492432, idle connection 497591.000000, request 304397.277355 06/01/2026 02:26:32.777 7f732d70a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266783.549316, idle connection 493529.000000, request 304999.105453 06/01/2026 02:26:32.777 7f732d046180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2324 06/01/2026 02:26:32.777 7f732d046180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.777 7f732d046180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2324 (604.1085720062256 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1330167754, topics=[]) 06/01/2026 02:26:32.778 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1330167754 with 0 response partitions (1 implied) 06/01/2026 02:26:32.811 7f732d70a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267295.225586, idle connection 496455.000000, request 304398.900509 06/01/2026 02:26:32.832 7f732d70a860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2350 06/01/2026 02:26:32.832 7f732d70a860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.832 7f732d70a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2350 (622.462272644043 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=359244489, topics=[]) 06/01/2026 02:26:32.833 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 359244489 with 0 response partitions (1 implied) 06/01/2026 02:26:32.854 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 97 06/01/2026 02:26:32.855 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 06/01/2026 02:26:32.855 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 06/01/2026 02:26:32.855 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.855 7f732eca07c0 [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=1813109497, session_epoch=2310, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.855 7f732eca07c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2321 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1813109497, session_epoch=2310, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.855 7f732eca07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266054.714600, idle connection 495219.000000, request 304999.917269 06/01/2026 02:26:32.856 7f732eca07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266054.035645, idle connection 495218.000000, request 304999.268532 06/01/2026 02:26:32.900 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 06/01/2026 02:26:32.916 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 06/01/2026 02:26:32.916 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 06/01/2026 02:26:32.916 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.917 7f732eca0360 [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=645957174, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.917 7f732eca0360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=645957174, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.917 7f732eca0360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265646.400391, idle connection 493575.000000, request 304999.927759 06/01/2026 02:26:32.917 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 06/01/2026 02:26:32.917 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/01/2026 02:26:32.917 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/01/2026 02:26:32.918 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.918 7f732eca00e0 [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=509054728, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.918 7f732eca00e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=509054728, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.920 7f732eca00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268057.814697, idle connection 493574.000000, request 304999.932289 06/01/2026 02:26:32.920 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 06/01/2026 02:26:32.920 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 06/01/2026 02:26:32.920 7f732eca0900 [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)]) 06/01/2026 02:26:32.920 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.920 7f732eca0900 [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=1276031713, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.920 7f732eca0900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1276031713, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.921 7f732eca0900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268058.472656, idle connection 494780.000000, request 304999.860525 06/01/2026 02:26:32.921 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 146 06/01/2026 02:26:32.922 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/01/2026 02:26:32.922 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/01/2026 02:26:32.922 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.922 7f732d0460e0 [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=769421207, session_epoch=2319, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.922 7f732d0460e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=769421207, session_epoch=2319, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.922 7f732d0460e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266560.947510, idle connection 496920.000000, request 304999.954700 06/01/2026 02:26:32.922 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 326 06/01/2026 02:26:32.922 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/01/2026 02:26:32.922 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/01/2026 02:26:32.923 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.923 7f732d70a360 [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=1150949948, session_epoch=2337, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.923 7f732d70a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2348 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1150949948, session_epoch=2337, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.923 7f732d70a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267864.104736, idle connection 497021.000000, request 304999.959707 06/01/2026 02:26:32.923 7f732eca0360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265639.950928, idle connection 493569.000000, request 304993.492603 06/01/2026 02:26:32.924 7f732eca00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268053.469482, idle connection 493570.000000, request 304995.554924 06/01/2026 02:26:32.925 7f732eca0900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268054.497070, idle connection 494776.000000, request 304995.887518 06/01/2026 02:26:32.925 7f732d0460e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266557.978760, idle connection 496917.000000, request 304996.992588 06/01/2026 02:26:32.925 7f732d70a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267861.460205, idle connection 497018.000000, request 304997.318745 06/01/2026 02:26:32.993 7f732d70aa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267748.468750, idle connection 496898.000000, request 304398.610592 06/01/2026 02:26:32.994 7f732d70aa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2364 06/01/2026 02:26:32.994 7f732d70aa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:32.994 7f732d70aa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2364 (602.013111114502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1023076342, topics=[]) 06/01/2026 02:26:32.994 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1023076342 with 0 response partitions (1 implied) 06/01/2026 02:26:32.997 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 325 06/01/2026 02:26:32.998 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/01/2026 02:26:32.998 7f732d70acc0 [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)]) 06/01/2026 02:26:32.998 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:32.998 7f732d70acc0 [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=1355545729, session_epoch=2345, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.998 7f732d70acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1355545729, session_epoch=2345, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:32.998 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266537.767578, idle connection 496891.000000, request 304999.943256 06/01/2026 02:26:32.999 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266537.235840, idle connection 496891.000000, request 304999.420643 06/01/2026 02:26:33.002 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 610 06/01/2026 02:26:33.002 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 06/01/2026 02:26:33.002 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 06/01/2026 02:26:33.002 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.002 7f732d70ac20 [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=1921926985, session_epoch=2386, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.002 7f732d70ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2397 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1921926985, session_epoch=2386, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.002 7f732d70ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267014.583740, idle connection 497379.000000, request 304999.950409 06/01/2026 02:26:33.003 7f732d70ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267014.150635, idle connection 497378.000000, request 304999.516487 06/01/2026 02:26:33.096 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 06/01/2026 02:26:33.096 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/01/2026 02:26:33.096 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/01/2026 02:26:33.096 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.096 7f732b7c7e00 [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=1621498013, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.097 7f732b7c7e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1621498013, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.097 7f732b7c7e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268013.332031, idle connection 494766.000000, request 304999.938965 06/01/2026 02:26:33.097 7f732b7c7e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268012.784180, idle connection 494765.000000, request 304999.401331 06/01/2026 02:26:33.101 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 06/01/2026 02:26:33.101 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 06/01/2026 02:26:33.101 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 06/01/2026 02:26:33.101 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.101 7f732ed28400 [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=146964436, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.101 7f732ed28400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=146964436, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.102 7f732ed28400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268076.155518, idle connection 494808.000000, request 304999.940395 06/01/2026 02:26:33.102 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 06/01/2026 02:26:33.102 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/01/2026 02:26:33.102 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/01/2026 02:26:33.102 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.102 7f732ed280e0 [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=1896486775, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.102 7f732ed280e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1896486775, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.103 7f732ed280e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268077.116211, idle connection 493604.000000, request 304999.955893 06/01/2026 02:26:33.103 7f732ed28400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268074.778564, idle connection 494807.000000, request 304998.566866 06/01/2026 02:26:33.103 7f732ed280e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268076.235107, idle connection 493603.000000, request 304999.078512 06/01/2026 02:26:33.123 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 06/01/2026 02:26:33.124 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 06/01/2026 02:26:33.124 7f732eca04a0 [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)]) 06/01/2026 02:26:33.124 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.124 7f732eca04a0 [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=1560197631, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.125 7f732eca04a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1560197631, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.125 7f732eca04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266850.567383, idle connection 494787.000000, request 304999.913692 06/01/2026 02:26:33.126 7f732eca04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266849.860352, idle connection 494786.000000, request 304999.220848 06/01/2026 02:26:33.129 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 06/01/2026 02:26:33.129 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/01/2026 02:26:33.129 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/01/2026 02:26:33.129 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.129 7f732ed28cc0 [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=596196020, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.129 7f732ed28cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=596196020, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.129 7f732ed28cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266859.092041, idle connection 496020.000000, request 304999.950409 06/01/2026 02:26:33.130 7f732ed28cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266858.649414, idle connection 496020.000000, request 304999.513388 06/01/2026 02:26:33.130 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 06/01/2026 02:26:33.130 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/01/2026 02:26:33.130 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/01/2026 02:26:33.130 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.130 7f732ed3c860 [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=517456141, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.130 7f732ed3c860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=517456141, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.131 7f732ed3c860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266859.730225, idle connection 496020.000000, request 304999.957561 06/01/2026 02:26:33.131 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0 06/01/2026 02:26:33.131 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/01/2026 02:26:33.131 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/01/2026 02:26:33.131 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.131 7f732eca02c0 [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=1401613560, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.131 7f732eca02c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1401613560, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.131 7f732eca02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268063.751465, idle connection 496020.000000, request 304999.961376 06/01/2026 02:26:33.132 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 06/01/2026 02:26:33.132 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/01/2026 02:26:33.132 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/01/2026 02:26:33.132 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.132 7f732ed3c180 [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=842303458, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.132 7f732ed3c180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=842303458, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.132 7f732ed3c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266870.750000, idle connection 496031.000000, request 304999.964476 06/01/2026 02:26:33.133 7f732ed3c860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266857.800537, idle connection 496018.000000, request 304998.028517 06/01/2026 02:26:33.133 7f732eca02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268062.103760, idle connection 496018.000000, request 304998.312712 06/01/2026 02:26:33.133 7f732ed3c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266869.547607, idle connection 496030.000000, request 304998.765469 06/01/2026 02:26:33.134 7f732eca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268656.034180, idle connection 495409.000000, request 304396.827698 06/01/2026 02:26:33.135 7f732eca0ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.135 7f732eca0ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.135 7f732eca0ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (603.6107540130615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2133717391, topics=[]) 06/01/2026 02:26:33.135 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2133717391 with 0 response partitions (1 implied) 06/01/2026 02:26:33.135 7f732eca0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268658.273438, idle connection 495411.000000, request 304396.465063 06/01/2026 02:26:33.136 7f732eca0860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.136 7f732eca0860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.136 7f732eca0860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (603.874683380127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=114998294, topics=[]) 06/01/2026 02:26:33.136 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 114998294 with 0 response partitions (1 implied) 06/01/2026 02:26:33.136 7f732d70a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268669.131104, idle connection 495411.000000, request 304397.008896 06/01/2026 02:26:33.136 7f732eca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267467.204834, idle connection 494216.000000, request 304398.016214 06/01/2026 02:26:33.136 7f732d70a4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.136 7f732d70a4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.137 7f732d70a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (603.4598350524902 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=917817629, topics=[]) 06/01/2026 02:26:33.137 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 917817629 with 0 response partitions (1 implied) 06/01/2026 02:26:33.137 7f732eca0b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.137 7f732eca0b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.137 7f732eca0b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (602.7777194976807 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=349379054, topics=[]) 06/01/2026 02:26:33.137 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 349379054 with 0 response partitions (1 implied) 06/01/2026 02:26:33.142 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2700 06/01/2026 02:26:33.142 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/01/2026 02:26:33.142 7f732b9fdf40 [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)]) 06/01/2026 02:26:33.142 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.142 7f732b9fdf40 [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=251155574, session_epoch=3131, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.142 7f732b9fdf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 3142 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=251155574, session_epoch=3131, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.142 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264393.568848, idle connection 496645.000000, request 304999.954462 06/01/2026 02:26:33.143 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264393.165283, idle connection 496645.000000, request 304999.557018 06/01/2026 02:26:33.181 7f732d70a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267428.622559, idle connection 494174.000000, request 304382.031202 06/01/2026 02:26:33.181 7f732d70a180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.181 7f732d70a180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.181 7f732d70a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (618.5827255249023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=586133260, topics=[]) 06/01/2026 02:26:33.181 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 586133260 with 0 response partitions (1 implied) 06/01/2026 02:26:33.182 7f732d70a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268632.174805, idle connection 495378.000000, request 304381.788731 06/01/2026 02:26:33.182 7f732ed3c040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266230.667969, idle connection 495383.000000, request 304383.047342 06/01/2026 02:26:33.182 7f732d70a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.182 7f732d70a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.182 7f732d70a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (618.6695098876953 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864505218, topics=[]) 06/01/2026 02:26:33.182 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1864505218 with 0 response partitions (1 implied) 06/01/2026 02:26:33.183 7f732ed3c040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2275 06/01/2026 02:26:33.183 7f732ed3c040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.183 7f732ed3c040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2275 (617.772102355957 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1237287070, topics=[]) 06/01/2026 02:26:33.183 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1237287070 with 0 response partitions (1 implied) 06/01/2026 02:26:33.221 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 347 06/01/2026 02:26:33.222 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/01/2026 02:26:33.222 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/01/2026 02:26:33.222 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.222 7f732eca05e0 [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=1037427446, session_epoch=2338, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.222 7f732eca05e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1037427446, session_epoch=2338, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.222 7f732eca05e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265344.398926, idle connection 494478.000000, request 304999.940157 06/01/2026 02:26:33.223 7f732eca05e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265343.883789, idle connection 494477.000000, request 304999.435663 06/01/2026 02:26:33.274 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267337.411133, idle connection 495290.000000, request 304398.563147 06/01/2026 02:26:33.275 7f732d70a9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2311 06/01/2026 02:26:33.275 7f732d70a9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.275 7f732d70a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2311 (602.1556854248047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1370503873, topics=[]) 06/01/2026 02:26:33.275 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1370503873 with 0 response partitions (1 implied) 06/01/2026 02:26:33.379 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 97 06/01/2026 02:26:33.379 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 06/01/2026 02:26:33.379 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 06/01/2026 02:26:33.379 7f732d046180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.379 7f732d046180 [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=1330167754, session_epoch=2314, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.379 7f732d046180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2325 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1330167754, session_epoch=2314, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.379 7f732d046180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266626.133789, idle connection 496987.000000, request 304999.935865 06/01/2026 02:26:33.380 7f732d70a220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266180.495605, idle connection 492926.000000, request 304396.049500 06/01/2026 02:26:33.380 7f732d046180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266625.462646, idle connection 496987.000000, request 304999.276876 06/01/2026 02:26:33.380 7f732d70a220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.380 7f732d70a220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.381 7f732d70a220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (604.8312187194824 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=121104449, topics=[]) 06/01/2026 02:26:33.381 7f732d70a220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 121104449 with 0 response partitions (1 implied) 06/01/2026 02:26:33.433 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 377 06/01/2026 02:26:33.434 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/01/2026 02:26:33.434 7f732d70a860 [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)]) 06/01/2026 02:26:33.434 7f732d70a860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.434 7f732d70a860 [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=359244489, session_epoch=2340, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.434 7f732d70a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=359244489, session_epoch=2340, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.435 7f732d70a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266671.533203, idle connection 495832.000000, request 304999.907494 06/01/2026 02:26:33.436 7f732d70a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266670.719727, idle connection 495831.000000, request 304999.108076 06/01/2026 02:26:33.457 7f732eca07c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265453.264648, idle connection 494617.000000, request 304398.479462 06/01/2026 02:26:33.457 7f732eca07c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2321 06/01/2026 02:26:33.458 7f732eca07c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.458 7f732eca07c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2321 (602.5569438934326 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1813109497, topics=[]) 06/01/2026 02:26:33.458 7f732eca07c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1813109497 with 0 response partitions (1 implied) 06/01/2026 02:26:33.527 7f732eca0360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265036.754883, idle connection 492966.000000, request 304390.288353 06/01/2026 02:26:33.527 7f732eca0360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.527 7f732eca0360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.527 7f732eca0360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (610.4049682617188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=645957174, topics=[]) 06/01/2026 02:26:33.528 7f732eca0360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 645957174 with 0 response partitions (1 implied) 06/01/2026 02:26:33.528 7f732eca00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267449.666748, idle connection 492966.000000, request 304391.789913 06/01/2026 02:26:33.528 7f732eca0900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267451.053711, idle connection 494172.000000, request 304392.446756 06/01/2026 02:26:33.528 7f732d0460e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265954.921631, idle connection 496314.000000, request 304393.934250 06/01/2026 02:26:33.528 7f732d70a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267258.688721, idle connection 496415.000000, request 304394.546747 06/01/2026 02:26:33.528 7f732eca00e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.529 7f732eca00e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.529 7f732eca00e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (609.0424060821533 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=509054728, topics=[]) 06/01/2026 02:26:33.529 7f732eca00e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 509054728 with 0 response partitions (1 implied) 06/01/2026 02:26:33.529 7f732eca0900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.529 7f732eca0900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.529 7f732eca0900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (608.7892055511475 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1276031713, topics=[]) 06/01/2026 02:26:33.529 7f732eca0900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1276031713 with 0 response partitions (1 implied) 06/01/2026 02:26:33.530 7f732d0460e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2330 06/01/2026 02:26:33.530 7f732d0460e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.530 7f732d0460e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2330 (607.6641082763672 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=769421207, topics=[]) 06/01/2026 02:26:33.530 7f732d0460e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 769421207 with 0 response partitions (1 implied) 06/01/2026 02:26:33.530 7f732d70a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2348 06/01/2026 02:26:33.530 7f732d70a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.530 7f732d70a360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2348 (607.3811054229736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1150949948, topics=[]) 06/01/2026 02:26:33.530 7f732d70a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1150949948 with 0 response partitions (1 implied) 06/01/2026 02:26:33.595 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 352 06/01/2026 02:26:33.595 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/01/2026 02:26:33.596 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/01/2026 02:26:33.596 7f732d70aa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.596 7f732d70aa40 [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=1023076342, session_epoch=2354, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.596 7f732d70aa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2365 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1023076342, session_epoch=2354, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.597 7f732d70aa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267145.220703, idle connection 496294.000000, request 304999.932528 06/01/2026 02:26:33.597 7f732d70aa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267144.540527, idle connection 496294.000000, request 304999.262810 06/01/2026 02:26:33.599 7f732d70acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265936.805664, idle connection 496290.000000, request 304398.989439 06/01/2026 02:26:33.600 7f732d70acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2356 06/01/2026 02:26:33.600 7f732d70acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.600 7f732d70acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2356 (601.6027927398682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1355545729, topics=[]) 06/01/2026 02:26:33.600 7f732d70acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1355545729 with 0 response partitions (1 implied) 06/01/2026 02:26:33.604 7f732d70ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266413.211670, idle connection 496777.000000, request 304398.578644 06/01/2026 02:26:33.604 7f732d70ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2397 06/01/2026 02:26:33.604 7f732d70ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.604 7f732d70ac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2397 (601.9129753112793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1921926985, topics=[]) 06/01/2026 02:26:33.605 7f732d70ac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1921926985 with 0 response partitions (1 implied) 06/01/2026 02:26:33.698 7f732b7c7e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267412.227539, idle connection 494165.000000, request 304398.834705 06/01/2026 02:26:33.698 7f732b7c7e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.699 7f732b7c7e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.699 7f732b7c7e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (601.8838882446289 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1621498013, topics=[]) 06/01/2026 02:26:33.699 7f732b7c7e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1621498013 with 0 response partitions (1 implied) 06/01/2026 02:26:33.704 7f732ed28400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267473.958984, idle connection 494206.000000, request 304397.743940 06/01/2026 02:26:33.704 7f732ed28400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.704 7f732ed28400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.704 7f732ed28400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (602.7867794036865 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=146964436, topics=[]) 06/01/2026 02:26:33.705 7f732ed28400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 146964436 with 0 response partitions (1 implied) 06/01/2026 02:26:33.705 7f732ed280e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267474.847656, idle connection 493001.000000, request 304397.691250 06/01/2026 02:26:33.705 7f732ed280e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.705 7f732ed280e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.705 7f732ed280e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (602.7731895446777 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1896486775, topics=[]) 06/01/2026 02:26:33.705 7f732ed280e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1896486775 with 0 response partitions (1 implied) 06/01/2026 02:26:33.727 7f732eca04a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266248.341553, idle connection 494185.000000, request 304397.695303 06/01/2026 02:26:33.728 7f732eca04a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.728 7f732eca04a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.728 7f732eca04a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (603.0638217926025 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1560197631, topics=[]) 06/01/2026 02:26:33.728 7f732eca04a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1560197631 with 0 response partitions (1 implied) 06/01/2026 02:26:33.732 7f732ed28cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266256.864258, idle connection 495418.000000, request 304397.716999 06/01/2026 02:26:33.732 7f732ed28cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.732 7f732ed28cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.732 7f732ed28cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (602.7803421020508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=596196020, topics=[]) 06/01/2026 02:26:33.732 7f732ed28cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 596196020 with 0 response partitions (1 implied) 06/01/2026 02:26:33.734 7f732ed3c860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266256.681885, idle connection 495417.000000, request 304396.904469 06/01/2026 02:26:33.734 7f732ed3c860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.734 7f732ed3c860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.734 7f732ed3c860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (603.5768985748291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=517456141, topics=[]) 06/01/2026 02:26:33.734 7f732ed3c860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 517456141 with 0 response partitions (1 implied) 06/01/2026 02:26:33.735 7f732eca02c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 267460.246338, idle connection 495416.000000, request 304396.452188 06/01/2026 02:26:33.735 7f732ed3c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266267.872559, idle connection 495428.000000, request 304397.086620 06/01/2026 02:26:33.735 7f732eca02c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.735 7f732eca02c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.735 7f732eca02c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (604.142427444458 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1401613560, topics=[]) 06/01/2026 02:26:33.736 7f732eca02c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1401613560 with 0 response partitions (1 implied) 06/01/2026 02:26:33.736 7f732ed3c180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2276 06/01/2026 02:26:33.736 7f732ed3c180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.736 7f732ed3c180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2276 (603.839635848999 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=842303458, topics=[]) 06/01/2026 02:26:33.736 7f732ed3c180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 842303458 with 0 response partitions (1 implied) 06/01/2026 02:26:33.736 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0 06/01/2026 02:26:33.736 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 06/01/2026 02:26:33.736 7f732eca0ea0 [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)]) 06/01/2026 02:26:33.736 7f732eca0ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.737 7f732eca0ea0 [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=2133717391, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.737 7f732eca0ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2133717391, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.737 7f732eca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268053.554688, idle connection 494807.000000, request 304999.952555 06/01/2026 02:26:33.737 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 06/01/2026 02:26:33.737 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/01/2026 02:26:33.737 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/01/2026 02:26:33.737 7f732eca0860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.737 7f732eca0860 [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=114998294, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.737 7f732eca0860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=114998294, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.737 7f732eca0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268056.225342, idle connection 494809.000000, request 304999.961615 06/01/2026 02:26:33.738 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0 06/01/2026 02:26:33.738 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/01/2026 02:26:33.738 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/01/2026 02:26:33.738 7f732d70a4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.738 7f732d70a4a0 [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=917817629, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.738 7f732d70a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=917817629, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.738 7f732d70a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268066.821533, idle connection 494809.000000, request 304999.960184 06/01/2026 02:26:33.739 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0 06/01/2026 02:26:33.739 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/01/2026 02:26:33.739 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/01/2026 02:26:33.739 7f732eca0b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.739 7f732eca0b80 [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=349379054, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.739 7f732eca0b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349379054, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.739 7f732eca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266864.374756, idle connection 493613.000000, request 304999.953508 06/01/2026 02:26:33.739 7f732eca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268050.926758, idle connection 494804.000000, request 304997.328997 06/01/2026 02:26:33.740 7f732eca0860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268053.931152, idle connection 494807.000000, request 304997.670174 06/01/2026 02:26:33.740 7f732d70a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268064.927246, idle connection 494807.000000, request 304998.068333 06/01/2026 02:26:33.741 7f732eca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266862.776855, idle connection 493611.000000, request 304998.359203 06/01/2026 02:26:33.743 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263792.844727, idle connection 496044.000000, request 304399.234295 06/01/2026 02:26:33.743 7f732b9fdf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3142 06/01/2026 02:26:33.743 7f732b9fdf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.744 7f732b9fdf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 3142 (601.311445236206 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=251155574, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2702, last_stable_offset=2702, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\n\x8c\x00\x00\x01\xd0\x00\x00\x00\x00\x02\xfbg\xc4\x9c\x00\x00\x00\x00\x00\x01\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\x02\xa6\x03\x00\x00\x00\xe8\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])]) 06/01/2026 02:26:33.744 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 251155574 with 1 response partitions (0 implied) 06/01/2026 02:26:33.744 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 476 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2700 06/01/2026 02:26:33.744 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2700 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/01/2026 02:26:33.745 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 2702 (leader epoch 0) 06/01/2026 02:26:33.782 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0 06/01/2026 02:26:33.782 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 06/01/2026 02:26:33.782 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 06/01/2026 02:26:33.782 7f732d70a180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.782 7f732d70a180 [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=586133260, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.783 7f732d70a180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=586133260, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.783 7f732d70a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266826.655029, idle connection 493572.000000, request 304999.942064 06/01/2026 02:26:33.783 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 0 06/01/2026 02:26:33.783 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/01/2026 02:26:33.783 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/01/2026 02:26:33.783 7f732d70a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.783 7f732d70a720 [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=1864505218, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.783 7f732d70a720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864505218, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.783 7f732d70a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268030.411377, idle connection 494776.000000, request 304999.955416 06/01/2026 02:26:33.784 7f732d70a180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266825.407715, idle connection 493571.000000, request 304998.706341 06/01/2026 02:26:33.784 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0 06/01/2026 02:26:33.784 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/01/2026 02:26:33.784 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/01/2026 02:26:33.784 7f732ed3c040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.784 7f732ed3c040 [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=1237287070, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.785 7f732ed3c040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2276 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1237287070, session_epoch=2265, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.785 7f732ed3c040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265627.766113, idle connection 494780.000000, request 304999.948978 06/01/2026 02:26:33.785 7f732d70a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 268028.779785, idle connection 494775.000000, request 304998.327971 06/01/2026 02:26:33.786 7f732ed3c040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265626.876953, idle connection 494779.000000, request 304999.063253 06/01/2026 02:26:33.823 7f732eca05e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264743.274170, idle connection 493876.000000, request 304398.815870 06/01/2026 02:26:33.824 7f732eca05e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2349 06/01/2026 02:26:33.824 7f732eca05e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/01/2026 02:26:33.824 7f732eca05e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 2349 (601.8400192260742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1037427446, topics=[]) 06/01/2026 02:26:33.824 7f732eca05e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1037427446 with 0 response partitions (1 implied) 06/01/2026 02:26:33.846 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2702 06/01/2026 02:26:33.846 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/01/2026 02:26:33.846 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/01/2026 02:26:33.847 7f732b9fdf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.847 7f732b9fdf40 [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=251155574, session_epoch=3132, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2702, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:26:33.847 7f732b9fdf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 3143 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=251155574, session_epoch=3132, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2702, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/01/2026 02:26:33.847 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263688.802246, idle connection 495940.000000, request 304999.894619 06/01/2026 02:26:33.848 7f732b9fdf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263688.231201, idle connection 495940.000000, request 304999.337435 06/01/2026 02:26:33.876 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 204 06/01/2026 02:26:33.876 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 06/01/2026 02:26:33.876 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 06/01/2026 02:26:33.876 7f732d70a9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/01/2026 02:26:33.876 7f732d70a9a0 [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=1370503873, session_epoch=2301, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.876 7f732d70a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 2312 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1370503873, session_epoch=2301, topics=[], forgotten_topics_data=[]) 06/01/2026 02:26:33.876 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266735.086914, idle connection 494688.000000, request 304999.934912 06/01/2026 02:26:33.877 7f732d70a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 266734.565918, idle connection 494687.000000, request 304999.425411