04/23/2026 02:07:45.448 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83062.613525, idle connection 261399.000000, request 304398.630142 04/23/2026 02:07:45.450 7ff0062d25e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 04/23/2026 02:07:45.450 7ff0062d25e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.450 7ff0062d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 720 (603.032112121582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=294578344, topics=[]) 04/23/2026 02:07:45.450 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 294578344 with 0 response partitions (1 implied) 04/23/2026 02:07:45.450 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 261 04/23/2026 02:07:45.450 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 04/23/2026 02:07:45.450 7ff0062d2ae0 [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)]) 04/23/2026 02:07:45.450 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.450 7ff0062d2ae0 [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=982030124, session_epoch=731, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.451 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 735 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=982030124, session_epoch=731, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.451 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82914.701660, idle connection 261144.000000, request 304999.952793 04/23/2026 02:07:45.451 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82914.240723, idle connection 261143.000000, request 304999.496460 04/23/2026 02:07:45.455 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83379.230957, idle connection 261113.000000, request 304398.906708 04/23/2026 02:07:45.456 7ff0062d2a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 04/23/2026 02:07:45.456 7ff0062d2a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.456 7ff0062d2a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 710 (601.4652252197266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1131051951, topics=[]) 04/23/2026 02:07:45.456 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1131051951 with 0 response partitions (1 implied) 04/23/2026 02:07:45.460 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44 04/23/2026 02:07:45.460 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/23/2026 02:07:45.460 7ff0062d2540 [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)]) 04/23/2026 02:07:45.461 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.461 7ff0062d2540 [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=890357573, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.461 7ff0062d2540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=890357573, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.461 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83365.716064, idle connection 261217.000000, request 304999.958038 04/23/2026 02:07:45.461 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83365.352051, idle connection 261217.000000, request 304999.596119 04/23/2026 02:07:45.462 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 34 04/23/2026 02:07:45.462 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 04/23/2026 02:07:45.462 7ff006403d60 [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)]) 04/23/2026 02:07:45.462 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.462 7ff006403d60 [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=36924144, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.462 7ff006403d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36924144, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.463 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83220.887451, idle connection 260230.000000, request 304999.963284 04/23/2026 02:07:45.463 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83220.600342, idle connection 260230.000000, request 304999.677658 04/23/2026 02:07:45.463 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 46 04/23/2026 02:07:45.463 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 04/23/2026 02:07:45.463 7ff0064032c0 [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)]) 04/23/2026 02:07:45.463 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.463 7ff0064032c0 [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=1528029278, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.463 7ff0064032c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1528029278, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.464 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82804.622070, idle connection 260327.000000, request 304999.965429 04/23/2026 02:07:45.464 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82804.337402, idle connection 260327.000000, request 304999.682188 04/23/2026 02:07:45.531 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82869.397461, idle connection 260279.000000, request 304397.933722 04/23/2026 02:07:45.531 7ff006034720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 04/23/2026 02:07:45.531 7ff006034720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.532 7ff006034720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 694 (602.5886535644531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=524261613, topics=[]) 04/23/2026 02:07:45.532 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 524261613 with 0 response partitions (1 implied) 04/23/2026 02:07:45.532 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82178.901855, idle connection 260763.000000, request 304397.861958 04/23/2026 02:07:45.532 7ff006403040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 04/23/2026 02:07:45.532 7ff006403040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.532 7ff006403040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 682 (602.4467945098877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307238224, topics=[]) 04/23/2026 02:07:45.532 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307238224 with 0 response partitions (1 implied) 04/23/2026 02:07:45.536 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 220 04/23/2026 02:07:45.536 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 04/23/2026 02:07:45.536 7ff0062d22c0 [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)]) 04/23/2026 02:07:45.536 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.536 7ff0062d22c0 [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=1502435447, session_epoch=718, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.536 7ff0062d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1502435447, session_epoch=718, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.536 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84033.829590, idle connection 261056.000000, request 304999.957085 04/23/2026 02:07:45.536 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 178 04/23/2026 02:07:45.537 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/23/2026 02:07:45.537 7ff0062d2c20 [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)]) 04/23/2026 02:07:45.537 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.537 7ff0062d2c20 [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=2094067982, session_epoch=707, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.537 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 711 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2094067982, session_epoch=707, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.537 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82900.049072, idle connection 260792.000000, request 304999.963522 04/23/2026 02:07:45.537 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84032.808350, idle connection 261055.000000, request 304998.938560 04/23/2026 02:07:45.537 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 51 04/23/2026 02:07:45.538 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 04/23/2026 02:07:45.538 7ff006403a40 [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)]) 04/23/2026 02:07:45.538 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.538 7ff006403a40 [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=1132901887, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.538 7ff006403a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132901887, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.538 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82788.467041, idle connection 260189.000000, request 304999.964952 04/23/2026 02:07:45.538 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82898.768799, idle connection 260790.000000, request 304998.686075 04/23/2026 02:07:45.539 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82787.832520, idle connection 260188.000000, request 304999.332666 04/23/2026 02:07:45.539 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 48 04/23/2026 02:07:45.540 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 04/23/2026 02:07:45.540 7ff006403ae0 [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)]) 04/23/2026 02:07:45.540 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.540 7ff006403ae0 [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=1773237565, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.540 7ff006403ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1773237565, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.540 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83386.592285, idle connection 260791.000000, request 304999.964476 04/23/2026 02:07:45.540 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82181.570068, idle connection 260756.000000, request 304398.090124 04/23/2026 02:07:45.540 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83386.191650, idle connection 260791.000000, request 304999.566555 04/23/2026 02:07:45.541 7ff006403540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 04/23/2026 02:07:45.541 7ff006403540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.541 7ff006403540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 682 (602.454662322998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458528261, topics=[]) 04/23/2026 02:07:45.541 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458528261 with 0 response partitions (1 implied) 04/23/2026 02:07:45.550 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 260 04/23/2026 02:07:45.550 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/23/2026 02:07:45.550 7ff0062d2400 [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)]) 04/23/2026 02:07:45.550 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.550 7ff0062d2400 [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=1208716337, session_epoch=733, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.550 7ff0062d2400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 737 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1208716337, session_epoch=733, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.550 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83204.036133, idle connection 260904.000000, request 304999.950886 04/23/2026 02:07:45.551 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83203.564209, idle connection 260903.000000, request 304999.484539 04/23/2026 02:07:45.554 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82774.345459, idle connection 261000.000000, request 304399.232626 04/23/2026 02:07:45.554 7ff0062d29a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 725 04/23/2026 02:07:45.554 7ff0062d29a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.554 7ff0062d29a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 725 (601.149320602417 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=641058939, topics=[]) 04/23/2026 02:07:45.554 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 641058939 with 0 response partitions (1 implied) 04/23/2026 02:07:45.592 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17 04/23/2026 02:07:45.592 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/23/2026 02:07:45.592 7ff0043822c0 [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)]) 04/23/2026 02:07:45.592 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.592 7ff0043822c0 [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=1899353276, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.593 7ff0043822c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1899353276, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.593 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82320.301514, idle connection 260924.000000, request 304999.949455 04/23/2026 02:07:45.593 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82319.810791, idle connection 260924.000000, request 304999.465466 04/23/2026 02:07:45.636 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 04/23/2026 02:07:45.636 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 04/23/2026 02:07:45.636 7ff0064034a0 [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)]) 04/23/2026 02:07:45.636 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.636 7ff0064034a0 [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=729888628, session_epoch=717, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.636 7ff0064034a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 721 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=729888628, session_epoch=717, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.636 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83140.298584, idle connection 260057.000000, request 304999.948978 04/23/2026 02:07:45.637 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83139.909424, idle connection 260057.000000, request 304999.566793 04/23/2026 02:07:45.659 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82335.148438, idle connection 260782.000000, request 304399.109364 04/23/2026 02:07:45.660 7ff006403180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1016 04/23/2026 02:07:45.660 7ff006403180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.660 7ff006403180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 1016 (601.4022827148438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=205155975, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3794, last_stable_offset=3794, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xd1\x00\x00\x01\x04\x00\x00\x00\x00\x02\xbfz\xb4#\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 04/23/2026 02:07:45.660 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 205155975 with 1 response partitions (0 implied) 04/23/2026 02:07:45.660 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3793 04/23/2026 02:07:45.660 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3793 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 04/23/2026 02:07:45.661 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3794 (leader epoch 0) 04/23/2026 02:07:45.690 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 46 04/23/2026 02:07:45.690 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 04/23/2026 02:07:45.690 7ff006403b80 [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)]) 04/23/2026 02:07:45.690 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.690 7ff006403b80 [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=2024950253, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.690 7ff006403b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2024950253, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.690 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82711.644531, idle connection 260159.000000, request 304999.949455 04/23/2026 02:07:45.691 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82711.234619, idle connection 260158.000000, request 304999.546289 04/23/2026 02:07:45.693 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82104.782227, idle connection 260720.000000, request 304398.508072 04/23/2026 02:07:45.693 7ff006034cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 04/23/2026 02:07:45.693 7ff006034cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.693 7ff006034cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 692 (601.8509864807129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=626634513, topics=[]) 04/23/2026 02:07:45.693 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 626634513 with 0 response partitions (1 implied) 04/23/2026 02:07:45.738 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82201.219238, idle connection 260917.000000, request 304398.806095 04/23/2026 02:07:45.738 7ff004382040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 04/23/2026 02:07:45.738 7ff004382040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.738 7ff004382040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 686 (601.668119430542 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=115312351, topics=[]) 04/23/2026 02:07:45.738 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 115312351 with 0 response partitions (1 implied) 04/23/2026 02:07:45.738 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 24 04/23/2026 02:07:45.739 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 04/23/2026 02:07:45.739 7ff00431c7c0 [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)]) 04/23/2026 02:07:45.739 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.739 7ff00431c7c0 [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=1564811653, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.739 7ff00431c7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1564811653, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.739 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82776.902100, idle connection 260176.000000, request 304999.959469 04/23/2026 02:07:45.739 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 23 04/23/2026 02:07:45.739 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/23/2026 02:07:45.739 7ff006034e00 [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)]) 04/23/2026 02:07:45.739 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.739 7ff006034e00 [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=1041053072, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.739 7ff006034e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1041053072, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.740 7ff006034e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82832.841064, idle connection 260053.000000, request 304999.965429 04/23/2026 02:07:45.740 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82775.947510, idle connection 260175.000000, request 304999.007702 04/23/2026 02:07:45.740 7ff006034e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82832.230957, idle connection 260052.000000, request 304999.358416 04/23/2026 02:07:45.761 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3794 04/23/2026 02:07:45.761 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 04/23/2026 02:07:45.761 7ff006403180 [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)]) 04/23/2026 02:07:45.761 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.761 7ff006403180 [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=205155975, session_epoch=1013, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3794, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:45.762 7ff006403180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 1017 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=205155975, session_epoch=1013, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3794, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:45.762 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82232.747314, idle connection 260680.000000, request 304999.949694 04/23/2026 02:07:45.762 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82232.373779, idle connection 260680.000000, request 304999.581337 04/23/2026 02:07:45.775 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 12 04/23/2026 02:07:45.775 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 04/23/2026 02:07:45.775 7ff00431c4a0 [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)]) 04/23/2026 02:07:45.775 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.775 7ff00431c4a0 [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=859434928, session_epoch=683, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.775 7ff00431c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=859434928, session_epoch=683, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.775 7ff00431c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81593.078613, idle connection 260234.000000, request 304999.955893 04/23/2026 02:07:45.776 7ff00431c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81592.718994, idle connection 260233.000000, request 304999.599695 04/23/2026 02:07:45.785 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 322 04/23/2026 02:07:45.785 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 04/23/2026 02:07:45.785 7ff0062d27c0 [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)]) 04/23/2026 02:07:45.785 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.785 7ff0062d27c0 [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=48706391, session_epoch=719, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.785 7ff0062d27c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=48706391, session_epoch=719, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.785 7ff0062d27c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82228.015625, idle connection 260580.000000, request 304999.956846 04/23/2026 02:07:45.785 7ff0062d27c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82227.681152, idle connection 260579.000000, request 304999.625683 04/23/2026 02:07:45.793 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82857.034180, idle connection 260160.000000, request 304398.897409 04/23/2026 02:07:45.794 7ff0062d2180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742 04/23/2026 02:07:45.794 7ff0062d2180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.794 7ff0062d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 742 (601.6802787780762 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1837721512, topics=[]) 04/23/2026 02:07:45.794 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1837721512 with 0 response partitions (1 implied) 04/23/2026 02:07:45.804 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 113 04/23/2026 02:07:45.804 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 04/23/2026 02:07:45.804 7ff006403ea0 [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)]) 04/23/2026 02:07:45.804 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.805 7ff006403ea0 [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=681443435, session_epoch=705, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.805 7ff006403ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 709 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=681443435, session_epoch=705, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.805 7ff006403ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82731.461670, idle connection 260536.000000, request 304999.932051 04/23/2026 02:07:45.805 7ff006403ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82731.047852, idle connection 260536.000000, request 304999.526739 04/23/2026 02:07:45.837 7ff0062d2ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83324.950439, idle connection 260564.000000, request 304398.940563 04/23/2026 02:07:45.837 7ff0062d2ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 04/23/2026 02:07:45.837 7ff0062d2ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:45.837 7ff0062d2ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 710 (601.5708446502686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1515926691, topics=[]) 04/23/2026 02:07:45.838 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1515926691 with 0 response partitions (1 implied) 04/23/2026 02:07:45.954 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 14 04/23/2026 02:07:45.954 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 04/23/2026 02:07:45.954 7ff00431ccc0 [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)]) 04/23/2026 02:07:45.954 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.954 7ff00431ccc0 [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=1718921010, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.954 7ff00431ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1718921010, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.954 7ff00431ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82156.636230, idle connection 260342.000000, request 304999.944925 04/23/2026 02:07:45.955 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31 04/23/2026 02:07:45.955 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 04/23/2026 02:07:45.955 7ff006403f40 [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)]) 04/23/2026 02:07:45.955 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:45.955 7ff006403f40 [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=370863008, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.955 7ff006403f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370863008, session_epoch=685, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:45.955 7ff006403f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82776.151123, idle connection 260196.000000, request 304999.960899 04/23/2026 02:07:45.956 7ff00431ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82155.347412, idle connection 260341.000000, request 304998.664856 04/23/2026 02:07:45.956 7ff006403f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82775.275635, idle connection 260195.000000, request 304999.088526 04/23/2026 02:07:46.051 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 214 04/23/2026 02:07:46.051 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/23/2026 02:07:46.051 7ff0062d25e0 [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)]) 04/23/2026 02:07:46.051 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.052 7ff0062d25e0 [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=294578344, session_epoch=717, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.052 7ff0062d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 721 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=294578344, session_epoch=717, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.052 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82458.808105, idle connection 260796.000000, request 304999.916315 04/23/2026 02:07:46.052 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82313.169678, idle connection 260542.000000, request 304398.421526 04/23/2026 02:07:46.053 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82458.024170, idle connection 260795.000000, request 304999.142885 04/23/2026 02:07:46.053 7ff0062d2ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 735 04/23/2026 02:07:46.053 7ff0062d2ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.053 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 735 (602.5362014770508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=982030124, topics=[]) 04/23/2026 02:07:46.053 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 982030124 with 0 response partitions (1 implied) 04/23/2026 02:07:46.056 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 126 04/23/2026 02:07:46.056 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/23/2026 02:07:46.056 7ff0062d2a40 [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)]) 04/23/2026 02:07:46.057 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.057 7ff0062d2a40 [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=1131051951, session_epoch=707, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.057 7ff0062d2a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 711 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1131051951, session_epoch=707, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.057 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82777.636719, idle connection 260512.000000, request 304999.942303 04/23/2026 02:07:46.058 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82777.048096, idle connection 260511.000000, request 304999.356747 04/23/2026 02:07:46.062 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82765.018799, idle connection 260617.000000, request 304399.257183 04/23/2026 02:07:46.062 7ff0062d2540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 04/23/2026 02:07:46.062 7ff0062d2540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.062 7ff0062d2540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 693 (601.2747287750244 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=890357573, topics=[]) 04/23/2026 02:07:46.062 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 890357573 with 0 response partitions (1 implied) 04/23/2026 02:07:46.063 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82620.297852, idle connection 259629.000000, request 304399.369240 04/23/2026 02:07:46.063 7ff006403d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 04/23/2026 02:07:46.064 7ff006403d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.064 7ff006403d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 689 (601.0844707489014 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=36924144, topics=[]) 04/23/2026 02:07:46.064 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 36924144 with 0 response partitions (1 implied) 04/23/2026 02:07:46.064 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82204.049316, idle connection 259727.000000, request 304399.388075 04/23/2026 02:07:46.064 7ff0064032c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 04/23/2026 02:07:46.064 7ff0064032c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.065 7ff0064032c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 691 (601.0181903839111 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1528029278, topics=[]) 04/23/2026 02:07:46.065 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1528029278 with 0 response partitions (1 implied) 04/23/2026 02:07:46.132 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 37 04/23/2026 02:07:46.132 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 04/23/2026 02:07:46.132 7ff006034720 [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)]) 04/23/2026 02:07:46.132 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.133 7ff006034720 [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=524261613, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.133 7ff006034720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=524261613, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.133 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82267.588867, idle connection 259677.000000, request 304999.943495 04/23/2026 02:07:46.133 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 04/23/2026 02:07:46.133 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 04/23/2026 02:07:46.133 7ff006403040 [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)]) 04/23/2026 02:07:46.133 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.133 7ff006403040 [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=1307238224, session_epoch=679, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.133 7ff006403040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307238224, session_epoch=679, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.134 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81577.291260, idle connection 260161.000000, request 304999.963999 04/23/2026 02:07:46.134 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82266.504150, idle connection 259676.000000, request 304998.863935 04/23/2026 02:07:46.134 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81576.501221, idle connection 260160.000000, request 304999.176979 04/23/2026 02:07:46.139 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83431.559570, idle connection 260454.000000, request 304397.689342 04/23/2026 02:07:46.139 7ff0062d22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 722 04/23/2026 02:07:46.139 7ff0062d22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.139 7ff0062d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 722 (602.6768684387207 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1502435447, topics=[]) 04/23/2026 02:07:46.139 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1502435447 with 0 response partitions (1 implied) 04/23/2026 02:07:46.139 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82297.761719, idle connection 260189.000000, request 304397.677898 04/23/2026 02:07:46.139 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82187.042480, idle connection 259587.000000, request 304398.542643 04/23/2026 02:07:46.140 7ff0062d2c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 711 04/23/2026 02:07:46.140 7ff0062d2c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.140 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 711 (602.7235984802246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2094067982, topics=[]) 04/23/2026 02:07:46.140 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2094067982 with 0 response partitions (1 implied) 04/23/2026 02:07:46.140 7ff006403a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 04/23/2026 02:07:46.140 7ff006403a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.140 7ff006403a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 693 (602.1854877471924 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132901887, topics=[]) 04/23/2026 02:07:46.140 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1132901887 with 0 response partitions (1 implied) 04/23/2026 02:07:46.141 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 04/23/2026 02:07:46.141 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 04/23/2026 02:07:46.141 7ff006403540 [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)]) 04/23/2026 02:07:46.141 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.141 7ff006403540 [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=458528261, session_epoch=679, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.141 7ff006403540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458528261, session_epoch=679, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.141 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81580.240479, idle connection 260155.000000, request 304999.964476 04/23/2026 02:07:46.142 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82784.907715, idle connection 260189.000000, request 304398.280382 04/23/2026 02:07:46.142 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81579.795898, idle connection 260154.000000, request 304999.522209 04/23/2026 02:07:46.142 7ff006403ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 04/23/2026 02:07:46.142 7ff006403ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.142 7ff006403ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 693 (602.2961139678955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1773237565, topics=[]) 04/23/2026 02:07:46.142 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1773237565 with 0 response partitions (1 implied) 04/23/2026 02:07:46.151 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82603.235352, idle connection 260303.000000, request 304399.154425 04/23/2026 02:07:46.152 7ff0062d2400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 737 04/23/2026 02:07:46.152 7ff0062d2400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.152 7ff0062d2400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 737 (601.191520690918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1208716337, topics=[]) 04/23/2026 02:07:46.152 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1208716337 with 0 response partitions (1 implied) 04/23/2026 02:07:46.154 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 245 04/23/2026 02:07:46.155 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 04/23/2026 02:07:46.155 7ff0062d29a0 [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)]) 04/23/2026 02:07:46.155 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.155 7ff0062d29a0 [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=641058939, session_epoch=722, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.155 7ff0062d29a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 726 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641058939, session_epoch=722, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.155 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82173.024414, idle connection 260398.000000, request 304999.958515 04/23/2026 02:07:46.155 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82172.694092, idle connection 260398.000000, request 304999.631166 04/23/2026 02:07:46.194 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81719.346191, idle connection 260324.000000, request 304398.993492 04/23/2026 02:07:46.194 7ff0043822c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 04/23/2026 02:07:46.194 7ff0043822c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.194 7ff0043822c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 689 (601.5024185180664 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1899353276, topics=[]) 04/23/2026 02:07:46.194 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1899353276 with 0 response partitions (1 implied) 04/23/2026 02:07:46.237 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82539.492920, idle connection 259456.000000, request 304399.142504 04/23/2026 02:07:46.238 7ff0064034a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721 04/23/2026 02:07:46.238 7ff0064034a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.238 7ff0064034a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 721 (601.3450622558594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=729888628, topics=[]) 04/23/2026 02:07:46.238 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 729888628 with 0 response partitions (1 implied) 04/23/2026 02:07:46.291 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82110.734375, idle connection 259558.000000, request 304399.033308 04/23/2026 02:07:46.292 7ff006403b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 04/23/2026 02:07:46.292 7ff006403b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.292 7ff006403b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (601.4914512634277 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2024950253, topics=[]) 04/23/2026 02:07:46.292 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2024950253 with 0 response partitions (1 implied) 04/23/2026 02:07:46.295 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 04/23/2026 02:07:46.295 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 04/23/2026 02:07:46.295 7ff006034cc0 [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)]) 04/23/2026 02:07:46.295 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.295 7ff006034cc0 [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=626634513, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.295 7ff006034cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=626634513, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.295 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81502.379395, idle connection 260118.000000, request 304999.953508 04/23/2026 02:07:46.296 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81502.005127, idle connection 260117.000000, request 304999.582529 04/23/2026 02:07:46.339 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 14 04/23/2026 02:07:46.339 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 04/23/2026 02:07:46.339 7ff004382040 [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)]) 04/23/2026 02:07:46.339 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.339 7ff004382040 [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=115312351, session_epoch=683, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.339 7ff004382040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=115312351, session_epoch=683, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.340 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81599.277100, idle connection 260315.000000, request 304999.951601 04/23/2026 02:07:46.340 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81598.877930, idle connection 260314.000000, request 304999.558210 04/23/2026 02:07:46.341 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82174.836914, idle connection 259574.000000, request 304397.895813 04/23/2026 02:07:46.341 7ff00431c7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 04/23/2026 02:07:46.341 7ff00431c7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.341 7ff00431c7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (602.4386882781982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1564811653, topics=[]) 04/23/2026 02:07:46.342 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1564811653 with 0 response partitions (1 implied) 04/23/2026 02:07:46.342 7ff006034e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82230.753906, idle connection 259451.000000, request 304397.879839 04/23/2026 02:07:46.342 7ff006034e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 04/23/2026 02:07:46.342 7ff006034e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.342 7ff006034e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 691 (602.4138927459717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1041053072, topics=[]) 04/23/2026 02:07:46.342 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1041053072 with 0 response partitions (1 implied) 04/23/2026 02:07:46.363 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81631.305664, idle connection 260079.000000, request 304398.506403 04/23/2026 02:07:46.364 7ff006403180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1017 04/23/2026 02:07:46.364 7ff006403180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.364 7ff006403180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 1017 (601.9580364227295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=205155975, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3795, last_stable_offset=3795, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x0e\xd2\x00\x00\x01\x04\x00\x00\x00\x00\x02H\xba\xa2'\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...")])]) 04/23/2026 02:07:46.364 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 205155975 with 1 response partitions (0 implied) 04/23/2026 02:07:46.364 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3794 04/23/2026 02:07:46.364 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3794 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 04/23/2026 02:07:46.364 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3795 (leader epoch 0) 04/23/2026 02:07:46.376 7ff00431c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80991.808838, idle connection 259632.000000, request 304398.681879 04/23/2026 02:07:46.377 7ff00431c4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 04/23/2026 02:07:46.377 7ff00431c4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.377 7ff00431c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 687 (601.7444133758545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=859434928, topics=[]) 04/23/2026 02:07:46.377 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 859434928 with 0 response partitions (1 implied) 04/23/2026 02:07:46.387 7ff0062d27c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81626.550537, idle connection 259978.000000, request 304398.489237 04/23/2026 02:07:46.387 7ff0062d27c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 723 04/23/2026 02:07:46.387 7ff0062d27c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.387 7ff0062d27c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 723 (601.9091606140137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=48706391, topics=[]) 04/23/2026 02:07:46.387 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 48706391 with 0 response partitions (1 implied) 04/23/2026 02:07:46.395 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 308 04/23/2026 02:07:46.395 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 04/23/2026 02:07:46.395 7ff0062d2180 [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)]) 04/23/2026 02:07:46.395 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.395 7ff0062d2180 [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=1837721512, session_epoch=739, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.395 7ff0062d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 743 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1837721512, session_epoch=739, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.395 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82255.157959, idle connection 259558.000000, request 304999.952555 04/23/2026 02:07:46.396 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82254.791504, idle connection 259558.000000, request 304999.590635 04/23/2026 02:07:46.406 7ff006403ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82130.348389, idle connection 259935.000000, request 304398.824453 04/23/2026 02:07:46.406 7ff006403ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 709 04/23/2026 02:07:46.406 7ff006403ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.406 7ff006403ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 709 (601.6073226928711 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=681443435, topics=[]) 04/23/2026 02:07:46.407 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 681443435 with 0 response partitions (1 implied) 04/23/2026 02:07:46.442 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 149 04/23/2026 02:07:46.442 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 04/23/2026 02:07:46.442 7ff0062d2ea0 [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)]) 04/23/2026 02:07:46.443 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.443 7ff0062d2ea0 [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=1515926691, session_epoch=707, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.443 7ff0062d2ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 711 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1515926691, session_epoch=707, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.443 7ff0062d2ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82718.845947, idle connection 259958.000000, request 304999.946833 04/23/2026 02:07:46.443 7ff0062d2ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82718.310303, idle connection 259957.000000, request 304999.418259 04/23/2026 02:07:46.465 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3795 04/23/2026 02:07:46.465 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 04/23/2026 02:07:46.465 7ff006403180 [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)]) 04/23/2026 02:07:46.465 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.465 7ff006403180 [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=205155975, session_epoch=1014, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3795, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:46.466 7ff006403180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 1018 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=205155975, session_epoch=1014, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3795, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:46.466 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.898682, idle connection 259976.000000, request 304999.946356 04/23/2026 02:07:46.466 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.449463, idle connection 259976.000000, request 304999.504566 04/23/2026 02:07:46.557 7ff00431ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81553.544678, idle connection 259739.000000, request 304396.851778 04/23/2026 02:07:46.558 7ff00431ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 04/23/2026 02:07:46.558 7ff00431ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.558 7ff00431ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 689 (603.6834716796875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1718921010, topics=[]) 04/23/2026 02:07:46.558 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1718921010 with 0 response partitions (1 implied) 04/23/2026 02:07:46.558 7ff006403f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82172.859375, idle connection 259593.000000, request 304396.668911 04/23/2026 02:07:46.559 7ff006403f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 04/23/2026 02:07:46.559 7ff006403f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.559 7ff006403f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 689 (603.6653518676758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=370863008, topics=[]) 04/23/2026 02:07:46.559 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 370863008 with 0 response partitions (1 implied) 04/23/2026 02:07:46.654 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 261 04/23/2026 02:07:46.654 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 04/23/2026 02:07:46.654 7ff0062d2ae0 [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)]) 04/23/2026 02:07:46.654 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.654 7ff0062d2ae0 [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=982030124, session_epoch=732, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.654 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 736 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=982030124, session_epoch=732, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.654 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81710.954102, idle connection 259940.000000, request 304999.930859 04/23/2026 02:07:46.655 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81855.987061, idle connection 260193.000000, request 304397.107363 04/23/2026 02:07:46.655 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81710.380371, idle connection 259939.000000, request 304999.365330 04/23/2026 02:07:46.655 7ff0062d25e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721 04/23/2026 02:07:46.655 7ff0062d25e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.655 7ff0062d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 721 (603.5614013671875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=294578344, topics=[]) 04/23/2026 02:07:46.656 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 294578344 with 0 response partitions (1 implied) 04/23/2026 02:07:46.658 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82176.636963, idle connection 259911.000000, request 304398.948908 04/23/2026 02:07:46.658 7ff0062d2a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 711 04/23/2026 02:07:46.658 7ff0062d2a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.658 7ff0062d2a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 711 (601.3672351837158 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1131051951, topics=[]) 04/23/2026 02:07:46.658 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1131051951 with 0 response partitions (1 implied) 04/23/2026 02:07:46.663 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44 04/23/2026 02:07:46.663 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/23/2026 02:07:46.663 7ff0062d2540 [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)]) 04/23/2026 02:07:46.663 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.663 7ff0062d2540 [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=890357573, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.663 7ff0062d2540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=890357573, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.663 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82163.506104, idle connection 260015.000000, request 304999.961376 04/23/2026 02:07:46.663 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82163.183350, idle connection 260015.000000, request 304999.640942 04/23/2026 02:07:46.664 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 34 04/23/2026 02:07:46.664 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 04/23/2026 02:07:46.664 7ff006403d60 [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)]) 04/23/2026 02:07:46.664 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.664 7ff006403d60 [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=36924144, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.664 7ff006403d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36924144, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.665 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82018.915771, idle connection 259028.000000, request 304999.963045 04/23/2026 02:07:46.665 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82018.617676, idle connection 259028.000000, request 304999.667406 04/23/2026 02:07:46.665 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 46 04/23/2026 02:07:46.665 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 04/23/2026 02:07:46.665 7ff0064032c0 [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)]) 04/23/2026 02:07:46.665 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.665 7ff0064032c0 [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=1528029278, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.665 7ff0064032c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1528029278, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.665 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81602.712402, idle connection 259125.000000, request 304999.967098 04/23/2026 02:07:46.666 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81602.377686, idle connection 259125.000000, request 304999.634504 04/23/2026 02:07:46.735 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81665.601807, idle connection 259075.000000, request 304397.958040 04/23/2026 02:07:46.735 7ff006034720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 04/23/2026 02:07:46.735 7ff006034720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.735 7ff006034720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 695 (602.5502681732178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=524261613, topics=[]) 04/23/2026 02:07:46.736 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 524261613 with 0 response partitions (1 implied) 04/23/2026 02:07:46.736 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80975.141846, idle connection 259559.000000, request 304397.815704 04/23/2026 02:07:46.736 7ff006403040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 04/23/2026 02:07:46.736 7ff006403040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.736 7ff006403040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 683 (602.4825572967529 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307238224, topics=[]) 04/23/2026 02:07:46.736 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307238224 with 0 response partitions (1 implied) 04/23/2026 02:07:46.739 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 220 04/23/2026 02:07:46.739 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 04/23/2026 02:07:46.739 7ff0062d22c0 [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)]) 04/23/2026 02:07:46.739 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.740 7ff0062d22c0 [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=1502435447, session_epoch=719, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.740 7ff0062d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1502435447, session_epoch=719, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.740 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82830.326416, idle connection 259852.000000, request 304999.958992 04/23/2026 02:07:46.740 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 178 04/23/2026 02:07:46.740 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/23/2026 02:07:46.740 7ff0062d2c20 [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)]) 04/23/2026 02:07:46.740 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.740 7ff0062d2c20 [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=2094067982, session_epoch=708, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.740 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 712 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2094067982, session_epoch=708, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.740 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81696.563721, idle connection 259588.000000, request 304999.965191 04/23/2026 02:07:46.741 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82829.346680, idle connection 259851.000000, request 304998.981714 04/23/2026 02:07:46.741 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 51 04/23/2026 02:07:46.741 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 04/23/2026 02:07:46.741 7ff006403a40 [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)]) 04/23/2026 02:07:46.741 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.741 7ff006403a40 [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=1132901887, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.741 7ff006403a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132901887, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.741 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81585.004883, idle connection 258985.000000, request 304999.965906 04/23/2026 02:07:46.742 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81695.331055, idle connection 259587.000000, request 304998.735666 04/23/2026 02:07:46.742 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81584.407959, idle connection 258985.000000, request 304999.371529 04/23/2026 02:07:46.743 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 48 04/23/2026 02:07:46.743 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 04/23/2026 02:07:46.743 7ff006403ae0 [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)]) 04/23/2026 02:07:46.743 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.743 7ff006403ae0 [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=1773237565, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.743 7ff006403ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1773237565, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.743 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82183.544922, idle connection 259588.000000, request 304999.965906 04/23/2026 02:07:46.743 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80978.524414, idle connection 259553.000000, request 304398.250580 04/23/2026 02:07:46.743 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82183.136475, idle connection 259588.000000, request 304999.560118 04/23/2026 02:07:46.744 7ff006403540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 04/23/2026 02:07:46.744 7ff006403540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.744 7ff006403540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 683 (602.3037433624268 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458528261, topics=[]) 04/23/2026 02:07:46.744 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458528261 with 0 response partitions (1 implied) 04/23/2026 02:07:46.752 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 260 04/23/2026 02:07:46.752 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/23/2026 02:07:46.752 7ff0062d2400 [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)]) 04/23/2026 02:07:46.752 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.752 7ff0062d2400 [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=1208716337, session_epoch=734, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.752 7ff0062d2400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 738 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1208716337, session_epoch=734, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.753 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82001.958496, idle connection 259702.000000, request 304999.959946 04/23/2026 02:07:46.753 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82001.629639, idle connection 259701.000000, request 304999.633551 04/23/2026 02:07:46.756 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81572.399414, idle connection 259798.000000, request 304399.335146 04/23/2026 02:07:46.756 7ff0062d29a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 726 04/23/2026 02:07:46.756 7ff0062d29a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.756 7ff0062d29a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 726 (601.03440284729 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=641058939, topics=[]) 04/23/2026 02:07:46.756 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 641058939 with 0 response partitions (1 implied) 04/23/2026 02:07:46.795 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17 04/23/2026 02:07:46.795 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/23/2026 02:07:46.795 7ff0043822c0 [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)]) 04/23/2026 02:07:46.795 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.795 7ff0043822c0 [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=1899353276, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.795 7ff0043822c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1899353276, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.795 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81117.684570, idle connection 259722.000000, request 304999.950886 04/23/2026 02:07:46.796 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81117.289307, idle connection 259721.000000, request 304999.562263 04/23/2026 02:07:46.838 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 04/23/2026 02:07:46.838 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 04/23/2026 02:07:46.839 7ff0064034a0 [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)]) 04/23/2026 02:07:46.839 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.839 7ff0064034a0 [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=729888628, session_epoch=718, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.839 7ff0064034a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=729888628, session_epoch=718, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.839 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81937.782227, idle connection 258855.000000, request 304999.948263 04/23/2026 02:07:46.839 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81937.381836, idle connection 258854.000000, request 304999.553919 04/23/2026 02:07:46.892 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 46 04/23/2026 02:07:46.893 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 04/23/2026 02:07:46.893 7ff006403b80 [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)]) 04/23/2026 02:07:46.893 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.893 7ff006403b80 [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=2024950253, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.893 7ff006403b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2024950253, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.893 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81509.011230, idle connection 258956.000000, request 304999.946356 04/23/2026 02:07:46.893 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81508.609131, idle connection 258956.000000, request 304999.552965 04/23/2026 02:07:46.896 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80901.489746, idle connection 259517.000000, request 304399.066687 04/23/2026 02:07:46.896 7ff006034cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 04/23/2026 02:07:46.896 7ff006034cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.896 7ff006034cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 693 (601.3026237487793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=626634513, topics=[]) 04/23/2026 02:07:46.897 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 626634513 with 0 response partitions (1 implied) 04/23/2026 02:07:46.941 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80997.784912, idle connection 259713.000000, request 304398.458958 04/23/2026 02:07:46.941 7ff004382040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 04/23/2026 02:07:46.941 7ff004382040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.942 7ff004382040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 687 (601.9763946533203 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=115312351, topics=[]) 04/23/2026 02:07:46.942 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 115312351 with 0 response partitions (1 implied) 04/23/2026 02:07:46.943 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 24 04/23/2026 02:07:46.943 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 04/23/2026 02:07:46.943 7ff00431c7c0 [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)]) 04/23/2026 02:07:46.943 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.943 7ff00431c7c0 [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=1564811653, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.944 7ff00431c7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1564811653, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.944 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81572.154541, idle connection 258971.000000, request 304999.958992 04/23/2026 02:07:46.944 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 23 04/23/2026 02:07:46.944 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/23/2026 02:07:46.944 7ff006034e00 [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)]) 04/23/2026 02:07:46.944 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.944 7ff006034e00 [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=1041053072, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.944 7ff006034e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1041053072, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.944 7ff006034e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81628.070801, idle connection 258848.000000, request 304999.965906 04/23/2026 02:07:46.945 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81571.178711, idle connection 258970.000000, request 304998.986721 04/23/2026 02:07:46.945 7ff006034e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81627.468262, idle connection 258848.000000, request 304999.365807 04/23/2026 02:07:46.977 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 12 04/23/2026 02:07:46.978 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 04/23/2026 02:07:46.978 7ff00431c4a0 [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)]) 04/23/2026 02:07:46.978 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.978 7ff00431c4a0 [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=859434928, session_epoch=684, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.978 7ff00431c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=859434928, session_epoch=684, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.978 7ff00431c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80390.078857, idle connection 259031.000000, request 304999.953747 04/23/2026 02:07:46.979 7ff00431c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80389.710205, idle connection 259030.000000, request 304999.588490 04/23/2026 02:07:46.987 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 322 04/23/2026 02:07:46.988 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 04/23/2026 02:07:46.988 7ff0062d27c0 [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)]) 04/23/2026 02:07:46.988 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:46.988 7ff0062d27c0 [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=48706391, session_epoch=720, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.988 7ff0062d27c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=48706391, session_epoch=720, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:46.988 7ff0062d27c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81025.125000, idle connection 259377.000000, request 304999.953270 04/23/2026 02:07:46.988 7ff0062d27c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81024.769531, idle connection 259376.000000, request 304999.601126 04/23/2026 02:07:46.996 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81654.374512, idle connection 258957.000000, request 304399.170876 04/23/2026 02:07:46.996 7ff0062d2180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743 04/23/2026 02:07:46.996 7ff0062d2180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:46.997 7ff0062d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 743 (601.2585163116455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1837721512, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=310, last_stable_offset=310, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x014\x00\x00\x02\x17\x00\x00\x00\x00\x02\xed\xa6\xc3n\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\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:46.997 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1837721512 with 1 response partitions (0 implied) 04/23/2026 02:07:46.997 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 308 04/23/2026 02:07:46.997 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 308 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 04/23/2026 02:07:46.997 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 310 (leader epoch 0) 04/23/2026 02:07:47.007 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 113 04/23/2026 02:07:47.007 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 04/23/2026 02:07:47.007 7ff006403ea0 [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)]) 04/23/2026 02:07:47.007 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.007 7ff006403ea0 [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=681443435, session_epoch=706, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.007 7ff006403ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 710 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=681443435, session_epoch=706, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.008 7ff006403ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.760010, idle connection 259334.000000, request 304999.949694 04/23/2026 02:07:47.008 7ff006403ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.355957, idle connection 259333.000000, request 304999.551773 04/23/2026 02:07:47.044 7ff0062d2ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82117.846924, idle connection 259357.000000, request 304398.950815 04/23/2026 02:07:47.044 7ff0062d2ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 711 04/23/2026 02:07:47.044 7ff0062d2ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.044 7ff0062d2ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 711 (601.5157699584961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1515926691, topics=[]) 04/23/2026 02:07:47.045 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1515926691 with 0 response partitions (1 implied) 04/23/2026 02:07:47.067 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80928.038574, idle connection 259375.000000, request 304399.087429 04/23/2026 02:07:47.067 7ff006403180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1018 04/23/2026 02:07:47.067 7ff006403180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.067 7ff006403180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 1018 (601.3400554656982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=205155975, topics=[]) 04/23/2026 02:07:47.067 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 205155975 with 0 response partitions (1 implied) 04/23/2026 02:07:47.098 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 310 04/23/2026 02:07:47.098 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 04/23/2026 02:07:47.098 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 04/23/2026 02:07:47.098 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.098 7ff0062d2180 [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=1837721512, session_epoch=740, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=310, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.099 7ff0062d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 744 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1837721512, session_epoch=740, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=310, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.099 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81551.784912, idle connection 258855.000000, request 304999.944925 04/23/2026 02:07:47.099 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81551.366455, idle connection 258854.000000, request 304999.532938 04/23/2026 02:07:47.159 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 14 04/23/2026 02:07:47.159 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 04/23/2026 02:07:47.159 7ff00431ccc0 [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)]) 04/23/2026 02:07:47.159 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.159 7ff00431ccc0 [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=1718921010, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.159 7ff00431ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1718921010, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.159 7ff00431ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80951.542236, idle connection 259137.000000, request 304999.948263 04/23/2026 02:07:47.160 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31 04/23/2026 02:07:47.160 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 04/23/2026 02:07:47.160 7ff006403f40 [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)]) 04/23/2026 02:07:47.160 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.160 7ff006403f40 [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=370863008, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.160 7ff006403f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=370863008, session_epoch=686, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.160 7ff006403f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81571.122314, idle connection 258991.000000, request 304999.964476 04/23/2026 02:07:47.161 7ff00431ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80950.364746, idle connection 259136.000000, request 304998.778820 04/23/2026 02:07:47.161 7ff006403f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81570.292969, idle connection 258990.000000, request 304999.138355 04/23/2026 02:07:47.257 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 214 04/23/2026 02:07:47.257 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/23/2026 02:07:47.257 7ff0062d25e0 [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)]) 04/23/2026 02:07:47.257 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.257 7ff0062d25e0 [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=294578344, session_epoch=718, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.257 7ff0062d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=294578344, session_epoch=718, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.257 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81253.440430, idle connection 259590.000000, request 304999.946833 04/23/2026 02:07:47.258 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81107.896729, idle connection 259337.000000, request 304396.879435 04/23/2026 02:07:47.258 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81252.870117, idle connection 259590.000000, request 304999.385118 04/23/2026 02:07:47.258 7ff0062d2ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 736 04/23/2026 02:07:47.258 7ff0062d2ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.258 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 736 (603.8048267364502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=982030124, topics=[]) 04/23/2026 02:07:47.258 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 982030124 with 0 response partitions (1 implied) 04/23/2026 02:07:47.259 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 126 04/23/2026 02:07:47.259 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/23/2026 02:07:47.259 7ff0062d2a40 [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)]) 04/23/2026 02:07:47.259 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.259 7ff0062d2a40 [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=1131051951, session_epoch=708, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.259 7ff0062d2a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 712 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1131051951, session_epoch=708, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.259 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81575.479980, idle connection 259309.000000, request 304999.963284 04/23/2026 02:07:47.259 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81575.177734, idle connection 259309.000000, request 304999.663353 04/23/2026 02:07:47.264 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81562.909668, idle connection 259415.000000, request 304399.365664 04/23/2026 02:07:47.264 7ff0062d2540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 04/23/2026 02:07:47.264 7ff0062d2540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.264 7ff0062d2540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 694 (600.9862422943115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=890357573, topics=[]) 04/23/2026 02:07:47.264 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 890357573 with 0 response partitions (1 implied) 04/23/2026 02:07:47.266 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81417.737549, idle connection 258427.000000, request 304398.786306 04/23/2026 02:07:47.266 7ff006403d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 04/23/2026 02:07:47.266 7ff006403d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.266 7ff006403d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (601.5284061431885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=36924144, topics=[]) 04/23/2026 02:07:47.266 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 36924144 with 0 response partitions (1 implied) 04/23/2026 02:07:47.266 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81001.843750, idle connection 258524.000000, request 304399.099827 04/23/2026 02:07:47.266 7ff0064032c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 04/23/2026 02:07:47.267 7ff0064032c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.267 7ff0064032c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 692 (601.1974811553955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1528029278, topics=[]) 04/23/2026 02:07:47.267 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1528029278 with 0 response partitions (1 implied) 04/23/2026 02:07:47.336 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 37 04/23/2026 02:07:47.336 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 04/23/2026 02:07:47.336 7ff006034720 [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)]) 04/23/2026 02:07:47.336 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.336 7ff006034720 [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=524261613, session_epoch=692, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.336 7ff006034720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 696 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=524261613, session_epoch=692, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.337 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81063.868164, idle connection 258474.000000, request 304999.948263 04/23/2026 02:07:47.337 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 04/23/2026 02:07:47.337 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 04/23/2026 02:07:47.337 7ff006403040 [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)]) 04/23/2026 02:07:47.337 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.337 7ff006403040 [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=1307238224, session_epoch=680, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.337 7ff006403040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307238224, session_epoch=680, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.337 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80373.585205, idle connection 258957.000000, request 304999.961853 04/23/2026 02:07:47.338 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81062.812988, idle connection 258473.000000, request 304998.900414 04/23/2026 02:07:47.338 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80372.925537, idle connection 258957.000000, request 304999.306440 04/23/2026 02:07:47.342 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82228.114990, idle connection 259250.000000, request 304397.748947 04/23/2026 02:07:47.342 7ff0062d22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 723 04/23/2026 02:07:47.342 7ff0062d22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.342 7ff0062d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 723 (602.6186943054199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1502435447, topics=[]) 04/23/2026 02:07:47.343 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1502435447 with 0 response partitions (1 implied) 04/23/2026 02:07:47.343 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81094.297852, idle connection 258986.000000, request 304397.701025 04/23/2026 02:07:47.343 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80983.576660, idle connection 258384.000000, request 304398.539543 04/23/2026 02:07:47.343 7ff0062d2c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 712 04/23/2026 02:07:47.343 7ff0062d2c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.343 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 712 (602.7178764343262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2094067982, topics=[]) 04/23/2026 02:07:47.343 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2094067982 with 0 response partitions (1 implied) 04/23/2026 02:07:47.343 7ff006403a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 04/23/2026 02:07:47.343 7ff006403a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.344 7ff006403a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 694 (602.1780967712402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132901887, topics=[]) 04/23/2026 02:07:47.344 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1132901887 with 0 response partitions (1 implied) 04/23/2026 02:07:47.344 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 04/23/2026 02:07:47.344 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 04/23/2026 02:07:47.344 7ff006403540 [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)]) 04/23/2026 02:07:47.344 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.344 7ff006403540 [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=458528261, session_epoch=680, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.344 7ff006403540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458528261, session_epoch=680, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.345 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80377.170410, idle connection 258951.000000, request 304999.961615 04/23/2026 02:07:47.345 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81581.836914, idle connection 258986.000000, request 304398.259163 04/23/2026 02:07:47.345 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80376.714600, idle connection 258951.000000, request 304999.508381 04/23/2026 02:07:47.345 7ff006403ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 04/23/2026 02:07:47.345 7ff006403ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.345 7ff006403ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 694 (602.3280620574951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1773237565, topics=[]) 04/23/2026 02:07:47.345 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1773237565 with 0 response partitions (1 implied) 04/23/2026 02:07:47.353 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81401.358887, idle connection 259101.000000, request 304399.361610 04/23/2026 02:07:47.353 7ff0062d2400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 738 04/23/2026 02:07:47.353 7ff0062d2400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.353 7ff0062d2400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 738 (600.9495258331299 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1208716337, topics=[]) 04/23/2026 02:07:47.354 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1208716337 with 0 response partitions (1 implied) 04/23/2026 02:07:47.356 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 245 04/23/2026 02:07:47.356 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 04/23/2026 02:07:47.357 7ff0062d29a0 [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)]) 04/23/2026 02:07:47.357 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.357 7ff0062d29a0 [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=641058939, session_epoch=723, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.357 7ff0062d29a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 727 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641058939, session_epoch=723, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.357 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80971.182617, idle connection 259197.000000, request 304999.959707 04/23/2026 02:07:47.357 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80970.881104, idle connection 259196.000000, request 304999.660015 04/23/2026 02:07:47.396 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80516.802979, idle connection 259121.000000, request 304399.055719 04/23/2026 02:07:47.397 7ff0043822c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 04/23/2026 02:07:47.397 7ff0043822c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.397 7ff0043822c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (601.9878387451172 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1899353276, topics=[]) 04/23/2026 02:07:47.397 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1899353276 with 0 response partitions (1 implied) 04/23/2026 02:07:47.440 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81336.949707, idle connection 258254.000000, request 304399.114132 04/23/2026 02:07:47.440 7ff0064034a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 722 04/23/2026 02:07:47.440 7ff0064034a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.440 7ff0064034a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 722 (601.3801097869873 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=729888628, topics=[]) 04/23/2026 02:07:47.440 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 729888628 with 0 response partitions (1 implied) 04/23/2026 02:07:47.494 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80908.183594, idle connection 258355.000000, request 304399.119377 04/23/2026 02:07:47.494 7ff006403b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 04/23/2026 02:07:47.494 7ff006403b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.494 7ff006403b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 691 (601.3469696044922 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2024950253, topics=[]) 04/23/2026 02:07:47.495 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2024950253 with 0 response partitions (1 implied) 04/23/2026 02:07:47.497 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 04/23/2026 02:07:47.498 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 04/23/2026 02:07:47.498 7ff006034cc0 [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)]) 04/23/2026 02:07:47.498 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.498 7ff006034cc0 [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=626634513, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.498 7ff006034cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=626634513, session_epoch=690, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.498 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80299.497070, idle connection 258915.000000, request 304999.953985 04/23/2026 02:07:47.498 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80299.038574, idle connection 258914.000000, request 304999.498844 04/23/2026 02:07:47.542 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 14 04/23/2026 02:07:47.542 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 04/23/2026 02:07:47.542 7ff004382040 [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)]) 04/23/2026 02:07:47.542 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.542 7ff004382040 [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=115312351, session_epoch=684, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.542 7ff004382040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=115312351, session_epoch=684, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.543 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80396.256592, idle connection 259112.000000, request 304999.955416 04/23/2026 02:07:47.543 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80395.882568, idle connection 259111.000000, request 304999.585629 04/23/2026 02:07:47.545 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80970.615479, idle connection 258369.000000, request 304398.421288 04/23/2026 02:07:47.545 7ff00431c7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 04/23/2026 02:07:47.546 7ff00431c7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.546 7ff00431c7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 691 (601.9361019134521 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1564811653, topics=[]) 04/23/2026 02:07:47.546 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1564811653 with 0 response partitions (1 implied) 04/23/2026 02:07:47.546 7ff006034e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81026.484375, idle connection 258247.000000, request 304398.379087 04/23/2026 02:07:47.546 7ff006034e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 04/23/2026 02:07:47.546 7ff006034e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.546 7ff006034e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 692 (601.912260055542 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1041053072, topics=[]) 04/23/2026 02:07:47.546 7ff006034e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1041053072 with 0 response partitions (1 implied) 04/23/2026 02:07:47.580 7ff00431c4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79788.636475, idle connection 258429.000000, request 304398.498774 04/23/2026 02:07:47.580 7ff00431c4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 04/23/2026 02:07:47.580 7ff00431c4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.580 7ff00431c4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 688 (602.1947860717773 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=859434928, topics=[]) 04/23/2026 02:07:47.581 7ff00431c4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 859434928 with 0 response partitions (1 implied) 04/23/2026 02:07:47.590 7ff0062d27c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80423.453613, idle connection 258775.000000, request 304398.276806 04/23/2026 02:07:47.590 7ff0062d27c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 724 04/23/2026 02:07:47.590 7ff0062d27c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.590 7ff0062d27c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 724 (602.3375988006592 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=48706391, topics=[]) 04/23/2026 02:07:47.591 7ff0062d27c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 48706391 with 0 response partitions (1 implied) 04/23/2026 02:07:47.609 7ff006403ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80927.750977, idle connection 258733.000000, request 304398.939371 04/23/2026 02:07:47.609 7ff006403ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 04/23/2026 02:07:47.609 7ff006403ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.609 7ff006403ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 710 (601.5172004699707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=681443435, topics=[]) 04/23/2026 02:07:47.609 7ff006403ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 681443435 with 0 response partitions (1 implied) 04/23/2026 02:07:47.647 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 149 04/23/2026 02:07:47.647 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 04/23/2026 02:07:47.647 7ff0062d2ea0 [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)]) 04/23/2026 02:07:47.647 7ff0062d2ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.647 7ff0062d2ea0 [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=1515926691, session_epoch=708, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.647 7ff0062d2ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 712 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1515926691, session_epoch=708, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.647 7ff0062d2ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81514.621826, idle connection 258754.000000, request 304999.950647 04/23/2026 02:07:47.648 7ff0062d2ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81514.189209, idle connection 258753.000000, request 304999.522924 04/23/2026 02:07:47.671 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3795 04/23/2026 02:07:47.671 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 04/23/2026 02:07:47.671 7ff006403180 [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)]) 04/23/2026 02:07:47.671 7ff006403180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.671 7ff006403180 [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=205155975, session_epoch=1015, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.671 7ff006403180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 1019 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=205155975, session_epoch=1015, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.671 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80323.210938, idle connection 258770.000000, request 304999.952793 04/23/2026 02:07:47.672 7ff006403180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80322.842041, idle connection 258770.000000, request 304999.587536 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80950.960449, idle connection 258254.000000, request 304399.125099 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 744 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 744 (601.3414859771729 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1837721512, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=312, last_stable_offset=312, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x016\x00\x00\x02\x13\x00\x00\x00\x00\x02\xaa0\xd6\xff\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\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1837721512 with 1 response partitions (0 implied) 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 543 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 310 04/23/2026 02:07:47.700 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 310 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 04/23/2026 02:07:47.701 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 312 (leader epoch 0) 04/23/2026 02:07:47.761 7ff00431ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80349.641113, idle connection 258535.000000, request 304398.047686 04/23/2026 02:07:47.762 7ff00431ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 04/23/2026 02:07:47.762 7ff00431ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.762 7ff00431ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (602.4045944213867 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1718921010, topics=[]) 04/23/2026 02:07:47.762 7ff00431ccc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1718921010 with 0 response partitions (1 implied) 04/23/2026 02:07:47.762 7ff006403f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80969.079102, idle connection 258389.000000, request 304397.922039 04/23/2026 02:07:47.762 7ff006403f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 04/23/2026 02:07:47.762 7ff006403f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.762 7ff006403f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 690 (602.379322052002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=370863008, topics=[]) 04/23/2026 02:07:47.763 7ff006403f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 370863008 with 0 response partitions (1 implied) 04/23/2026 02:07:47.801 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 312 04/23/2026 02:07:47.801 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 04/23/2026 02:07:47.801 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 04/23/2026 02:07:47.801 7ff0062d2180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.801 7ff0062d2180 [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=1837721512, session_epoch=741, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=312, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.802 7ff0062d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 745 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1837721512, session_epoch=741, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=312, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.802 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80848.751709, idle connection 258152.000000, request 304999.952793 04/23/2026 02:07:47.802 7ff0062d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80848.342773, idle connection 258151.000000, request 304999.547958 04/23/2026 02:07:47.859 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 261 04/23/2026 02:07:47.859 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 04/23/2026 02:07:47.859 7ff0062d2ae0 [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)]) 04/23/2026 02:07:47.859 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.859 7ff0062d2ae0 [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=982030124, session_epoch=733, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.859 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 737 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=982030124, session_epoch=733, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.859 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80506.073242, idle connection 258735.000000, request 304999.950409 04/23/2026 02:07:47.860 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80651.126465, idle connection 258988.000000, request 304397.639990 04/23/2026 02:07:47.860 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80505.519287, idle connection 258735.000000, request 304999.403477 04/23/2026 02:07:47.860 7ff0062d25e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 722 04/23/2026 02:07:47.860 7ff0062d25e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.860 7ff0062d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 722 (603.0526161193848 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=294578344, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=215, last_stable_offset=215, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xd6\x00\x00\x01#\x00\x00\x00\x00\x02\xe3\xba\xe5~\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\xe0\x03\x00\x00\x00\xa2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:47.860 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 294578344 with 1 response partitions (0 implied) 04/23/2026 02:07:47.861 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 303 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 214 04/23/2026 02:07:47.861 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 214 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 04/23/2026 02:07:47.861 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 215 (leader epoch 0) 04/23/2026 02:07:47.861 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80973.582031, idle connection 258708.000000, request 304398.065567 04/23/2026 02:07:47.861 7ff0062d2ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 737 04/23/2026 02:07:47.861 7ff0062d2ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.861 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 737 (2.0940303802490234 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=982030124, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=263, last_stable_offset=263, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x01\x05\x00\x00\x01#\x00\x00\x00\x00\x02Z\xe6\xa9\x12\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\xe0\x03\x00\x00\x00\xa2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:47.862 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 982030124 with 1 response partitions (0 implied) 04/23/2026 02:07:47.862 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 609 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 261 04/23/2026 02:07:47.862 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 261 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) 04/23/2026 02:07:47.862 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 263 (leader epoch 0) 04/23/2026 02:07:47.862 7ff0062d2a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 712 04/23/2026 02:07:47.862 7ff0062d2a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.862 7ff0062d2a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 712 (603.2216548919678 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1131051951, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=128, last_stable_offset=128, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00~\x00\x00\x02\x17\x00\x00\x00\x00\x02s\xfd\xe2\xe1\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\xfc\x03\x00\x00\x00\xbe\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:47.863 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1131051951 with 1 response partitions (0 implied) 04/23/2026 02:07:47.863 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 126 04/23/2026 02:07:47.863 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 126 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 04/23/2026 02:07:47.863 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 128 (leader epoch 0) 04/23/2026 02:07:47.864 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44 04/23/2026 02:07:47.864 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/23/2026 02:07:47.864 7ff0062d2540 [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)]) 04/23/2026 02:07:47.865 7ff0062d2540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.865 7ff0062d2540 [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=890357573, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.865 7ff0062d2540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=890357573, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.865 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80961.735596, idle connection 258813.000000, request 304999.960423 04/23/2026 02:07:47.865 7ff0062d2540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80961.409912, idle connection 258813.000000, request 304999.637127 04/23/2026 02:07:47.866 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 34 04/23/2026 02:07:47.866 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 04/23/2026 02:07:47.866 7ff006403d60 [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)]) 04/23/2026 02:07:47.867 7ff006403d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.867 7ff006403d60 [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=36924144, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.867 7ff006403d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=36924144, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.867 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80816.611084, idle connection 257826.000000, request 304999.964237 04/23/2026 02:07:47.867 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 46 04/23/2026 02:07:47.867 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 04/23/2026 02:07:47.867 7ff0064032c0 [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)]) 04/23/2026 02:07:47.867 7ff0064032c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.867 7ff0064032c0 [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=1528029278, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.867 7ff0064032c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1528029278, session_epoch=689, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.867 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80400.717041, idle connection 257923.000000, request 304999.966860 04/23/2026 02:07:47.868 7ff006403d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80815.741699, idle connection 257825.000000, request 304999.096632 04/23/2026 02:07:47.868 7ff0064032c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80400.184814, idle connection 257923.000000, request 304999.436378 04/23/2026 02:07:47.938 7ff006034720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80462.052246, idle connection 257872.000000, request 304398.130655 04/23/2026 02:07:47.939 7ff006034720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696 04/23/2026 02:07:47.939 7ff006034720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.939 7ff006034720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 696 (602.4148464202881 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=524261613, topics=[]) 04/23/2026 02:07:47.939 7ff006034720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 524261613 with 0 response partitions (1 implied) 04/23/2026 02:07:47.939 7ff006403040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79771.550293, idle connection 258355.000000, request 304397.927523 04/23/2026 02:07:47.939 7ff006403040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 04/23/2026 02:07:47.940 7ff006403040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.940 7ff006403040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 684 (602.367639541626 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307238224, topics=[]) 04/23/2026 02:07:47.940 7ff006403040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307238224 with 0 response partitions (1 implied) 04/23/2026 02:07:47.943 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 220 04/23/2026 02:07:47.943 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 04/23/2026 02:07:47.943 7ff0062d22c0 [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)]) 04/23/2026 02:07:47.943 7ff0062d22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.943 7ff0062d22c0 [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=1502435447, session_epoch=720, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.943 7ff0062d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1502435447, session_epoch=720, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.943 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81626.813965, idle connection 258649.000000, request 304999.959469 04/23/2026 02:07:47.943 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 178 04/23/2026 02:07:47.944 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/23/2026 02:07:47.944 7ff0062d2c20 [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)]) 04/23/2026 02:07:47.944 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.944 7ff0062d2c20 [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=2094067982, session_epoch=709, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.944 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 713 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2094067982, session_epoch=709, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.944 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80493.057373, idle connection 258385.000000, request 304999.963284 04/23/2026 02:07:47.944 7ff0062d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81625.840820, idle connection 258648.000000, request 304998.989105 04/23/2026 02:07:47.944 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 51 04/23/2026 02:07:47.944 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 04/23/2026 02:07:47.945 7ff006403a40 [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)]) 04/23/2026 02:07:47.945 7ff006403a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.945 7ff006403a40 [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=1132901887, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.945 7ff006403a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132901887, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.945 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80381.523438, idle connection 257782.000000, request 304999.952078 04/23/2026 02:07:47.945 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80491.852051, idle connection 258383.000000, request 304998.761177 04/23/2026 02:07:47.945 7ff006403a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80380.936768, idle connection 257781.000000, request 304999.367237 04/23/2026 02:07:47.946 7ff0062d2c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 713 04/23/2026 02:07:47.946 7ff0062d2c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.946 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 713 (1.9154548645019531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2094067982, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=182, last_stable_offset=182, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xb2\x00\x00\x02\x1c\x00\x00\x00\x00\x02\xae\x1dCp\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\xe4\x03\x00\x00\x00\xa6\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:47.946 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2094067982 with 1 response partitions (0 implied) 04/23/2026 02:07:47.946 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1088 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 178 04/23/2026 02:07:47.946 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 178 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 04/23/2026 02:07:47.947 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 182 (leader epoch 0) 04/23/2026 02:07:47.947 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 48 04/23/2026 02:07:47.947 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 04/23/2026 02:07:47.947 7ff006403ae0 [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)]) 04/23/2026 02:07:47.947 7ff006403ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.947 7ff006403ae0 [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=1773237565, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.947 7ff006403ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1773237565, session_epoch=691, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.947 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80979.253662, idle connection 258384.000000, request 304999.965191 04/23/2026 02:07:47.947 7ff006403540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79774.245117, idle connection 258349.000000, request 304397.037745 04/23/2026 02:07:47.948 7ff006403540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 04/23/2026 02:07:47.948 7ff006403540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.948 7ff006403540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 684 (603.3239364624023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458528261, topics=[]) 04/23/2026 02:07:47.948 7ff006403540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458528261 with 0 response partitions (1 implied) 04/23/2026 02:07:47.948 7ff006403ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80978.282471, idle connection 258383.000000, request 304998.995543 04/23/2026 02:07:47.954 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 260 04/23/2026 02:07:47.954 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/23/2026 02:07:47.954 7ff0062d2400 [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)]) 04/23/2026 02:07:47.954 7ff0062d2400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.954 7ff0062d2400 [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=1208716337, session_epoch=735, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.954 7ff0062d2400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 739 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1208716337, session_epoch=735, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.954 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80800.221191, idle connection 258500.000000, request 304999.962807 04/23/2026 02:07:47.955 7ff0062d2400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80799.924072, idle connection 258500.000000, request 304999.667645 04/23/2026 02:07:47.957 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80370.626465, idle connection 258596.000000, request 304399.405479 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 727 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 727 (600.9368896484375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=641058939, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=246, last_stable_offset=246, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xf5\x00\x00\x01!\x00\x00\x00\x00\x02\x00\x87\xaaN\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\xdc\x03\x00\x00\x00\x9e\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 641058939 with 1 response partitions (0 implied) 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 301 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 245 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 245 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 04/23/2026 02:07:47.958 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 246 (leader epoch 0) 04/23/2026 02:07:47.961 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 215 04/23/2026 02:07:47.961 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/23/2026 02:07:47.961 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/23/2026 02:07:47.961 7ff0062d25e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.962 7ff0062d25e0 [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=294578344, session_epoch=719, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=215, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.962 7ff0062d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=294578344, session_epoch=719, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=215, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.962 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80548.902588, idle connection 258886.000000, request 304999.961376 04/23/2026 02:07:47.962 7ff0062d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80548.575928, idle connection 258885.000000, request 304999.637365 04/23/2026 02:07:47.963 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 263 04/23/2026 02:07:47.963 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 04/23/2026 02:07:47.963 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-27', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 04/23/2026 02:07:47.963 7ff0062d2ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.963 7ff0062d2ae0 [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=982030124, session_epoch=734, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=263, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.963 7ff0062d2ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 738 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=982030124, session_epoch=734, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=263, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.963 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80402.375000, idle connection 258631.000000, request 304999.963999 04/23/2026 02:07:47.963 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 128 04/23/2026 02:07:47.964 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/23/2026 02:07:47.964 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 04/23/2026 02:07:47.964 7ff0062d2a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.964 7ff0062d2a40 [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=1131051951, session_epoch=709, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=128, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.964 7ff0062d2a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 713 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1131051951, session_epoch=709, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=128, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:47.964 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80870.637695, idle connection 258605.000000, request 304999.960661 04/23/2026 02:07:47.964 7ff0062d2ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80401.124512, idle connection 258630.000000, request 304998.715401 04/23/2026 02:07:47.965 7ff0062d2a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80870.084961, idle connection 258604.000000, request 304999.411106 04/23/2026 02:07:47.998 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17 04/23/2026 02:07:47.999 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/23/2026 02:07:47.999 7ff0043822c0 [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)]) 04/23/2026 02:07:47.999 7ff0043822c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:47.999 7ff0043822c0 [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=1899353276, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.999 7ff0043822c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1899353276, session_epoch=687, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:47.999 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79913.941895, idle connection 258518.000000, request 304999.949932 04/23/2026 02:07:47.999 7ff0043822c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79913.552734, idle connection 258518.000000, request 304999.566317 04/23/2026 02:07:48.041 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 04/23/2026 02:07:48.041 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 04/23/2026 02:07:48.041 7ff0064034a0 [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)]) 04/23/2026 02:07:48.041 7ff0064034a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:48.041 7ff0064034a0 [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=729888628, session_epoch=719, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:48.041 7ff0064034a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=729888628, session_epoch=719, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:48.041 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80735.377930, idle connection 257652.000000, request 304999.954939 04/23/2026 02:07:48.042 7ff0064034a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80735.023193, idle connection 257652.000000, request 304999.604464 04/23/2026 02:07:48.047 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 182 04/23/2026 02:07:48.047 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/23/2026 02:07:48.047 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-23', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/23/2026 02:07:48.047 7ff0062d2c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:48.047 7ff0062d2c20 [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=2094067982, session_epoch=710, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=182, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:48.048 7ff0062d2c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 714 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2094067982, session_epoch=710, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=182, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:48.048 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80389.306885, idle connection 258281.000000, request 304999.958038 04/23/2026 02:07:48.048 7ff0062d2c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80388.821045, idle connection 258280.000000, request 304999.475479 04/23/2026 02:07:48.059 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 246 04/23/2026 02:07:48.059 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 04/23/2026 02:07:48.059 7ff0062d29a0 [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)]) 04/23/2026 02:07:48.059 7ff0062d29a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:48.059 7ff0062d29a0 [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=641058939, session_epoch=724, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=246, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:48.059 7ff0062d29a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 728 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=641058939, session_epoch=724, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=246, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/23/2026 02:07:48.059 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80268.683594, idle connection 258494.000000, request 304999.956846 04/23/2026 02:07:48.060 7ff0062d29a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80268.326660, idle connection 258494.000000, request 304999.603510 04/23/2026 02:07:48.095 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 46 04/23/2026 02:07:48.095 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 04/23/2026 02:07:48.095 7ff006403b80 [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)]) 04/23/2026 02:07:48.095 7ff006403b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:48.095 7ff006403b80 [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=2024950253, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:48.095 7ff006403b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2024950253, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:48.095 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80306.617676, idle connection 257754.000000, request 304999.953270 04/23/2026 02:07:48.096 7ff006403b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80306.247070, idle connection 257753.000000, request 304999.587774 04/23/2026 02:07:48.099 7ff006034cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79698.723389, idle connection 258314.000000, request 304399.184465 04/23/2026 02:07:48.099 7ff006034cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 04/23/2026 02:07:48.099 7ff006034cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:48.099 7ff006034cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 694 (601.1850833892822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=626634513, topics=[]) 04/23/2026 02:07:48.099 7ff006034cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 626634513 with 0 response partitions (1 implied) 04/23/2026 02:07:48.143 7ff004382040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79795.472168, idle connection 258511.000000, request 304399.169207 04/23/2026 02:07:48.144 7ff004382040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 04/23/2026 02:07:48.144 7ff004382040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/23/2026 02:07:48.144 7ff004382040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 688 (601.2318134307861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=115312351, topics=[]) 04/23/2026 02:07:48.144 7ff004382040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 115312351 with 0 response partitions (1 implied) 04/23/2026 02:07:48.146 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 24 04/23/2026 02:07:48.146 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 04/23/2026 02:07:48.146 7ff00431c7c0 [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)]) 04/23/2026 02:07:48.146 7ff00431c7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/23/2026 02:07:48.146 7ff00431c7c0 [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=1564811653, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:48.146 7ff00431c7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1564811653, session_epoch=688, topics=[], forgotten_topics_data=[]) 04/23/2026 02:07:48.146 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80369.380615, idle connection 257768.000000, request 304999.957800 04/23/2026 02:07:48.147 7ff00431c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80369.023193, idle connection 257768.000000, request 304999.603987