03/31/2025 02:30:52.177 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 2 03/31/2025 02:30:52.180 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.180 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:52.180 7f06fa7c6f60 [kafka.conn] [DEBUG]: Request 1022: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:52.181 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 13 03/31/2025 02:30:52.181 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.181 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:52.181 7f06f9d26588 [kafka.conn] [DEBUG]: Request 1028: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:52.181 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 03/31/2025 02:30:52.181 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.182 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:52.182 7f06f99790f0 [kafka.conn] [DEBUG]: Request 1030: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:52.182 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 37 03/31/2025 02:30:52.182 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.182 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:52.182 7f06f9c9ab70 [kafka.conn] [DEBUG]: Request 1110: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:52.183 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1023 03/31/2025 02:30:52.183 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.184 7f06f9d5eac8 [kafka.conn] [DEBUG]: Response 1023 (609.1103553771973 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.184 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1127 03/31/2025 02:30:52.184 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.184 7f06fa7a80f0 [kafka.conn] [DEBUG]: Response 1127 (609.0493202209473 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.195 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 32 03/31/2025 02:30:52.195 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.196 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:52.196 7f06f9d26d68 [kafka.conn] [DEBUG]: Request 1036: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:52.230 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 39 03/31/2025 02:30:52.230 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.230 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:52.231 7f06f9d5eb70 [kafka.conn] [DEBUG]: Request 1119: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:52.383 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1116 03/31/2025 02:30:52.383 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.383 7f06f9c9aa20 [kafka.conn] [DEBUG]: Response 1116 (602.4773120880127 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=94, last_stable_offset=94, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.384 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 69 03/31/2025 02:30:52.384 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.384 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:52.385 7f06f9767cc0 [kafka.conn] [DEBUG]: Request 1050: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:52.385 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1103 03/31/2025 02:30:52.385 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.386 7f06f9d26ac8 [kafka.conn] [DEBUG]: Response 1103 (603.8496494293213 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.388 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 03/31/2025 02:30:52.388 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.389 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:52.389 7f06fa79f6d8 [kafka.conn] [DEBUG]: Request 1095: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:52.436 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 198 03/31/2025 02:30:52.436 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.436 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:52.437 7f06f9d7a438 [kafka.conn] [DEBUG]: Request 1153: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:52.482 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 207 03/31/2025 02:30:52.483 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.483 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:52.483 7f06f97e4e10 [kafka.conn] [DEBUG]: Request 1086: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:52.484 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 162 03/31/2025 02:30:52.484 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.484 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:52.484 7f06f7b24e10 [kafka.conn] [DEBUG]: Request 1147: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:52.504 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 283 03/31/2025 02:30:52.504 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.504 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=283, max_bytes=1048576)])]) 03/31/2025 02:30:52.504 7f06f97ea0f0 [kafka.conn] [DEBUG]: Request 1185: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=283, max_bytes=1048576)])]) 03/31/2025 02:30:52.536 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 197 03/31/2025 02:30:52.536 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.536 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:52.537 7f06f9740cc0 [kafka.conn] [DEBUG]: Request 1095: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:52.604 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 03/31/2025 02:30:52.604 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.604 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:52.605 7f06fa1c3f60 [kafka.conn] [DEBUG]: Request 1134: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:52.625 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1548 03/31/2025 02:30:52.625 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.625 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1548 (602.6368141174316 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3586, last_stable_offset=3586, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.626 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1222 03/31/2025 02:30:52.626 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.626 7f06f9740eb8 [kafka.conn] [DEBUG]: Response 1222 (602.7011871337891 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=517, last_stable_offset=517, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.664 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1108 03/31/2025 02:30:52.664 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.664 7f06f9d5e828 [kafka.conn] [DEBUG]: Response 1108 (605.5054664611816 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.685 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1097 03/31/2025 02:30:52.686 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.686 7f06fa7a8390 [kafka.conn] [DEBUG]: Response 1097 (609.1930866241455 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.701 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1108 03/31/2025 02:30:52.701 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.702 7f06f9c9a978 [kafka.conn] [DEBUG]: Response 1108 (602.9884815216064 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.703 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1030 03/31/2025 02:30:52.703 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.703 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Response 1030 (603.5962104797363 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.704 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1140 03/31/2025 02:30:52.704 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.704 7f06f9c9ae10 [kafka.conn] [DEBUG]: Response 1140 (603.7118434906006 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=222, last_stable_offset=222, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.704 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1038 03/31/2025 02:30:52.704 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.705 7f06f9861e10 [kafka.conn] [DEBUG]: Response 1038 (603.7018299102783 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.705 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:52.706 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.706 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:52.706 7f06f9d7a630 [kafka.conn] [DEBUG]: Request 1101: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:52.707 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6 03/31/2025 02:30:52.707 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.707 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:52.707 7f06f9767c18 [kafka.conn] [DEBUG]: Request 1025: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:52.708 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1142 03/31/2025 02:30:52.708 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.709 7f06fa1c38d0 [kafka.conn] [DEBUG]: Response 1142 (602.9958724975586 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=142, last_stable_offset=142, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.785 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 03/31/2025 02:30:52.785 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.785 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:52.786 7f06f9d5eac8 [kafka.conn] [DEBUG]: Request 1024: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:52.786 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 96 03/31/2025 02:30:52.786 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.786 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:52.786 7f06fa7a80f0 [kafka.conn] [DEBUG]: Request 1128: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:52.794 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1098 03/31/2025 02:30:52.795 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.795 7f06f9d268d0 [kafka.conn] [DEBUG]: Response 1098 (617.842435836792 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.795 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1022 03/31/2025 02:30:52.796 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.796 7f06fa7c6f60 [kafka.conn] [DEBUG]: Response 1022 (615.4289245605469 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.796 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1028 03/31/2025 02:30:52.796 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.796 7f06f9d26588 [kafka.conn] [DEBUG]: Response 1028 (615.3137683868408 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.797 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1030 03/31/2025 02:30:52.797 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.797 7f06f99790f0 [kafka.conn] [DEBUG]: Response 1030 (615.2806282043457 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.797 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1110 03/31/2025 02:30:52.797 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.798 7f06f9c9ab70 [kafka.conn] [DEBUG]: Response 1110 (615.2739524841309 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.801 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1036 03/31/2025 02:30:52.801 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.801 7f06f9d26d68 [kafka.conn] [DEBUG]: Response 1036 (605.4115295410156 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.832 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1119 03/31/2025 02:30:52.832 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.832 7f06f9d5eb70 [kafka.conn] [DEBUG]: Response 1119 (601.5057563781738 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=39, last_stable_offset=39, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.985 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 94 03/31/2025 02:30:52.985 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.985 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:52.985 7f06f9c9aa20 [kafka.conn] [DEBUG]: Request 1117: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:52.987 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 20 03/31/2025 02:30:52.987 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:52.987 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:52.987 7f06f9d26ac8 [kafka.conn] [DEBUG]: Request 1104: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:52.988 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1050 03/31/2025 02:30:52.988 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.988 7f06f9767cc0 [kafka.conn] [DEBUG]: Response 1050 (603.4176349639893 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=69, last_stable_offset=69, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:52.996 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1095 03/31/2025 02:30:52.996 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:52.996 7f06fa79f6d8 [kafka.conn] [DEBUG]: Response 1095 (607.2235107421875 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.038 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1153 03/31/2025 02:30:53.038 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.038 7f06f9d7a438 [kafka.conn] [DEBUG]: Response 1153 (601.5527248382568 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.085 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1086 03/31/2025 02:30:53.085 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.085 7f06f97e4e10 [kafka.conn] [DEBUG]: Response 1086 (602.2698879241943 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=207, last_stable_offset=207, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.086 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1147 03/31/2025 02:30:53.087 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.087 7f06f7b24e10 [kafka.conn] [DEBUG]: Response 1147 (602.8008460998535 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.106 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1185 03/31/2025 02:30:53.106 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.106 7f06f97ea0f0 [kafka.conn] [DEBUG]: Response 1185 (602.0119190216064 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=283, last_stable_offset=283, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.138 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1095 03/31/2025 02:30:53.139 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.139 7f06f9740cc0 [kafka.conn] [DEBUG]: Response 1095 (602.2505760192871 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=197, last_stable_offset=197, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.207 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1134 03/31/2025 02:30:53.207 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.207 7f06fa1c3f60 [kafka.conn] [DEBUG]: Response 1134 (602.7770042419434 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.226 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3586 03/31/2025 02:30:53.226 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.226 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3586, max_bytes=1048576)])]) 03/31/2025 02:30:53.226 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1549: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3586, max_bytes=1048576)])]) 03/31/2025 02:30:53.227 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 517 03/31/2025 02:30:53.227 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.227 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:53.227 7f06f9740eb8 [kafka.conn] [DEBUG]: Request 1223: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:53.228 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1549 03/31/2025 02:30:53.228 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.228 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1549 (1.447916030883789 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3587, last_stable_offset=3587, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0e\x02\x00\x00\x00\xfe\x00\x00\x00\x00\x02u\xba,L\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\x96\x03\x00\x00\x00\xd8\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/31/2025 02:30:53.228 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3586 to buffered record list 03/31/2025 02:30:53.265 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 19 03/31/2025 02:30:53.265 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.265 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:53.266 7f06f9d5e828 [kafka.conn] [DEBUG]: Request 1109: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:53.287 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 03/31/2025 02:30:53.287 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.287 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.288 7f06fa7a8390 [kafka.conn] [DEBUG]: Request 1098: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.302 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28 03/31/2025 02:30:53.303 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.303 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:53.303 7f06f9c9a978 [kafka.conn] [DEBUG]: Request 1109: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:53.304 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 17 03/31/2025 02:30:53.304 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.304 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:53.304 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Request 1031: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:53.304 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 222 03/31/2025 02:30:53.304 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.305 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:53.305 7f06f9c9ae10 [kafka.conn] [DEBUG]: Request 1141: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:53.305 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45 03/31/2025 02:30:53.305 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.306 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:53.306 7f06f9861e10 [kafka.conn] [DEBUG]: Request 1039: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:53.308 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1101 03/31/2025 02:30:53.308 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.308 7f06f9d7a630 [kafka.conn] [DEBUG]: Response 1101 (602.4594306945801 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.309 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1025 03/31/2025 02:30:53.309 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.309 7f06f9767c18 [kafka.conn] [DEBUG]: Response 1025 (601.9425392150879 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.310 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 142 03/31/2025 02:30:53.310 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.310 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:53.310 7f06fa1c38d0 [kafka.conn] [DEBUG]: Request 1143: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:53.329 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3587 03/31/2025 02:30:53.329 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.329 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3587, max_bytes=1048576)])]) 03/31/2025 02:30:53.329 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1550: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3587, max_bytes=1048576)])]) 03/31/2025 02:30:53.387 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1024 03/31/2025 02:30:53.387 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.388 7f06f9d5eac8 [kafka.conn] [DEBUG]: Response 1024 (602.1919250488281 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.388 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1128 03/31/2025 02:30:53.388 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.388 7f06fa7a80f0 [kafka.conn] [DEBUG]: Response 1128 (602.1180152893066 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.396 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/31/2025 02:30:53.396 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.396 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.397 7f06f9d268d0 [kafka.conn] [DEBUG]: Request 1099: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.397 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 2 03/31/2025 02:30:53.397 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.397 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:53.398 7f06fa7c6f60 [kafka.conn] [DEBUG]: Request 1023: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:53.398 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 13 03/31/2025 02:30:53.398 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.398 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:53.398 7f06f9d26588 [kafka.conn] [DEBUG]: Request 1029: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:53.399 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 03/31/2025 02:30:53.399 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.399 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:53.399 7f06f99790f0 [kafka.conn] [DEBUG]: Request 1031: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:53.399 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 37 03/31/2025 02:30:53.399 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.400 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:53.400 7f06f9c9ab70 [kafka.conn] [DEBUG]: Request 1111: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:53.403 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 32 03/31/2025 02:30:53.403 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.403 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:53.403 7f06f9d26d68 [kafka.conn] [DEBUG]: Request 1037: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:53.434 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 39 03/31/2025 02:30:53.434 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.434 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:53.435 7f06f9d5eb70 [kafka.conn] [DEBUG]: Request 1120: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:53.587 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1117 03/31/2025 02:30:53.587 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.587 7f06f9c9aa20 [kafka.conn] [DEBUG]: Response 1117 (601.6330718994141 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=94, last_stable_offset=94, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.588 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1104 03/31/2025 02:30:53.588 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.588 7f06f9d26ac8 [kafka.conn] [DEBUG]: Response 1104 (601.1605262756348 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.589 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 69 03/31/2025 02:30:53.589 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.589 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:53.589 7f06f9767cc0 [kafka.conn] [DEBUG]: Request 1051: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:53.597 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 03/31/2025 02:30:53.597 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.597 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:53.598 7f06fa79f6d8 [kafka.conn] [DEBUG]: Request 1096: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:53.640 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 198 03/31/2025 02:30:53.640 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.641 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:53.641 7f06f9d7a438 [kafka.conn] [DEBUG]: Request 1154: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:53.687 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 207 03/31/2025 02:30:53.687 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.687 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:53.687 7f06f97e4e10 [kafka.conn] [DEBUG]: Request 1087: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:53.688 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 162 03/31/2025 02:30:53.688 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.688 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:53.689 7f06f7b24e10 [kafka.conn] [DEBUG]: Request 1148: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:53.709 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 283 03/31/2025 02:30:53.709 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.709 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=283, max_bytes=1048576)])]) 03/31/2025 02:30:53.710 7f06f97ea0f0 [kafka.conn] [DEBUG]: Request 1186: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=283, max_bytes=1048576)])]) 03/31/2025 02:30:53.739 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 197 03/31/2025 02:30:53.740 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.740 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:53.740 7f06f9740cc0 [kafka.conn] [DEBUG]: Request 1096: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:53.808 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 03/31/2025 02:30:53.808 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.808 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:53.809 7f06fa1c3f60 [kafka.conn] [DEBUG]: Request 1135: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:53.830 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1223 03/31/2025 02:30:53.830 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.830 7f06f9740eb8 [kafka.conn] [DEBUG]: Response 1223 (603.2395362854004 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=517, last_stable_offset=517, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.867 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1109 03/31/2025 02:30:53.867 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.867 7f06f9d5e828 [kafka.conn] [DEBUG]: Response 1109 (601.2876033782959 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.889 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1098 03/31/2025 02:30:53.889 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.889 7f06fa7a8390 [kafka.conn] [DEBUG]: Response 1098 (601.9067764282227 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.904 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1109 03/31/2025 02:30:53.904 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.904 7f06f9c9a978 [kafka.conn] [DEBUG]: Response 1109 (601.3901233673096 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.905 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1031 03/31/2025 02:30:53.905 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.905 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Response 1031 (601.4590263366699 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.906 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1141 03/31/2025 02:30:53.906 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.907 7f06f9c9ae10 [kafka.conn] [DEBUG]: Response 1141 (601.7675399780273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=222, last_stable_offset=222, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.907 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1039 03/31/2025 02:30:53.907 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.907 7f06f9861e10 [kafka.conn] [DEBUG]: Response 1039 (601.5124320983887 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.913 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:53.913 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.913 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.914 7f06f9d7a630 [kafka.conn] [DEBUG]: Request 1102: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.914 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6 03/31/2025 02:30:53.914 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.914 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:53.914 7f06f9767c18 [kafka.conn] [DEBUG]: Request 1026: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:53.915 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1143 03/31/2025 02:30:53.915 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.915 7f06fa1c38d0 [kafka.conn] [DEBUG]: Response 1143 (605.2284240722656 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=142, last_stable_offset=142, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.931 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1550 03/31/2025 02:30:53.931 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.931 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1550 (601.8211841583252 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3587, last_stable_offset=3587, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:53.988 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 03/31/2025 02:30:53.989 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.989 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.989 7f06f9d5eac8 [kafka.conn] [DEBUG]: Request 1025: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:53.989 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 96 03/31/2025 02:30:53.989 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:53.989 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:53.990 7f06fa7a80f0 [kafka.conn] [DEBUG]: Request 1129: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:53.999 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1099 03/31/2025 02:30:53.999 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:53.999 7f06f9d268d0 [kafka.conn] [DEBUG]: Response 1099 (602.7307510375977 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.000 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1023 03/31/2025 02:30:54.000 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.001 7f06fa7c6f60 [kafka.conn] [DEBUG]: Response 1023 (603.1696796417236 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.001 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1029 03/31/2025 02:30:54.001 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.001 7f06f9d26588 [kafka.conn] [DEBUG]: Response 1029 (603.3403873443604 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.002 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1031 03/31/2025 02:30:54.002 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.002 7f06f99790f0 [kafka.conn] [DEBUG]: Response 1031 (602.9987335205078 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.002 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1111 03/31/2025 02:30:54.002 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.003 7f06f9c9ab70 [kafka.conn] [DEBUG]: Response 1111 (602.9143333435059 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.004 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1037 03/31/2025 02:30:54.004 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.004 7f06f9d26d68 [kafka.conn] [DEBUG]: Response 1037 (601.11403465271 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.036 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1120 03/31/2025 02:30:54.036 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.036 7f06f9d5eb70 [kafka.conn] [DEBUG]: Response 1120 (601.3836860656738 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=39, last_stable_offset=39, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.188 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 94 03/31/2025 02:30:54.188 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.188 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:54.189 7f06f9c9aa20 [kafka.conn] [DEBUG]: Request 1118: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:54.189 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 20 03/31/2025 02:30:54.189 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.189 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:54.190 7f06f9d26ac8 [kafka.conn] [DEBUG]: Request 1105: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:54.190 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1051 03/31/2025 02:30:54.191 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.191 7f06f9767cc0 [kafka.conn] [DEBUG]: Response 1051 (601.3269424438477 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=69, last_stable_offset=69, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.199 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1096 03/31/2025 02:30:54.199 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.199 7f06fa79f6d8 [kafka.conn] [DEBUG]: Response 1096 (601.5925407409668 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.242 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1154 03/31/2025 02:30:54.242 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.242 7f06f9d7a438 [kafka.conn] [DEBUG]: Response 1154 (601.3448238372803 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.289 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1087 03/31/2025 02:30:54.290 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.290 7f06f97e4e10 [kafka.conn] [DEBUG]: Response 1087 (602.5612354278564 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=207, last_stable_offset=207, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.291 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1148 03/31/2025 02:30:54.291 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.291 7f06f7b24e10 [kafka.conn] [DEBUG]: Response 1148 (602.3643016815186 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.310 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1186 03/31/2025 02:30:54.311 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.311 7f06f97ea0f0 [kafka.conn] [DEBUG]: Response 1186 (601.2930870056152 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=285, last_stable_offset=285, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x01\x1b\x00\x00\x02\x0b\x00\x00\x00\x00\x02\xab\xd1\xce#\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\xd6\x03\x00\x00\x00\x98\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 03/31/2025 02:30:54.311 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 283 to buffered record list 03/31/2025 02:30:54.341 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1096 03/31/2025 02:30:54.341 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.342 7f06f9740cc0 [kafka.conn] [DEBUG]: Response 1096 (601.4323234558105 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=197, last_stable_offset=197, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.410 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1135 03/31/2025 02:30:54.410 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.410 7f06fa1c3f60 [kafka.conn] [DEBUG]: Response 1135 (601.2897491455078 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.412 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 285 03/31/2025 02:30:54.412 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.412 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=285, max_bytes=1048576)])]) 03/31/2025 02:30:54.412 7f06f97ea0f0 [kafka.conn] [DEBUG]: Request 1187: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=285, max_bytes=1048576)])]) 03/31/2025 02:30:54.432 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 517 03/31/2025 02:30:54.432 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.432 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:54.432 7f06f9740eb8 [kafka.conn] [DEBUG]: Request 1224: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:54.467 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 19 03/31/2025 02:30:54.468 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.468 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:54.468 7f06f9d5e828 [kafka.conn] [DEBUG]: Request 1110: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:54.490 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 03/31/2025 02:30:54.490 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.491 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:54.491 7f06fa7a8390 [kafka.conn] [DEBUG]: Request 1099: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:54.505 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28 03/31/2025 02:30:54.505 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.505 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:54.506 7f06f9c9a978 [kafka.conn] [DEBUG]: Request 1110: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:54.506 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 17 03/31/2025 02:30:54.506 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.506 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:54.507 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Request 1032: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:54.507 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 222 03/31/2025 02:30:54.507 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.507 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:54.507 7f06f9c9ae10 [kafka.conn] [DEBUG]: Request 1142: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:54.508 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45 03/31/2025 02:30:54.508 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.508 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:54.508 7f06f9861e10 [kafka.conn] [DEBUG]: Request 1040: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:54.515 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1102 03/31/2025 02:30:54.515 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.515 7f06f9d7a630 [kafka.conn] [DEBUG]: Response 1102 (601.7370223999023 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.516 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 142 03/31/2025 02:30:54.516 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.516 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:54.516 7f06fa1c38d0 [kafka.conn] [DEBUG]: Request 1144: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:54.517 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1026 03/31/2025 02:30:54.517 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.517 7f06f9767c18 [kafka.conn] [DEBUG]: Response 1026 (602.398157119751 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.532 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3587 03/31/2025 02:30:54.532 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.532 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3587, max_bytes=1048576)])]) 03/31/2025 02:30:54.532 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1551: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3587, max_bytes=1048576)])]) 03/31/2025 02:30:54.590 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1025 03/31/2025 02:30:54.591 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.591 7f06f9d5eac8 [kafka.conn] [DEBUG]: Response 1025 (601.9425392150879 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.591 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1129 03/31/2025 02:30:54.591 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.592 7f06fa7a80f0 [kafka.conn] [DEBUG]: Response 1129 (601.9606590270996 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.600 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/31/2025 02:30:54.600 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.600 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:54.600 7f06f9d268d0 [kafka.conn] [DEBUG]: Request 1100: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:54.601 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 2 03/31/2025 02:30:54.601 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.601 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:54.601 7f06fa7c6f60 [kafka.conn] [DEBUG]: Request 1024: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:54.602 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 13 03/31/2025 02:30:54.602 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.602 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:54.602 7f06f9d26588 [kafka.conn] [DEBUG]: Request 1030: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:54.603 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 03/31/2025 02:30:54.603 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.603 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:54.603 7f06f99790f0 [kafka.conn] [DEBUG]: Request 1032: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:54.603 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 37 03/31/2025 02:30:54.603 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.603 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:54.604 7f06f9c9ab70 [kafka.conn] [DEBUG]: Request 1112: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:54.605 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 32 03/31/2025 02:30:54.605 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.605 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:54.605 7f06f9d26d68 [kafka.conn] [DEBUG]: Request 1038: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:54.636 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 39 03/31/2025 02:30:54.637 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.637 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:54.637 7f06f9d5eb70 [kafka.conn] [DEBUG]: Request 1121: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:54.791 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1118 03/31/2025 02:30:54.791 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.791 7f06f9c9aa20 [kafka.conn] [DEBUG]: Response 1118 (602.5054454803467 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=94, last_stable_offset=94, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.792 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 69 03/31/2025 02:30:54.792 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.792 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:54.792 7f06f9767cc0 [kafka.conn] [DEBUG]: Request 1052: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:54.793 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1105 03/31/2025 02:30:54.793 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:54.793 7f06f9d26ac8 [kafka.conn] [DEBUG]: Response 1105 (603.2595634460449 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:54.800 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 03/31/2025 02:30:54.800 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.800 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:54.800 7f06fa79f6d8 [kafka.conn] [DEBUG]: Request 1097: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:54.843 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 198 03/31/2025 02:30:54.843 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.843 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:54.843 7f06f9d7a438 [kafka.conn] [DEBUG]: Request 1155: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:54.890 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 207 03/31/2025 02:30:54.891 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.891 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:54.891 7f06f97e4e10 [kafka.conn] [DEBUG]: Request 1088: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:54.891 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 162 03/31/2025 02:30:54.892 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.892 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:54.892 7f06f7b24e10 [kafka.conn] [DEBUG]: Request 1149: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:54.942 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 197 03/31/2025 02:30:54.942 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:54.943 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:54.943 7f06f9740cc0 [kafka.conn] [DEBUG]: Request 1097: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:55.011 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 03/31/2025 02:30:55.011 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.011 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:55.011 7f06fa1c3f60 [kafka.conn] [DEBUG]: Request 1136: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:55.013 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1187 03/31/2025 02:30:55.013 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.013 7f06f97ea0f0 [kafka.conn] [DEBUG]: Response 1187 (601.1307239532471 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=285, last_stable_offset=285, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.033 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1224 03/31/2025 02:30:55.033 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.033 7f06f9740eb8 [kafka.conn] [DEBUG]: Response 1224 (601.1419296264648 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=517, last_stable_offset=517, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.069 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1110 03/31/2025 02:30:55.069 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.069 7f06f9d5e828 [kafka.conn] [DEBUG]: Response 1110 (601.4316082000732 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.092 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1099 03/31/2025 02:30:55.092 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.093 7f06fa7a8390 [kafka.conn] [DEBUG]: Response 1099 (601.797342300415 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.107 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1110 03/31/2025 02:30:55.107 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.108 7f06f9c9a978 [kafka.conn] [DEBUG]: Response 1110 (601.8965244293213 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.108 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1032 03/31/2025 02:30:55.108 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.108 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Response 1032 (601.9628047943115 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.109 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1142 03/31/2025 02:30:55.109 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.109 7f06f9c9ae10 [kafka.conn] [DEBUG]: Response 1142 (601.6848087310791 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=222, last_stable_offset=222, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.110 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1040 03/31/2025 02:30:55.110 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.110 7f06f9861e10 [kafka.conn] [DEBUG]: Response 1040 (601.5493869781494 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.116 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:55.116 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.116 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.116 7f06f9d7a630 [kafka.conn] [DEBUG]: Request 1103: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.117 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6 03/31/2025 02:30:55.117 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.117 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:55.118 7f06f9767c18 [kafka.conn] [DEBUG]: Request 1027: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:55.118 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1144 03/31/2025 02:30:55.118 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.118 7f06fa1c38d0 [kafka.conn] [DEBUG]: Response 1144 (602.3082733154297 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=142, last_stable_offset=142, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.133 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1551 03/31/2025 02:30:55.133 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.133 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1551 (601.0541915893555 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3588, last_stable_offset=3588, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0e\x03\x00\x00\x00\xfe\x00\x00\x00\x00\x02\xd5\xef\x18\xe7\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\x96\x03\x00\x00\x00\xd8\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/31/2025 02:30:55.133 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3587 to buffered record list 03/31/2025 02:30:55.191 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 03/31/2025 02:30:55.192 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.192 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.192 7f06f9d5eac8 [kafka.conn] [DEBUG]: Request 1026: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.192 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 96 03/31/2025 02:30:55.193 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.193 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:55.193 7f06fa7a80f0 [kafka.conn] [DEBUG]: Request 1130: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:55.201 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1100 03/31/2025 02:30:55.201 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.201 7f06f9d268d0 [kafka.conn] [DEBUG]: Response 1100 (601.2134552001953 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.202 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1024 03/31/2025 02:30:55.202 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.202 7f06fa7c6f60 [kafka.conn] [DEBUG]: Response 1024 (600.8307933807373 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.203 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1030 03/31/2025 02:30:55.204 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.204 7f06f9d26588 [kafka.conn] [DEBUG]: Response 1030 (601.5069484710693 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.204 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1032 03/31/2025 02:30:55.204 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.204 7f06f99790f0 [kafka.conn] [DEBUG]: Response 1032 (601.5884876251221 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.205 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1112 03/31/2025 02:30:55.205 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.205 7f06f9c9ab70 [kafka.conn] [DEBUG]: Response 1112 (601.466178894043 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.206 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1038 03/31/2025 02:30:55.206 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.206 7f06f9d26d68 [kafka.conn] [DEBUG]: Response 1038 (600.7874011993408 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.276 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3588 03/31/2025 02:30:55.276 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.276 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3588, max_bytes=1048576)])]) 03/31/2025 02:30:55.277 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1552: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3588, max_bytes=1048576)])]) 03/31/2025 02:30:55.278 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1121 03/31/2025 02:30:55.278 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.278 7f06f9d5eb70 [kafka.conn] [DEBUG]: Response 1121 (641.1254405975342 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=39, last_stable_offset=39, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.393 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 94 03/31/2025 02:30:55.400 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.400 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:55.400 7f06f9c9aa20 [kafka.conn] [DEBUG]: Request 1119: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:55.401 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 20 03/31/2025 02:30:55.402 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.402 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:55.402 7f06f9d26ac8 [kafka.conn] [DEBUG]: Request 1106: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:55.403 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1052 03/31/2025 02:30:55.403 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.403 7f06f9767cc0 [kafka.conn] [DEBUG]: Response 1052 (611.1648082733154 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=69, last_stable_offset=69, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.404 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1097 03/31/2025 02:30:55.404 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.404 7f06fa79f6d8 [kafka.conn] [DEBUG]: Response 1097 (604.0003299713135 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.444 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1155 03/31/2025 02:30:55.444 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.444 7f06f9d7a438 [kafka.conn] [DEBUG]: Response 1155 (601.3343334197998 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.493 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1088 03/31/2025 02:30:55.493 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.493 7f06f97e4e10 [kafka.conn] [DEBUG]: Response 1088 (602.3304462432861 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=207, last_stable_offset=207, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.494 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1149 03/31/2025 02:30:55.494 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.495 7f06f7b24e10 [kafka.conn] [DEBUG]: Response 1149 (602.6792526245117 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.544 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1097 03/31/2025 02:30:55.544 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.544 7f06f9740cc0 [kafka.conn] [DEBUG]: Response 1097 (601.2823581695557 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=197, last_stable_offset=197, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.612 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1136 03/31/2025 02:30:55.612 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.613 7f06fa1c3f60 [kafka.conn] [DEBUG]: Response 1136 (601.4471054077148 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.614 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 285 03/31/2025 02:30:55.614 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.614 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=285, max_bytes=1048576)])]) 03/31/2025 02:30:55.615 7f06f97ea0f0 [kafka.conn] [DEBUG]: Request 1188: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=285, max_bytes=1048576)])]) 03/31/2025 02:30:55.634 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 517 03/31/2025 02:30:55.634 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.634 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:55.635 7f06f9740eb8 [kafka.conn] [DEBUG]: Request 1225: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:55.670 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 19 03/31/2025 02:30:55.670 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.670 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:55.671 7f06f9d5e828 [kafka.conn] [DEBUG]: Request 1111: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:55.694 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 03/31/2025 02:30:55.694 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.694 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.694 7f06fa7a8390 [kafka.conn] [DEBUG]: Request 1100: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.708 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28 03/31/2025 02:30:55.708 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.708 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:55.709 7f06f9c9a978 [kafka.conn] [DEBUG]: Request 1111: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:55.709 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 17 03/31/2025 02:30:55.709 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.709 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:55.710 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Request 1033: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:55.710 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 222 03/31/2025 02:30:55.710 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.710 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:55.711 7f06f9c9ae10 [kafka.conn] [DEBUG]: Request 1143: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:55.711 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45 03/31/2025 02:30:55.711 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.711 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:55.711 7f06f9861e10 [kafka.conn] [DEBUG]: Request 1041: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:55.717 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1103 03/31/2025 02:30:55.717 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.717 7f06f9d7a630 [kafka.conn] [DEBUG]: Response 1103 (601.1431217193604 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.718 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1027 03/31/2025 02:30:55.718 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.719 7f06f9767c18 [kafka.conn] [DEBUG]: Response 1027 (600.916862487793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.719 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 142 03/31/2025 02:30:55.719 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.719 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:55.719 7f06fa1c38d0 [kafka.conn] [DEBUG]: Request 1145: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:55.794 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1026 03/31/2025 02:30:55.794 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.794 7f06f9d5eac8 [kafka.conn] [DEBUG]: Response 1026 (602.0722389221191 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.795 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1130 03/31/2025 02:30:55.795 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.795 7f06fa7a80f0 [kafka.conn] [DEBUG]: Response 1130 (602.1075248718262 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.802 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/31/2025 02:30:55.802 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.802 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.803 7f06f9d268d0 [kafka.conn] [DEBUG]: Request 1101: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:55.803 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 2 03/31/2025 02:30:55.803 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.803 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:55.803 7f06fa7c6f60 [kafka.conn] [DEBUG]: Request 1025: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:55.804 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 13 03/31/2025 02:30:55.804 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.804 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:55.805 7f06f9d26588 [kafka.conn] [DEBUG]: Request 1031: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:55.805 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 03/31/2025 02:30:55.805 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.805 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:55.805 7f06f99790f0 [kafka.conn] [DEBUG]: Request 1033: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:55.806 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 37 03/31/2025 02:30:55.806 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.806 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:55.806 7f06f9c9ab70 [kafka.conn] [DEBUG]: Request 1113: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:55.807 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 32 03/31/2025 02:30:55.807 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.807 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:55.807 7f06f9d26d68 [kafka.conn] [DEBUG]: Request 1039: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:55.878 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1552 03/31/2025 02:30:55.878 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:55.878 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1552 (601.886510848999 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3588, last_stable_offset=3588, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:55.880 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 39 03/31/2025 02:30:55.880 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:55.880 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:55.880 7f06f9d5eb70 [kafka.conn] [DEBUG]: Request 1122: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:56.003 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1119 03/31/2025 02:30:56.003 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.003 7f06f9c9aa20 [kafka.conn] [DEBUG]: Response 1119 (603.2519340515137 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=94, last_stable_offset=94, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.004 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 69 03/31/2025 02:30:56.004 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.004 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:56.004 7f06f9767cc0 [kafka.conn] [DEBUG]: Request 1053: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:56.005 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 03/31/2025 02:30:56.005 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.005 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:56.005 7f06fa79f6d8 [kafka.conn] [DEBUG]: Request 1098: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:56.006 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1106 03/31/2025 02:30:56.006 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.006 7f06f9d26ac8 [kafka.conn] [DEBUG]: Response 1106 (604.0244102478027 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.047 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 198 03/31/2025 02:30:56.047 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.047 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:56.047 7f06f9d7a438 [kafka.conn] [DEBUG]: Request 1156: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:56.095 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 207 03/31/2025 02:30:56.095 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.096 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:56.096 7f06f97e4e10 [kafka.conn] [DEBUG]: Request 1089: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:56.096 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 162 03/31/2025 02:30:56.097 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.097 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:56.097 7f06f7b24e10 [kafka.conn] [DEBUG]: Request 1150: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:56.151 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 197 03/31/2025 02:30:56.151 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.151 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:56.151 7f06f9740cc0 [kafka.conn] [DEBUG]: Request 1098: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:56.213 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 03/31/2025 02:30:56.214 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.214 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:56.214 7f06fa1c3f60 [kafka.conn] [DEBUG]: Request 1137: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:56.215 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1188 03/31/2025 02:30:56.216 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.216 7f06f97ea0f0 [kafka.conn] [DEBUG]: Response 1188 (601.121187210083 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=285, last_stable_offset=285, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.236 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1225 03/31/2025 02:30:56.236 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.236 7f06f9740eb8 [kafka.conn] [DEBUG]: Response 1225 (601.466178894043 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=517, last_stable_offset=517, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.272 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1111 03/31/2025 02:30:56.272 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.272 7f06f9d5e828 [kafka.conn] [DEBUG]: Response 1111 (601.5415191650391 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.296 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1100 03/31/2025 02:30:56.296 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.296 7f06fa7a8390 [kafka.conn] [DEBUG]: Response 1100 (602.1058559417725 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.310 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1111 03/31/2025 02:30:56.311 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.311 7f06f9c9a978 [kafka.conn] [DEBUG]: Response 1111 (602.1125316619873 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.311 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1033 03/31/2025 02:30:56.311 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.312 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Response 1033 (601.9902229309082 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.312 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1143 03/31/2025 02:30:56.312 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.312 7f06f9c9ae10 [kafka.conn] [DEBUG]: Response 1143 (601.9344329833984 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=222, last_stable_offset=222, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.313 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1041 03/31/2025 02:30:56.313 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.313 7f06f9861e10 [kafka.conn] [DEBUG]: Response 1041 (601.6764640808105 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.318 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:56.318 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.318 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:56.319 7f06f9d7a630 [kafka.conn] [DEBUG]: Request 1104: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:56.319 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6 03/31/2025 02:30:56.319 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.319 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:56.319 7f06f9767c18 [kafka.conn] [DEBUG]: Request 1028: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:56.320 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1145 03/31/2025 02:30:56.320 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.320 7f06fa1c38d0 [kafka.conn] [DEBUG]: Response 1145 (600.9910106658936 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=142, last_stable_offset=142, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.395 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 03/31/2025 02:30:56.395 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.395 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:56.396 7f06f9d5eac8 [kafka.conn] [DEBUG]: Request 1027: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:56.396 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 96 03/31/2025 02:30:56.396 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.396 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:56.396 7f06fa7a80f0 [kafka.conn] [DEBUG]: Request 1131: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:56.404 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1101 03/31/2025 02:30:56.404 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.404 7f06f9d268d0 [kafka.conn] [DEBUG]: Response 1101 (601.8269062042236 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.405 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1025 03/31/2025 02:30:56.405 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.405 7f06fa7c6f60 [kafka.conn] [DEBUG]: Response 1025 (601.8466949462891 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.406 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1031 03/31/2025 02:30:56.406 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.406 7f06f9d26588 [kafka.conn] [DEBUG]: Response 1031 (601.6221046447754 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.407 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1033 03/31/2025 02:30:56.407 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.407 7f06f99790f0 [kafka.conn] [DEBUG]: Response 1033 (601.6721725463867 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.407 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1113 03/31/2025 02:30:56.408 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.408 7f06f9c9ab70 [kafka.conn] [DEBUG]: Response 1113 (601.5799045562744 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.408 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1039 03/31/2025 02:30:56.408 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.408 7f06f9d26d68 [kafka.conn] [DEBUG]: Response 1039 (601.4077663421631 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.479 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3588 03/31/2025 02:30:56.479 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.479 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3588, max_bytes=1048576)])]) 03/31/2025 02:30:56.480 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1553: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3588, max_bytes=1048576)])]) 03/31/2025 02:30:56.481 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1122 03/31/2025 02:30:56.481 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.481 7f06f9d5eb70 [kafka.conn] [DEBUG]: Response 1122 (600.9750366210938 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=39, last_stable_offset=39, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.605 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 94 03/31/2025 02:30:56.606 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.606 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:56.606 7f06f9c9aa20 [kafka.conn] [DEBUG]: Request 1120: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:56.607 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1053 03/31/2025 02:30:56.607 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.607 7f06f9767cc0 [kafka.conn] [DEBUG]: Response 1053 (602.4980545043945 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=69, last_stable_offset=69, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.608 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 20 03/31/2025 02:30:56.608 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.608 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:56.608 7f06f9d26ac8 [kafka.conn] [DEBUG]: Request 1107: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:56.608 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1098 03/31/2025 02:30:56.609 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.609 7f06fa79f6d8 [kafka.conn] [DEBUG]: Response 1098 (603.5308837890625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.652 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1156 03/31/2025 02:30:56.652 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.652 7f06f9d7a438 [kafka.conn] [DEBUG]: Response 1156 (605.1054000854492 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.698 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1089 03/31/2025 02:30:56.698 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.698 7f06f97e4e10 [kafka.conn] [DEBUG]: Response 1089 (602.5571823120117 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=207, last_stable_offset=207, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.699 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1150 03/31/2025 02:30:56.699 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.699 7f06f7b24e10 [kafka.conn] [DEBUG]: Response 1150 (602.1268367767334 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.753 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1098 03/31/2025 02:30:56.753 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.753 7f06f9740cc0 [kafka.conn] [DEBUG]: Response 1098 (601.7022132873535 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=197, last_stable_offset=197, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.815 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1137 03/31/2025 02:30:56.815 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.816 7f06fa1c3f60 [kafka.conn] [DEBUG]: Response 1137 (601.4354228973389 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.817 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 285 03/31/2025 02:30:56.817 7f06f97ea0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.817 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=285, max_bytes=1048576)])]) 03/31/2025 02:30:56.818 7f06f97ea0f0 [kafka.conn] [DEBUG]: Request 1189: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=285, max_bytes=1048576)])]) 03/31/2025 02:30:56.837 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 517 03/31/2025 02:30:56.837 7f06f9740eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.837 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:56.838 7f06f9740eb8 [kafka.conn] [DEBUG]: Request 1226: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=517, max_bytes=1048576)])]) 03/31/2025 02:30:56.873 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 19 03/31/2025 02:30:56.873 7f06f9d5e828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.874 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:56.874 7f06f9d5e828 [kafka.conn] [DEBUG]: Request 1112: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 03/31/2025 02:30:56.897 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 03/31/2025 02:30:56.897 7f06fa7a8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.897 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:56.898 7f06fa7a8390 [kafka.conn] [DEBUG]: Request 1101: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:56.911 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28 03/31/2025 02:30:56.912 7f06f9c9a978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.912 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:56.912 7f06f9c9a978 [kafka.conn] [DEBUG]: Request 1112: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])]) 03/31/2025 02:30:56.912 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 17 03/31/2025 02:30:56.912 7f06f9d5e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.912 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:56.913 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Request 1034: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/31/2025 02:30:56.913 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 222 03/31/2025 02:30:56.913 7f06f9c9ae10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.913 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:56.914 7f06f9c9ae10 [kafka.conn] [DEBUG]: Request 1144: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=222, max_bytes=1048576)])]) 03/31/2025 02:30:56.914 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45 03/31/2025 02:30:56.914 7f06f9861e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.914 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:56.914 7f06f9861e10 [kafka.conn] [DEBUG]: Request 1042: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 03/31/2025 02:30:56.919 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1104 03/31/2025 02:30:56.919 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.919 7f06f9d7a630 [kafka.conn] [DEBUG]: Response 1104 (601.0072231292725 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.920 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1028 03/31/2025 02:30:56.920 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.920 7f06f9767c18 [kafka.conn] [DEBUG]: Response 1028 (600.825309753418 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.921 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 142 03/31/2025 02:30:56.921 7f06fa1c38d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:56.921 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:56.921 7f06fa1c38d0 [kafka.conn] [DEBUG]: Request 1146: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=142, max_bytes=1048576)])]) 03/31/2025 02:30:56.997 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1027 03/31/2025 02:30:56.997 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.998 7f06f9d5eac8 [kafka.conn] [DEBUG]: Response 1027 (602.0536422729492 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:56.998 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1131 03/31/2025 02:30:56.998 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:56.998 7f06fa7a80f0 [kafka.conn] [DEBUG]: Response 1131 (601.9654273986816 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.005 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/31/2025 02:30:57.005 7f06f9d268d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.006 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:57.006 7f06f9d268d0 [kafka.conn] [DEBUG]: Request 1102: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:57.006 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 2 03/31/2025 02:30:57.007 7f06fa7c6f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.007 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:57.007 7f06fa7c6f60 [kafka.conn] [DEBUG]: Request 1026: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 03/31/2025 02:30:57.068 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 13 03/31/2025 02:30:57.068 7f06f9d26588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.068 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:57.068 7f06f9d26588 [kafka.conn] [DEBUG]: Request 1032: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:57.069 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 03/31/2025 02:30:57.069 7f06f99790f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.069 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:57.069 7f06f99790f0 [kafka.conn] [DEBUG]: Request 1034: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 03/31/2025 02:30:57.070 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 37 03/31/2025 02:30:57.070 7f06f9c9ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.070 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:57.070 7f06f9c9ab70 [kafka.conn] [DEBUG]: Request 1114: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 03/31/2025 02:30:57.071 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 32 03/31/2025 02:30:57.071 7f06f9d26d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.071 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:57.071 7f06f9d26d68 [kafka.conn] [DEBUG]: Request 1040: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 03/31/2025 02:30:57.081 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1553 03/31/2025 02:30:57.081 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.081 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1553 (601.5164852142334 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3588, last_stable_offset=3588, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.083 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 39 03/31/2025 02:30:57.083 7f06f9d5eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.083 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:57.084 7f06f9d5eb70 [kafka.conn] [DEBUG]: Request 1123: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=39, max_bytes=1048576)])]) 03/31/2025 02:30:57.207 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1120 03/31/2025 02:30:57.207 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.207 7f06f9c9aa20 [kafka.conn] [DEBUG]: Response 1120 (601.3650894165039 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=94, last_stable_offset=94, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.208 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 69 03/31/2025 02:30:57.208 7f06f9767cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.208 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:57.208 7f06f9767cc0 [kafka.conn] [DEBUG]: Request 1054: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=69, max_bytes=1048576)])]) 03/31/2025 02:30:57.209 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1107 03/31/2025 02:30:57.209 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.209 7f06f9d26ac8 [kafka.conn] [DEBUG]: Response 1107 (601.1946201324463 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.209 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 03/31/2025 02:30:57.210 7f06fa79f6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.210 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:57.210 7f06fa79f6d8 [kafka.conn] [DEBUG]: Request 1099: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 03/31/2025 02:30:57.255 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 198 03/31/2025 02:30:57.255 7f06f9d7a438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.255 7f06f9d7a438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:57.256 7f06f9d7a438 [kafka.conn] [DEBUG]: Request 1157: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/31/2025 02:30:57.300 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 207 03/31/2025 02:30:57.300 7f06f97e4e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.300 7f06f97e4e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:57.300 7f06f97e4e10 [kafka.conn] [DEBUG]: Request 1090: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=207, max_bytes=1048576)])]) 03/31/2025 02:30:57.301 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 162 03/31/2025 02:30:57.301 7f06f7b24e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.301 7f06f7b24e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:57.301 7f06f7b24e10 [kafka.conn] [DEBUG]: Request 1151: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=162, max_bytes=1048576)])]) 03/31/2025 02:30:57.354 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 197 03/31/2025 02:30:57.354 7f06f9740cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.354 7f06f9740cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:57.354 7f06f9740cc0 [kafka.conn] [DEBUG]: Request 1099: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=197, max_bytes=1048576)])]) 03/31/2025 02:30:57.416 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 03/31/2025 02:30:57.416 7f06fa1c3f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.417 7f06fa1c3f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:57.417 7f06fa1c3f60 [kafka.conn] [DEBUG]: Request 1138: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 03/31/2025 02:30:57.418 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1189 03/31/2025 02:30:57.418 7f06f97ea0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.419 7f06f97ea0f0 [kafka.conn] [DEBUG]: Response 1189 (601.020097732544 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=285, last_stable_offset=285, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.439 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1226 03/31/2025 02:30:57.439 7f06f9740eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.439 7f06f9740eb8 [kafka.conn] [DEBUG]: Response 1226 (601.513147354126 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=517, last_stable_offset=517, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.476 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1112 03/31/2025 02:30:57.476 7f06f9d5e828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.476 7f06f9d5e828 [kafka.conn] [DEBUG]: Response 1112 (602.1125316619873 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.499 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1101 03/31/2025 02:30:57.499 7f06fa7a8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.499 7f06fa7a8390 [kafka.conn] [DEBUG]: Response 1101 (601.8416881561279 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.572 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1112 03/31/2025 02:30:57.572 7f06f9c9a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.572 7f06f9c9a978 [kafka.conn] [DEBUG]: Response 1112 (660.167932510376 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.573 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:57.573 7f06f9d7a630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.573 7f06f9d7a630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:57.573 7f06f9d7a630 [kafka.conn] [DEBUG]: Request 1105: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:57.573 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 6 03/31/2025 02:30:57.574 7f06f9767c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.574 7f06f9767c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:57.574 7f06f9767c18 [kafka.conn] [DEBUG]: Request 1029: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/31/2025 02:30:57.574 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1034 03/31/2025 02:30:57.574 7f06f9d5e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.575 7f06f9d5e0f0 [kafka.conn] [DEBUG]: Response 1034 (661.9048118591309 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.575 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1144 03/31/2025 02:30:57.575 7f06f9c9ae10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.575 7f06f9c9ae10 [kafka.conn] [DEBUG]: Response 1144 (661.6835594177246 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=222, last_stable_offset=222, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.576 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1042 03/31/2025 02:30:57.576 7f06f9861e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.576 7f06f9861e10 [kafka.conn] [DEBUG]: Response 1042 (661.5109443664551 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.576 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1146 03/31/2025 02:30:57.576 7f06fa1c38d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.576 7f06fa1c38d0 [kafka.conn] [DEBUG]: Response 1146 (655.2927494049072 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=142, last_stable_offset=142, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.599 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 03/31/2025 02:30:57.599 7f06f9d5eac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.599 7f06f9d5eac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:57.600 7f06f9d5eac8 [kafka.conn] [DEBUG]: Request 1028: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/31/2025 02:30:57.600 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 96 03/31/2025 02:30:57.601 7f06fa7a80f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.601 7f06fa7a80f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:57.601 7f06fa7a80f0 [kafka.conn] [DEBUG]: Request 1132: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=96, max_bytes=1048576)])]) 03/31/2025 02:30:57.607 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1102 03/31/2025 02:30:57.608 7f06f9d268d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.608 7f06f9d268d0 [kafka.conn] [DEBUG]: Response 1102 (602.0755767822266 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.672 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1026 03/31/2025 02:30:57.673 7f06fa7c6f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.673 7f06fa7c6f60 [kafka.conn] [DEBUG]: Response 1026 (665.8129692077637 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.674 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1032 03/31/2025 02:30:57.674 7f06f9d26588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.674 7f06f9d26588 [kafka.conn] [DEBUG]: Response 1032 (605.8053970336914 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.675 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1034 03/31/2025 02:30:57.675 7f06f99790f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.675 7f06f99790f0 [kafka.conn] [DEBUG]: Response 1034 (605.6125164031982 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.675 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1114 03/31/2025 02:30:57.675 7f06f9c9ab70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.675 7f06f9c9ab70 [kafka.conn] [DEBUG]: Response 1114 (605.377197265625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.676 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1040 03/31/2025 02:30:57.676 7f06f9d26d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.676 7f06f9d26d68 [kafka.conn] [DEBUG]: Response 1040 (605.1747798919678 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.682 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3588 03/31/2025 02:30:57.682 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.682 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3588, max_bytes=1048576)])]) 03/31/2025 02:30:57.683 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1554: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3588, max_bytes=1048576)])]) 03/31/2025 02:30:57.683 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1554 03/31/2025 02:30:57.684 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.684 7f06fa19d390 [kafka.conn] [DEBUG]: Response 1554 (1.2176036834716797 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3589, last_stable_offset=3589, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0e\x04\x00\x00\x00\xfe\x00\x00\x00\x00\x02\xc1p\xcb$\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\x96\x03\x00\x00\x00\xd8\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/31/2025 02:30:57.684 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3588 to buffered record list 03/31/2025 02:30:57.685 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1123 03/31/2025 02:30:57.685 7f06f9d5eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.685 7f06f9d5eb70 [kafka.conn] [DEBUG]: Response 1123 (601.6106605529785 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=39, last_stable_offset=39, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.785 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3589 03/31/2025 02:30:57.785 7f06fa19d390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.785 7f06fa19d390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3589, max_bytes=1048576)])]) 03/31/2025 02:30:57.786 7f06fa19d390 [kafka.conn] [DEBUG]: Request 1555: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=3589, max_bytes=1048576)])]) 03/31/2025 02:30:57.809 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 94 03/31/2025 02:30:57.809 7f06f9c9aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.809 7f06f9c9aa20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:57.810 7f06f9c9aa20 [kafka.conn] [DEBUG]: Request 1121: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=94, max_bytes=1048576)])]) 03/31/2025 02:30:57.811 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 20 03/31/2025 02:30:57.811 7f06f9d26ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:57.811 7f06f9d26ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:57.811 7f06f9d26ac8 [kafka.conn] [DEBUG]: Request 1108: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 03/31/2025 02:30:57.812 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1054 03/31/2025 02:30:57.812 7f06f9767cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.812 7f06f9767cc0 [kafka.conn] [DEBUG]: Response 1054 (604.0327548980713 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=69, last_stable_offset=69, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:57.813 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1099 03/31/2025 02:30:57.813 7f06fa79f6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:57.813 7f06fa79f6d8 [kafka.conn] [DEBUG]: Response 1099 (603.238582611084 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])])