03/31/2025 02:30:24.799 7f45299668d0 [kafka.conn] [DEBUG]: Response 792 (601.0787487030029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2375, last_stable_offset=2375, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:24.888 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 500 03/31/2025 02:30:24.889 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:24.889 7f45299690f0 [kafka.conn] [DEBUG]: Response 500 (602.4940013885498 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:24.889 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 88 03/31/2025 02:30:24.889 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:24.889 7f45298cca20 [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=88, max_bytes=1048576)])]) 03/31/2025 02:30:24.890 7f45298cca20 [kafka.conn] [DEBUG]: Request 528: 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=88, max_bytes=1048576)])]) 03/31/2025 02:30:24.890 7f4529966048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 500 03/31/2025 02:30:24.890 7f4529966048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:24.890 7f4529966048 [kafka.conn] [DEBUG]: Response 500 (603.3146381378174 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:24.891 7f4529974828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/31/2025 02:30:24.891 7f4529974828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:24.891 7f4529974828 [kafka.conn] [DEBUG]: Response 504 (603.363037109375 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:24.901 7f4529969240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/31/2025 02:30:24.901 7f4529969240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:24.901 7f4529969240 [kafka.conn] [DEBUG]: Response 508 (601.0160446166992 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:24.972 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121 03/31/2025 02:30:24.972 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:24.972 7f45298cc4e0 [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=121, max_bytes=1048576)])]) 03/31/2025 02:30:24.973 7f45298cc4e0 [kafka.conn] [DEBUG]: Request 544: 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=121, max_bytes=1048576)])]) 03/31/2025 02:30:24.973 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 50 03/31/2025 02:30:24.973 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:24.973 7f4527fa5cc0 [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=50, max_bytes=1048576)])]) 03/31/2025 02:30:24.974 7f4527fa5cc0 [kafka.conn] [DEBUG]: Request 516: 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=50, max_bytes=1048576)])]) 03/31/2025 02:30:24.974 7f4529932978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 03/31/2025 02:30:24.974 7f4529932978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:24.974 7f4529932978 [kafka.conn] [DEBUG]: Response 522 (602.11181640625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:24.988 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 356 03/31/2025 02:30:24.988 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:24.988 7f4527fa5f60 [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=356, max_bytes=1048576)])]) 03/31/2025 02:30:24.988 7f4527fa5f60 [kafka.conn] [DEBUG]: Request 564: 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=356, max_bytes=1048576)])]) 03/31/2025 02:30:25.010 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 171 03/31/2025 02:30:25.011 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.011 7f4527fab198 [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=171, max_bytes=1048576)])]) 03/31/2025 02:30:25.011 7f4527fab198 [kafka.conn] [DEBUG]: Request 536: 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=171, max_bytes=1048576)])]) 03/31/2025 02:30:25.110 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 03/31/2025 02:30:25.110 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.111 7f45298b0198 [kafka.conn] [DEBUG]: Response 516 (601.3438701629639 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.164 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 28 03/31/2025 02:30:25.164 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.164 7f45297a0d68 [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=28, max_bytes=1048576)])]) 03/31/2025 02:30:25.164 7f45297a0d68 [kafka.conn] [DEBUG]: Request 511: 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=28, max_bytes=1048576)])]) 03/31/2025 02:30:25.165 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/31/2025 02:30:25.165 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.165 7f4529770cc0 [kafka.conn] [DEBUG]: Response 508 (601.6263961791992 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.166 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/31/2025 02:30:25.166 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.166 7f45297aa630 [kafka.conn] [DEBUG]: Response 504 (601.7298698425293 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.167 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/31/2025 02:30:25.167 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.167 7f4529770d68 [kafka.conn] [DEBUG]: Response 509 (601.6409397125244 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.167 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31 03/31/2025 02:30:25.167 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.168 7f45299324e0 [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=31, max_bytes=1048576)])]) 03/31/2025 02:30:25.168 7f45299324e0 [kafka.conn] [DEBUG]: Request 508: 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=31, max_bytes=1048576)])]) 03/31/2025 02:30:25.168 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 03/31/2025 02:30:25.168 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.168 7f45298cce10 [kafka.conn] [DEBUG]: Response 530 (602.2751331329346 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=133, last_stable_offset=133, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.190 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 221 03/31/2025 02:30:25.191 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.191 7f45298b04e0 [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=221, max_bytes=1048576)])]) 03/31/2025 02:30:25.191 7f45298b04e0 [kafka.conn] [DEBUG]: Request 552: 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=221, max_bytes=1048576)])]) 03/31/2025 02:30:25.216 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 03/31/2025 02:30:25.216 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.216 7f4529932cc0 [kafka.conn] [DEBUG]: Response 540 (601.1049747467041 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=199, last_stable_offset=199, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.283 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 523 03/31/2025 02:30:25.284 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.284 7f45298cc8d0 [kafka.conn] [DEBUG]: Response 523 (602.4785041809082 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.285 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/31/2025 02:30:25.285 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.285 7f45297aa0f0 [kafka.conn] [DEBUG]: Response 502 (603.0187606811523 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.286 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:25.286 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.286 7f4529770eb8 [kafka.conn] [DEBUG]: Response 506 (603.2693386077881 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.287 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 03/31/2025 02:30:25.287 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.287 7f45297aa8d0 [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=2, max_bytes=1048576)])]) 03/31/2025 02:30:25.287 7f45297aa8d0 [kafka.conn] [DEBUG]: Request 502: 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=2, max_bytes=1048576)])]) 03/31/2025 02:30:25.288 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 11 03/31/2025 02:30:25.288 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.288 7f4529d236d8 [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=11, max_bytes=1048576)])]) 03/31/2025 02:30:25.289 7f4529d236d8 [kafka.conn] [DEBUG]: Request 504: 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=11, max_bytes=1048576)])]) 03/31/2025 02:30:25.311 7f45297aa390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 03/31/2025 02:30:25.311 7f45297aa390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.312 7f45297aa390 [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=5, max_bytes=1048576)])]) 03/31/2025 02:30:25.312 7f45297aa390 [kafka.conn] [DEBUG]: Request 504: 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=5, max_bytes=1048576)])]) 03/31/2025 02:30:25.314 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 533 03/31/2025 02:30:25.315 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.315 7f4529140a20 [kafka.conn] [DEBUG]: Response 533 (601.4726161956787 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=153, last_stable_offset=153, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.392 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/31/2025 02:30:25.392 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.392 7f452996dc18 [kafka.conn] [DEBUG]: Response 519 (603.3546924591064 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=83, last_stable_offset=83, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.392 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 116 03/31/2025 02:30:25.393 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.393 7f4529969b70 [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=116, max_bytes=1048576)])]) 03/31/2025 02:30:25.393 7f4529969b70 [kafka.conn] [DEBUG]: Request 526: 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=116, max_bytes=1048576)])]) 03/31/2025 02:30:25.394 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:25.394 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.394 7f4529d3de10 [kafka.conn] [DEBUG]: Response 506 (604.7029495239258 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.399 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2375 03/31/2025 02:30:25.400 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.400 7f45299668d0 [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=2375, max_bytes=1048576)])]) 03/31/2025 02:30:25.400 7f45299668d0 [kafka.conn] [DEBUG]: Request 793: 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=2375, max_bytes=1048576)])]) 03/31/2025 02:30:25.490 7f45299690f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 03/31/2025 02:30:25.490 7f45299690f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.490 7f45299690f0 [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=0, max_bytes=1048576)])]) 03/31/2025 02:30:25.491 7f45299690f0 [kafka.conn] [DEBUG]: Request 501: 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=0, max_bytes=1048576)])]) 03/31/2025 02:30:25.491 7f4529966048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:25.491 7f4529966048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.491 7f4529966048 [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:25.492 7f4529966048 [kafka.conn] [DEBUG]: Request 501: 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:25.492 7f4529974828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 13 03/31/2025 02:30:25.492 7f4529974828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.492 7f4529974828 [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=13, max_bytes=1048576)])]) 03/31/2025 02:30:25.493 7f4529974828 [kafka.conn] [DEBUG]: Request 505: 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=13, max_bytes=1048576)])]) 03/31/2025 02:30:25.493 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 03/31/2025 02:30:25.493 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.493 7f45298cca20 [kafka.conn] [DEBUG]: Response 528 (603.924036026001 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=88, last_stable_offset=88, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.502 7f4529969240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 19 03/31/2025 02:30:25.503 7f4529969240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.503 7f4529969240 [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=19, max_bytes=1048576)])]) 03/31/2025 02:30:25.503 7f4529969240 [kafka.conn] [DEBUG]: Request 509: 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=19, max_bytes=1048576)])]) 03/31/2025 02:30:25.574 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 544 03/31/2025 02:30:25.574 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.574 7f45298cc4e0 [kafka.conn] [DEBUG]: Response 544 (601.3987064361572 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=121, last_stable_offset=121, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.575 7f4527fa5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 03/31/2025 02:30:25.575 7f4527fa5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.575 7f4527fa5cc0 [kafka.conn] [DEBUG]: Response 516 (601.2625694274902 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=50, last_stable_offset=50, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.575 7f4529932978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 96 03/31/2025 02:30:25.575 7f4529932978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.575 7f4529932978 [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=96, max_bytes=1048576)])]) 03/31/2025 02:30:25.576 7f4529932978 [kafka.conn] [DEBUG]: Request 523: 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=96, max_bytes=1048576)])]) 03/31/2025 02:30:25.589 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 564 03/31/2025 02:30:25.589 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.589 7f4527fa5f60 [kafka.conn] [DEBUG]: Response 564 (601.050853729248 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=356, last_stable_offset=356, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.612 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 03/31/2025 02:30:25.612 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.612 7f4527fab198 [kafka.conn] [DEBUG]: Response 536 (601.1590957641602 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.711 7f45298b0198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 57 03/31/2025 02:30:25.712 7f45298b0198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.712 7f45298b0198 [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=57, max_bytes=1048576)])]) 03/31/2025 02:30:25.712 7f45298b0198 [kafka.conn] [DEBUG]: Request 517: 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=57, max_bytes=1048576)])]) 03/31/2025 02:30:25.765 7f45297a0d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/31/2025 02:30:25.765 7f45297a0d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.766 7f45297a0d68 [kafka.conn] [DEBUG]: Response 511 (601.3436317443848 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.766 7f4529770cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 32 03/31/2025 02:30:25.766 7f4529770cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.766 7f4529770cc0 [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=32, max_bytes=1048576)])]) 03/31/2025 02:30:25.767 7f4529770cc0 [kafka.conn] [DEBUG]: Request 509: 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=32, max_bytes=1048576)])]) 03/31/2025 02:30:25.767 7f45297aa630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 11 03/31/2025 02:30:25.767 7f45297aa630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.767 7f45297aa630 [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=11, max_bytes=1048576)])]) 03/31/2025 02:30:25.767 7f45297aa630 [kafka.conn] [DEBUG]: Request 505: 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=11, max_bytes=1048576)])]) 03/31/2025 02:30:25.768 7f4529770d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 32 03/31/2025 02:30:25.768 7f4529770d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.768 7f4529770d68 [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=32, max_bytes=1048576)])]) 03/31/2025 02:30:25.768 7f4529770d68 [kafka.conn] [DEBUG]: Request 510: 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=32, max_bytes=1048576)])]) 03/31/2025 02:30:25.768 7f45299324e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/31/2025 02:30:25.769 7f45299324e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.769 7f45299324e0 [kafka.conn] [DEBUG]: Response 508 (600.9774208068848 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.769 7f45298cce10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 133 03/31/2025 02:30:25.769 7f45298cce10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.769 7f45298cce10 [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=133, max_bytes=1048576)])]) 03/31/2025 02:30:25.769 7f45298cce10 [kafka.conn] [DEBUG]: Request 531: 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=133, max_bytes=1048576)])]) 03/31/2025 02:30:25.792 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 552 03/31/2025 02:30:25.792 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.792 7f45298b04e0 [kafka.conn] [DEBUG]: Response 552 (601.2697219848633 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=221, last_stable_offset=221, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.817 7f4529932cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 199 03/31/2025 02:30:25.817 7f4529932cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.817 7f4529932cc0 [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=199, max_bytes=1048576)])]) 03/31/2025 02:30:25.818 7f4529932cc0 [kafka.conn] [DEBUG]: Request 541: 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=199, max_bytes=1048576)])]) 03/31/2025 02:30:25.885 7f45298cc8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 100 03/31/2025 02:30:25.885 7f45298cc8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.885 7f45298cc8d0 [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=100, max_bytes=1048576)])]) 03/31/2025 02:30:25.885 7f45298cc8d0 [kafka.conn] [DEBUG]: Request 524: 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=100, max_bytes=1048576)])]) 03/31/2025 02:30:25.886 7f45297aa0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 03/31/2025 02:30:25.886 7f45297aa0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.886 7f45297aa0f0 [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=4, max_bytes=1048576)])]) 03/31/2025 02:30:25.886 7f45297aa0f0 [kafka.conn] [DEBUG]: Request 503: 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=4, max_bytes=1048576)])]) 03/31/2025 02:30:25.887 7f4529770eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 18 03/31/2025 02:30:25.887 7f4529770eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.887 7f4529770eb8 [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=18, max_bytes=1048576)])]) 03/31/2025 02:30:25.887 7f4529770eb8 [kafka.conn] [DEBUG]: Request 507: 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=18, max_bytes=1048576)])]) 03/31/2025 02:30:25.889 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/31/2025 02:30:25.889 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.889 7f45297aa8d0 [kafka.conn] [DEBUG]: Response 502 (601.9954681396484 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.890 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/31/2025 02:30:25.890 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.890 7f4529d236d8 [kafka.conn] [DEBUG]: Response 504 (601.5162467956543 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.913 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/31/2025 02:30:25.913 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.913 7f45297aa390 [kafka.conn] [DEBUG]: Response 504 (601.4294624328613 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:25.915 7f4529140a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 153 03/31/2025 02:30:25.916 7f4529140a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.916 7f4529140a20 [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=153, max_bytes=1048576)])]) 03/31/2025 02:30:25.916 7f4529140a20 [kafka.conn] [DEBUG]: Request 534: 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=153, max_bytes=1048576)])]) 03/31/2025 02:30:25.993 7f452996dc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 83 03/31/2025 02:30:25.993 7f452996dc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.994 7f452996dc18 [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=83, max_bytes=1048576)])]) 03/31/2025 02:30:25.994 7f452996dc18 [kafka.conn] [DEBUG]: Request 520: 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=83, max_bytes=1048576)])]) 03/31/2025 02:30:25.994 7f4529d3de10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 19 03/31/2025 02:30:25.995 7f4529d3de10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:25.995 7f4529d3de10 [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=19, max_bytes=1048576)])]) 03/31/2025 02:30:25.995 7f4529d3de10 [kafka.conn] [DEBUG]: Request 507: 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=19, max_bytes=1048576)])]) 03/31/2025 02:30:25.996 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 526 03/31/2025 02:30:25.996 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:25.996 7f4529969b70 [kafka.conn] [DEBUG]: Response 526 (602.8382778167725 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=116, last_stable_offset=116, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.001 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 793 03/31/2025 02:30:26.001 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.001 7f45299668d0 [kafka.conn] [DEBUG]: Response 793 (601.207971572876 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2376, last_stable_offset=2376, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\tG\x00\x00\x01\x04\x00\x00\x00\x00\x02Uq\x1d\xea\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/31/2025 02:30:26.001 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2375 to buffered record list 03/31/2025 02:30:26.092 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 03/31/2025 02:30:26.092 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.092 7f45299690f0 [kafka.conn] [DEBUG]: Response 501 (601.4115810394287 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.093 7f4529966048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 03/31/2025 02:30:26.093 7f4529966048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.093 7f4529966048 [kafka.conn] [DEBUG]: Response 501 (601.6278266906738 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:26.094 7f4529974828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/31/2025 02:30:26.094 7f4529974828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.094 7f4529974828 [kafka.conn] [DEBUG]: Response 505 (601.405143737793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.094 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 88 03/31/2025 02:30:26.094 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.094 7f45298cca20 [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=88, max_bytes=1048576)])]) 03/31/2025 02:30:26.095 7f45298cca20 [kafka.conn] [DEBUG]: Request 529: 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=88, max_bytes=1048576)])]) 03/31/2025 02:30:26.102 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2376 03/31/2025 02:30:26.102 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.102 7f45299668d0 [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=2376, max_bytes=1048576)])]) 03/31/2025 02:30:26.102 7f45299668d0 [kafka.conn] [DEBUG]: Request 794: 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=2376, max_bytes=1048576)])]) 03/31/2025 02:30:26.103 7f4529969240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/31/2025 02:30:26.104 7f4529969240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.104 7f4529969240 [kafka.conn] [DEBUG]: Response 509 (600.8436679840088 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.175 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121 03/31/2025 02:30:26.175 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.175 7f45298cc4e0 [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=121, max_bytes=1048576)])]) 03/31/2025 02:30:26.175 7f45298cc4e0 [kafka.conn] [DEBUG]: Request 545: 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=121, max_bytes=1048576)])]) 03/31/2025 02:30:26.176 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 50 03/31/2025 02:30:26.176 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.176 7f4527fa5cc0 [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=50, max_bytes=1048576)])]) 03/31/2025 02:30:26.176 7f4527fa5cc0 [kafka.conn] [DEBUG]: Request 517: 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=50, max_bytes=1048576)])]) 03/31/2025 02:30:26.177 7f4529932978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 523 03/31/2025 02:30:26.177 7f4529932978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.177 7f4529932978 [kafka.conn] [DEBUG]: Response 523 (601.4077663421631 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.190 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 356 03/31/2025 02:30:26.190 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.190 7f4527fa5f60 [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=356, max_bytes=1048576)])]) 03/31/2025 02:30:26.190 7f4527fa5f60 [kafka.conn] [DEBUG]: Request 565: 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=356, max_bytes=1048576)])]) 03/31/2025 02:30:26.213 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 171 03/31/2025 02:30:26.213 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.213 7f4527fab198 [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=171, max_bytes=1048576)])]) 03/31/2025 02:30:26.214 7f4527fab198 [kafka.conn] [DEBUG]: Request 537: 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=171, max_bytes=1048576)])]) 03/31/2025 02:30:26.313 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 03/31/2025 02:30:26.313 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.313 7f45298b0198 [kafka.conn] [DEBUG]: Response 517 (601.3548374176025 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.366 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 28 03/31/2025 02:30:26.367 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.367 7f45297a0d68 [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=28, max_bytes=1048576)])]) 03/31/2025 02:30:26.367 7f45297a0d68 [kafka.conn] [DEBUG]: Request 512: 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=28, max_bytes=1048576)])]) 03/31/2025 02:30:26.368 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/31/2025 02:30:26.368 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.368 7f4529770cc0 [kafka.conn] [DEBUG]: Response 509 (601.5489101409912 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.368 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/31/2025 02:30:26.369 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.369 7f45297aa630 [kafka.conn] [DEBUG]: Response 505 (601.5889644622803 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.369 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/31/2025 02:30:26.369 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.369 7f4529770d68 [kafka.conn] [DEBUG]: Response 510 (601.447343826294 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.370 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31 03/31/2025 02:30:26.370 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.370 7f45299324e0 [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=31, max_bytes=1048576)])]) 03/31/2025 02:30:26.370 7f45299324e0 [kafka.conn] [DEBUG]: Request 509: 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=31, max_bytes=1048576)])]) 03/31/2025 02:30:26.371 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 531 03/31/2025 02:30:26.371 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.371 7f45298cce10 [kafka.conn] [DEBUG]: Response 531 (601.3498306274414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=133, last_stable_offset=133, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.393 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 221 03/31/2025 02:30:26.393 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.393 7f45298b04e0 [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=221, max_bytes=1048576)])]) 03/31/2025 02:30:26.393 7f45298b04e0 [kafka.conn] [DEBUG]: Request 553: 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=221, max_bytes=1048576)])]) 03/31/2025 02:30:26.418 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 03/31/2025 02:30:26.419 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.419 7f4529932cc0 [kafka.conn] [DEBUG]: Response 541 (601.2210845947266 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=199, last_stable_offset=199, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.486 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 524 03/31/2025 02:30:26.486 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.487 7f45298cc8d0 [kafka.conn] [DEBUG]: Response 524 (601.3333797454834 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.488 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/31/2025 02:30:26.488 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.488 7f45297aa0f0 [kafka.conn] [DEBUG]: Response 503 (601.672887802124 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.488 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/31/2025 02:30:26.488 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.489 7f4529770eb8 [kafka.conn] [DEBUG]: Response 507 (601.4077663421631 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.490 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 03/31/2025 02:30:26.490 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.490 7f45297aa8d0 [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=2, max_bytes=1048576)])]) 03/31/2025 02:30:26.490 7f45297aa8d0 [kafka.conn] [DEBUG]: Request 503: 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=2, max_bytes=1048576)])]) 03/31/2025 02:30:26.490 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 11 03/31/2025 02:30:26.491 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.491 7f4529d236d8 [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=11, max_bytes=1048576)])]) 03/31/2025 02:30:26.491 7f4529d236d8 [kafka.conn] [DEBUG]: Request 505: 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=11, max_bytes=1048576)])]) 03/31/2025 02:30:26.514 7f45297aa390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 03/31/2025 02:30:26.514 7f45297aa390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.514 7f45297aa390 [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=5, max_bytes=1048576)])]) 03/31/2025 02:30:26.515 7f45297aa390 [kafka.conn] [DEBUG]: Request 505: 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=5, max_bytes=1048576)])]) 03/31/2025 02:30:26.516 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 534 03/31/2025 02:30:26.516 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.517 7f4529140a20 [kafka.conn] [DEBUG]: Response 534 (600.797176361084 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=153, last_stable_offset=153, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.595 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/31/2025 02:30:26.596 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.596 7f452996dc18 [kafka.conn] [DEBUG]: Response 520 (601.8893718719482 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=83, last_stable_offset=83, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.596 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/31/2025 02:30:26.596 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.597 7f4529d3de10 [kafka.conn] [DEBUG]: Response 507 (601.7265319824219 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.597 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 116 03/31/2025 02:30:26.597 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.597 7f4529969b70 [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=116, max_bytes=1048576)])]) 03/31/2025 02:30:26.597 7f4529969b70 [kafka.conn] [DEBUG]: Request 527: 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=116, max_bytes=1048576)])]) 03/31/2025 02:30:26.693 7f45299690f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 03/31/2025 02:30:26.693 7f45299690f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.693 7f45299690f0 [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=0, max_bytes=1048576)])]) 03/31/2025 02:30:26.693 7f45299690f0 [kafka.conn] [DEBUG]: Request 502: 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=0, max_bytes=1048576)])]) 03/31/2025 02:30:26.694 7f4529966048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:26.694 7f4529966048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.694 7f4529966048 [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:26.694 7f4529966048 [kafka.conn] [DEBUG]: Request 502: 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:26.695 7f4529974828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 13 03/31/2025 02:30:26.695 7f4529974828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.695 7f4529974828 [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=13, max_bytes=1048576)])]) 03/31/2025 02:30:26.695 7f4529974828 [kafka.conn] [DEBUG]: Request 506: 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=13, max_bytes=1048576)])]) 03/31/2025 02:30:26.695 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 03/31/2025 02:30:26.696 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.696 7f45298cca20 [kafka.conn] [DEBUG]: Response 529 (601.036787033081 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=88, last_stable_offset=88, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.703 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 794 03/31/2025 02:30:26.703 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.703 7f45299668d0 [kafka.conn] [DEBUG]: Response 794 (601.0048389434814 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2377, last_stable_offset=2377, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\tH\x00\x00\x01\x19\x00\x00\x00\x00\x02c\xecl\x95\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\xcc\x03\x00\x00\x00\x8e\x03ObjectConfigDatabaseInfo:cn-jenk...')])]) 03/31/2025 02:30:26.704 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2376 to buffered record list 03/31/2025 02:30:26.704 7f4529969240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 19 03/31/2025 02:30:26.704 7f4529969240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.704 7f4529969240 [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=19, max_bytes=1048576)])]) 03/31/2025 02:30:26.705 7f4529969240 [kafka.conn] [DEBUG]: Request 510: 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=19, max_bytes=1048576)])]) 03/31/2025 02:30:26.777 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 545 03/31/2025 02:30:26.777 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.777 7f45298cc4e0 [kafka.conn] [DEBUG]: Response 545 (601.9270420074463 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=121, last_stable_offset=121, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.778 7f4529932978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 96 03/31/2025 02:30:26.778 7f4529932978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.778 7f4529932978 [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=96, max_bytes=1048576)])]) 03/31/2025 02:30:26.778 7f4529932978 [kafka.conn] [DEBUG]: Request 524: 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=96, max_bytes=1048576)])]) 03/31/2025 02:30:26.779 7f4527fa5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 03/31/2025 02:30:26.779 7f4527fa5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.779 7f4527fa5cc0 [kafka.conn] [DEBUG]: Response 517 (602.7653217315674 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=50, last_stable_offset=50, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.791 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 565 03/31/2025 02:30:26.791 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.791 7f4527fa5f60 [kafka.conn] [DEBUG]: Response 565 (601.0675430297852 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=356, last_stable_offset=356, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.804 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2377 03/31/2025 02:30:26.804 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.804 7f45299668d0 [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=2377, max_bytes=1048576)])]) 03/31/2025 02:30:26.805 7f45299668d0 [kafka.conn] [DEBUG]: Request 795: 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=2377, max_bytes=1048576)])]) 03/31/2025 02:30:26.815 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 03/31/2025 02:30:26.815 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.815 7f4527fab198 [kafka.conn] [DEBUG]: Response 537 (601.4719009399414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.914 7f45298b0198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 57 03/31/2025 02:30:26.914 7f45298b0198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.914 7f45298b0198 [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=57, max_bytes=1048576)])]) 03/31/2025 02:30:26.915 7f45298b0198 [kafka.conn] [DEBUG]: Request 518: 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=57, max_bytes=1048576)])]) 03/31/2025 02:30:26.968 7f45297a0d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/31/2025 02:30:26.968 7f45297a0d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.968 7f45297a0d68 [kafka.conn] [DEBUG]: Response 512 (601.372480392456 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.969 7f4529770cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 32 03/31/2025 02:30:26.969 7f4529770cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.969 7f4529770cc0 [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=32, max_bytes=1048576)])]) 03/31/2025 02:30:26.969 7f4529770cc0 [kafka.conn] [DEBUG]: Request 510: 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=32, max_bytes=1048576)])]) 03/31/2025 02:30:26.969 7f45297aa630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 11 03/31/2025 02:30:26.969 7f45297aa630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.969 7f45297aa630 [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=11, max_bytes=1048576)])]) 03/31/2025 02:30:26.970 7f45297aa630 [kafka.conn] [DEBUG]: Request 506: 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=11, max_bytes=1048576)])]) 03/31/2025 02:30:26.970 7f4529770d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 32 03/31/2025 02:30:26.970 7f4529770d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.970 7f4529770d68 [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=32, max_bytes=1048576)])]) 03/31/2025 02:30:26.971 7f4529770d68 [kafka.conn] [DEBUG]: Request 511: 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=32, max_bytes=1048576)])]) 03/31/2025 02:30:26.971 7f45299324e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/31/2025 02:30:26.971 7f45299324e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.971 7f45299324e0 [kafka.conn] [DEBUG]: Response 509 (601.1557579040527 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:26.971 7f45298cce10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 133 03/31/2025 02:30:26.972 7f45298cce10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:26.972 7f45298cce10 [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=133, max_bytes=1048576)])]) 03/31/2025 02:30:26.972 7f45298cce10 [kafka.conn] [DEBUG]: Request 532: 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=133, max_bytes=1048576)])]) 03/31/2025 02:30:26.994 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 553 03/31/2025 02:30:26.994 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:26.995 7f45298b04e0 [kafka.conn] [DEBUG]: Response 553 (601.1834144592285 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=221, last_stable_offset=221, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.019 7f4529932cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 199 03/31/2025 02:30:27.020 7f4529932cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.020 7f4529932cc0 [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=199, max_bytes=1048576)])]) 03/31/2025 02:30:27.020 7f4529932cc0 [kafka.conn] [DEBUG]: Request 542: 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=199, max_bytes=1048576)])]) 03/31/2025 02:30:27.088 7f45298cc8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 100 03/31/2025 02:30:27.088 7f45298cc8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.088 7f45298cc8d0 [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=100, max_bytes=1048576)])]) 03/31/2025 02:30:27.088 7f45298cc8d0 [kafka.conn] [DEBUG]: Request 525: 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=100, max_bytes=1048576)])]) 03/31/2025 02:30:27.089 7f45297aa0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 03/31/2025 02:30:27.089 7f45297aa0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.089 7f45297aa0f0 [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=4, max_bytes=1048576)])]) 03/31/2025 02:30:27.089 7f45297aa0f0 [kafka.conn] [DEBUG]: Request 504: 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=4, max_bytes=1048576)])]) 03/31/2025 02:30:27.089 7f4529770eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 18 03/31/2025 02:30:27.090 7f4529770eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.090 7f4529770eb8 [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=18, max_bytes=1048576)])]) 03/31/2025 02:30:27.090 7f4529770eb8 [kafka.conn] [DEBUG]: Request 508: 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=18, max_bytes=1048576)])]) 03/31/2025 02:30:27.091 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/31/2025 02:30:27.092 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.092 7f45297aa8d0 [kafka.conn] [DEBUG]: Response 503 (601.5756130218506 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.092 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/31/2025 02:30:27.092 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.092 7f4529d236d8 [kafka.conn] [DEBUG]: Response 505 (601.5691757202148 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.115 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/31/2025 02:30:27.116 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.116 7f45297aa390 [kafka.conn] [DEBUG]: Response 505 (601.2799739837646 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.117 7f4529140a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 153 03/31/2025 02:30:27.117 7f4529140a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.117 7f4529140a20 [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=153, max_bytes=1048576)])]) 03/31/2025 02:30:27.118 7f4529140a20 [kafka.conn] [DEBUG]: Request 535: 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=153, max_bytes=1048576)])]) 03/31/2025 02:30:27.196 7f452996dc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 83 03/31/2025 02:30:27.196 7f452996dc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.197 7f452996dc18 [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=83, max_bytes=1048576)])]) 03/31/2025 02:30:27.197 7f452996dc18 [kafka.conn] [DEBUG]: Request 521: 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=83, max_bytes=1048576)])]) 03/31/2025 02:30:27.197 7f4529d3de10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 19 03/31/2025 02:30:27.197 7f4529d3de10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.197 7f4529d3de10 [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=19, max_bytes=1048576)])]) 03/31/2025 02:30:27.197 7f4529d3de10 [kafka.conn] [DEBUG]: Request 508: 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=19, max_bytes=1048576)])]) 03/31/2025 02:30:27.198 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 527 03/31/2025 02:30:27.198 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.198 7f4529969b70 [kafka.conn] [DEBUG]: Response 527 (601.0751724243164 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=116, last_stable_offset=116, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.295 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/31/2025 02:30:27.295 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.295 7f45299690f0 [kafka.conn] [DEBUG]: Response 502 (601.912260055542 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.296 7f4529966048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/31/2025 02:30:27.296 7f4529966048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.296 7f4529966048 [kafka.conn] [DEBUG]: Response 502 (601.9625663757324 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:27.296 7f4529974828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:27.297 7f4529974828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.297 7f4529974828 [kafka.conn] [DEBUG]: Response 506 (601.7718315124512 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.297 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 88 03/31/2025 02:30:27.297 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.297 7f45298cca20 [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=88, max_bytes=1048576)])]) 03/31/2025 02:30:27.297 7f45298cca20 [kafka.conn] [DEBUG]: Request 530: 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=88, max_bytes=1048576)])]) 03/31/2025 02:30:27.305 7f4529969240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/31/2025 02:30:27.305 7f4529969240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.305 7f4529969240 [kafka.conn] [DEBUG]: Response 510 (600.9745597839355 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.378 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121 03/31/2025 02:30:27.378 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.378 7f45298cc4e0 [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=121, max_bytes=1048576)])]) 03/31/2025 02:30:27.379 7f45298cc4e0 [kafka.conn] [DEBUG]: Request 546: 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=121, max_bytes=1048576)])]) 03/31/2025 02:30:27.379 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 50 03/31/2025 02:30:27.379 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.379 7f4527fa5cc0 [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=50, max_bytes=1048576)])]) 03/31/2025 02:30:27.380 7f4527fa5cc0 [kafka.conn] [DEBUG]: Request 518: 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=50, max_bytes=1048576)])]) 03/31/2025 02:30:27.380 7f4529932978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 524 03/31/2025 02:30:27.380 7f4529932978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.380 7f4529932978 [kafka.conn] [DEBUG]: Response 524 (602.135419845581 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.392 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 356 03/31/2025 02:30:27.392 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.392 7f4527fa5f60 [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=356, max_bytes=1048576)])]) 03/31/2025 02:30:27.392 7f4527fa5f60 [kafka.conn] [DEBUG]: Request 566: 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=356, max_bytes=1048576)])]) 03/31/2025 02:30:27.406 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 795 03/31/2025 02:30:27.406 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.406 7f45299668d0 [kafka.conn] [DEBUG]: Response 795 (601.2158393859863 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2378, last_stable_offset=2378, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\tI\x00\x00\x01\x04\x00\x00\x00\x00\x02\x12\xe3\xac\xaf\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/31/2025 02:30:27.406 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2377 to buffered record list 03/31/2025 02:30:27.416 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 171 03/31/2025 02:30:27.416 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.416 7f4527fab198 [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=171, max_bytes=1048576)])]) 03/31/2025 02:30:27.416 7f4527fab198 [kafka.conn] [DEBUG]: Request 538: 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=171, max_bytes=1048576)])]) 03/31/2025 02:30:27.507 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2378 03/31/2025 02:30:27.507 7f45299668d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.507 7f45299668d0 [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=2378, max_bytes=1048576)])]) 03/31/2025 02:30:27.508 7f45299668d0 [kafka.conn] [DEBUG]: Request 796: 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=2378, max_bytes=1048576)])]) 03/31/2025 02:30:27.516 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/31/2025 02:30:27.516 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.516 7f45298b0198 [kafka.conn] [DEBUG]: Response 518 (601.4835834503174 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.569 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 28 03/31/2025 02:30:27.569 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.570 7f45297a0d68 [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=28, max_bytes=1048576)])]) 03/31/2025 02:30:27.570 7f45297a0d68 [kafka.conn] [DEBUG]: Request 513: 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=28, max_bytes=1048576)])]) 03/31/2025 02:30:27.571 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/31/2025 02:30:27.571 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.571 7f4529770cc0 [kafka.conn] [DEBUG]: Response 510 (602.2005081176758 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.572 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31 03/31/2025 02:30:27.572 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.572 7f45299324e0 [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=31, max_bytes=1048576)])]) 03/31/2025 02:30:27.573 7f45299324e0 [kafka.conn] [DEBUG]: Request 510: 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=31, max_bytes=1048576)])]) 03/31/2025 02:30:27.573 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:27.573 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.573 7f45297aa630 [kafka.conn] [DEBUG]: Response 506 (603.6863327026367 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.574 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/31/2025 02:30:27.574 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.574 7f4529770d68 [kafka.conn] [DEBUG]: Response 511 (603.8293838500977 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.575 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 532 03/31/2025 02:30:27.575 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.575 7f45298cce10 [kafka.conn] [DEBUG]: Response 532 (603.654146194458 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=133, last_stable_offset=133, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.595 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 221 03/31/2025 02:30:27.595 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.596 7f45298b04e0 [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=221, max_bytes=1048576)])]) 03/31/2025 02:30:27.596 7f45298b04e0 [kafka.conn] [DEBUG]: Request 554: 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=221, max_bytes=1048576)])]) 03/31/2025 02:30:27.621 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 542 03/31/2025 02:30:27.621 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.621 7f4529932cc0 [kafka.conn] [DEBUG]: Response 542 (601.2961864471436 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=199, last_stable_offset=199, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.690 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 525 03/31/2025 02:30:27.690 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.690 7f45298cc8d0 [kafka.conn] [DEBUG]: Response 525 (602.0252704620361 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.691 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/31/2025 02:30:27.691 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.691 7f45297aa0f0 [kafka.conn] [DEBUG]: Response 504 (602.0238399505615 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.691 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/31/2025 02:30:27.691 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.691 7f4529770eb8 [kafka.conn] [DEBUG]: Response 508 (601.7005443572998 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.692 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 03/31/2025 02:30:27.692 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.692 7f45297aa8d0 [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=2, max_bytes=1048576)])]) 03/31/2025 02:30:27.693 7f45297aa8d0 [kafka.conn] [DEBUG]: Request 504: 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=2, max_bytes=1048576)])]) 03/31/2025 02:30:27.693 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 11 03/31/2025 02:30:27.693 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.693 7f4529d236d8 [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=11, max_bytes=1048576)])]) 03/31/2025 02:30:27.693 7f4529d236d8 [kafka.conn] [DEBUG]: Request 506: 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=11, max_bytes=1048576)])]) 03/31/2025 02:30:27.716 7f45297aa390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 03/31/2025 02:30:27.717 7f45297aa390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.717 7f45297aa390 [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=5, max_bytes=1048576)])]) 03/31/2025 02:30:27.717 7f45297aa390 [kafka.conn] [DEBUG]: Request 506: 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=5, max_bytes=1048576)])]) 03/31/2025 02:30:27.718 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 535 03/31/2025 02:30:27.718 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.718 7f4529140a20 [kafka.conn] [DEBUG]: Response 535 (600.9960174560547 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=153, last_stable_offset=153, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.798 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 03/31/2025 02:30:27.798 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.798 7f452996dc18 [kafka.conn] [DEBUG]: Response 521 (601.691722869873 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=83, last_stable_offset=83, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.799 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 116 03/31/2025 02:30:27.799 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.799 7f4529969b70 [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=116, max_bytes=1048576)])]) 03/31/2025 02:30:27.799 7f4529969b70 [kafka.conn] [DEBUG]: Request 528: 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=116, max_bytes=1048576)])]) 03/31/2025 02:30:27.800 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/31/2025 02:30:27.800 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.800 7f4529d3de10 [kafka.conn] [DEBUG]: Response 508 (602.384090423584 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.896 7f45299690f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 03/31/2025 02:30:27.896 7f45299690f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.896 7f45299690f0 [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=0, max_bytes=1048576)])]) 03/31/2025 02:30:27.897 7f45299690f0 [kafka.conn] [DEBUG]: Request 503: 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=0, max_bytes=1048576)])]) 03/31/2025 02:30:27.897 7f4529966048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/31/2025 02:30:27.897 7f4529966048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.897 7f4529966048 [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:27.897 7f4529966048 [kafka.conn] [DEBUG]: Request 503: 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:27.898 7f4529974828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 13 03/31/2025 02:30:27.898 7f4529974828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.898 7f4529974828 [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=13, max_bytes=1048576)])]) 03/31/2025 02:30:27.898 7f4529974828 [kafka.conn] [DEBUG]: Request 507: 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=13, max_bytes=1048576)])]) 03/31/2025 02:30:27.899 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 03/31/2025 02:30:27.899 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.899 7f45298cca20 [kafka.conn] [DEBUG]: Response 530 (601.4511585235596 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=88, last_stable_offset=88, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.907 7f4529969240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 19 03/31/2025 02:30:27.907 7f4529969240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.907 7f4529969240 [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=19, max_bytes=1048576)])]) 03/31/2025 02:30:27.907 7f4529969240 [kafka.conn] [DEBUG]: Request 511: 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=19, max_bytes=1048576)])]) 03/31/2025 02:30:27.980 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 546 03/31/2025 02:30:27.980 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.980 7f45298cc4e0 [kafka.conn] [DEBUG]: Response 546 (601.3317108154297 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=121, last_stable_offset=121, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.980 7f4527fa5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/31/2025 02:30:27.981 7f4527fa5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.981 7f4527fa5cc0 [kafka.conn] [DEBUG]: Response 518 (601.1981964111328 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=50, last_stable_offset=50, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:27.981 7f4529932978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 96 03/31/2025 02:30:27.981 7f4529932978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:27.981 7f4529932978 [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=96, max_bytes=1048576)])]) 03/31/2025 02:30:27.981 7f4529932978 [kafka.conn] [DEBUG]: Request 525: 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=96, max_bytes=1048576)])]) 03/31/2025 02:30:27.993 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 566 03/31/2025 02:30:27.993 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:27.993 7f4527fa5f60 [kafka.conn] [DEBUG]: Response 566 (600.9736061096191 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=356, last_stable_offset=356, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.017 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 538 03/31/2025 02:30:28.017 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.018 7f4527fab198 [kafka.conn] [DEBUG]: Response 538 (601.5293598175049 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.108 7f45299668d0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-0']) to node 1 03/31/2025 02:30:28.109 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-0']) 03/31/2025 02:30:28.109 7f45299668d0 [kafka.conn] [DEBUG]: Request 797: MetadataRequest_v1(topics=['-uve-topic-0']) 03/31/2025 02:30:28.109 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 796 03/31/2025 02:30:28.110 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.110 7f45299668d0 [kafka.conn] [DEBUG]: Response 796 (602.3051738739014 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2378, last_stable_offset=2378, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.117 7f45298b0198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 57 03/31/2025 02:30:28.117 7f45298b0198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.117 7f45298b0198 [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=57, max_bytes=1048576)])]) 03/31/2025 02:30:28.118 7f45298b0198 [kafka.conn] [DEBUG]: Request 519: 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=57, max_bytes=1048576)])]) 03/31/2025 02:30:28.171 7f45297a0d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/31/2025 02:30:28.171 7f45297a0d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.172 7f45297a0d68 [kafka.conn] [DEBUG]: Response 513 (601.7277240753174 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=28, last_stable_offset=28, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.172 7f4529770cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 32 03/31/2025 02:30:28.172 7f4529770cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.172 7f4529770cc0 [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=32, max_bytes=1048576)])]) 03/31/2025 02:30:28.172 7f4529770cc0 [kafka.conn] [DEBUG]: Request 511: 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=32, max_bytes=1048576)])]) 03/31/2025 02:30:28.174 7f45297aa630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 11 03/31/2025 02:30:28.174 7f45297aa630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.174 7f45297aa630 [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=11, max_bytes=1048576)])]) 03/31/2025 02:30:28.174 7f45297aa630 [kafka.conn] [DEBUG]: Request 507: 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=11, max_bytes=1048576)])]) 03/31/2025 02:30:28.175 7f4529770d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 32 03/31/2025 02:30:28.175 7f4529770d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.175 7f4529770d68 [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=32, max_bytes=1048576)])]) 03/31/2025 02:30:28.175 7f4529770d68 [kafka.conn] [DEBUG]: Request 512: 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=32, max_bytes=1048576)])]) 03/31/2025 02:30:28.176 7f45299324e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/31/2025 02:30:28.176 7f45299324e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.176 7f45299324e0 [kafka.conn] [DEBUG]: Response 510 (603.4097671508789 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.176 7f45298cce10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 133 03/31/2025 02:30:28.176 7f45298cce10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.176 7f45298cce10 [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=133, max_bytes=1048576)])]) 03/31/2025 02:30:28.177 7f45298cce10 [kafka.conn] [DEBUG]: Request 533: 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=133, max_bytes=1048576)])]) 03/31/2025 02:30:28.197 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 554 03/31/2025 02:30:28.199 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.200 7f45298b04e0 [kafka.conn] [DEBUG]: Response 554 (603.6887168884277 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=221, last_stable_offset=221, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.222 7f4529932cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 199 03/31/2025 02:30:28.222 7f4529932cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.222 7f4529932cc0 [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=199, max_bytes=1048576)])]) 03/31/2025 02:30:28.222 7f4529932cc0 [kafka.conn] [DEBUG]: Request 543: 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=199, max_bytes=1048576)])]) 03/31/2025 02:30:28.291 7f45298cc8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 100 03/31/2025 02:30:28.291 7f45298cc8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.291 7f45298cc8d0 [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=100, max_bytes=1048576)])]) 03/31/2025 02:30:28.291 7f45298cc8d0 [kafka.conn] [DEBUG]: Request 526: 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=100, max_bytes=1048576)])]) 03/31/2025 02:30:28.292 7f45297aa0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 03/31/2025 02:30:28.292 7f45297aa0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.292 7f45297aa0f0 [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=4, max_bytes=1048576)])]) 03/31/2025 02:30:28.292 7f45297aa0f0 [kafka.conn] [DEBUG]: Request 505: 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=4, max_bytes=1048576)])]) 03/31/2025 02:30:28.293 7f4529770eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 18 03/31/2025 02:30:28.293 7f4529770eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.293 7f4529770eb8 [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=18, max_bytes=1048576)])]) 03/31/2025 02:30:28.293 7f4529770eb8 [kafka.conn] [DEBUG]: Request 509: 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=18, max_bytes=1048576)])]) 03/31/2025 02:30:28.294 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/31/2025 02:30:28.294 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.294 7f45297aa8d0 [kafka.conn] [DEBUG]: Response 504 (601.5439033508301 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.295 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:28.295 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.295 7f4529d236d8 [kafka.conn] [DEBUG]: Response 506 (601.6926765441895 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.322 7f45297aa390 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-8']) to node 1 03/31/2025 02:30:28.322 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-8']) 03/31/2025 02:30:28.323 7f45297aa390 [kafka.conn] [DEBUG]: Request 507: MetadataRequest_v1(topics=['-uve-topic-8']) 03/31/2025 02:30:28.323 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:28.323 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.323 7f45297aa390 [kafka.conn] [DEBUG]: Response 506 (606.24098777771 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.323 7f4529140a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 153 03/31/2025 02:30:28.324 7f4529140a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.324 7f4529140a20 [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=153, max_bytes=1048576)])]) 03/31/2025 02:30:28.324 7f4529140a20 [kafka.conn] [DEBUG]: Request 536: 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=153, max_bytes=1048576)])]) 03/31/2025 02:30:28.399 7f452996dc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 83 03/31/2025 02:30:28.399 7f452996dc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.400 7f452996dc18 [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=83, max_bytes=1048576)])]) 03/31/2025 02:30:28.400 7f452996dc18 [kafka.conn] [DEBUG]: Request 522: 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=83, max_bytes=1048576)])]) 03/31/2025 02:30:28.400 7f4529d3de10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 19 03/31/2025 02:30:28.400 7f4529d3de10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.400 7f4529d3de10 [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=19, max_bytes=1048576)])]) 03/31/2025 02:30:28.401 7f4529d3de10 [kafka.conn] [DEBUG]: Request 509: 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=19, max_bytes=1048576)])]) 03/31/2025 02:30:28.401 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 03/31/2025 02:30:28.401 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.401 7f4529969b70 [kafka.conn] [DEBUG]: Response 528 (602.1604537963867 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=116, last_stable_offset=116, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.498 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/31/2025 02:30:28.498 7f45299690f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.499 7f45299690f0 [kafka.conn] [DEBUG]: Response 503 (602.0846366882324 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.499 7f4529966048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/31/2025 02:30:28.499 7f4529966048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.499 7f4529966048 [kafka.conn] [DEBUG]: Response 503 (602.2613048553467 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:28.500 7f4529974828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/31/2025 02:30:28.500 7f4529974828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.500 7f4529974828 [kafka.conn] [DEBUG]: Response 507 (602.0145416259766 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.500 7f45298cca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 88 03/31/2025 02:30:28.500 7f45298cca20 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-24']) to node 1 03/31/2025 02:30:28.501 7f45298cca20 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-24']) 03/31/2025 02:30:28.501 7f45298cca20 [kafka.conn] [DEBUG]: Request 531: MetadataRequest_v1(topics=['-uve-topic-24']) 03/31/2025 02:30:28.508 7f4529969240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/31/2025 02:30:28.508 7f4529969240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.508 7f4529969240 [kafka.conn] [DEBUG]: Response 511 (600.9910106658936 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.581 7f45298cc4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121 03/31/2025 02:30:28.581 7f45298cc4e0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-22']) to node 1 03/31/2025 02:30:28.581 7f45298cc4e0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-22']) 03/31/2025 02:30:28.581 7f45298cc4e0 [kafka.conn] [DEBUG]: Request 547: MetadataRequest_v1(topics=['-uve-topic-22']) 03/31/2025 02:30:28.581 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 50 03/31/2025 02:30:28.582 7f4527fa5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.582 7f4527fa5cc0 [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=50, max_bytes=1048576)])]) 03/31/2025 02:30:28.582 7f4527fa5cc0 [kafka.conn] [DEBUG]: Request 519: 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=50, max_bytes=1048576)])]) 03/31/2025 02:30:28.582 7f4529932978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 525 03/31/2025 02:30:28.583 7f4529932978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.583 7f4529932978 [kafka.conn] [DEBUG]: Response 525 (601.243257522583 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=96, last_stable_offset=96, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.594 7f4527fa5f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 356 03/31/2025 02:30:28.594 7f4527fa5f60 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-29']) to node 1 03/31/2025 02:30:28.594 7f4527fa5f60 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-29']) 03/31/2025 02:30:28.595 7f4527fa5f60 [kafka.conn] [DEBUG]: Request 567: MetadataRequest_v1(topics=['-uve-topic-29']) 03/31/2025 02:30:28.619 7f4527fab198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 171 03/31/2025 02:30:28.619 7f4527fab198 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-28']) to node 1 03/31/2025 02:30:28.619 7f4527fab198 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-28']) 03/31/2025 02:30:28.619 7f4527fab198 [kafka.conn] [DEBUG]: Request 539: MetadataRequest_v1(topics=['-uve-topic-28']) 03/31/2025 02:30:28.711 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 797 03/31/2025 02:30:28.711 7f45299668d0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:28.712 7f45299668d0 [kafka.conn] [DEBUG]: Response 797 (602.7154922485352 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-0', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:28.713 7f45299668d0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/31/2025 02:30:28.718 7f45298b0198 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-25']) to node 1 03/31/2025 02:30:28.719 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-25']) 03/31/2025 02:30:28.719 7f45298b0198 [kafka.conn] [DEBUG]: Request 520: MetadataRequest_v1(topics=['-uve-topic-25']) 03/31/2025 02:30:28.719 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/31/2025 02:30:28.719 7f45298b0198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.719 7f45298b0198 [kafka.conn] [DEBUG]: Response 519 (601.7229557037354 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.772 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 28 03/31/2025 02:30:28.772 7f45297a0d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.773 7f45297a0d68 [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=28, max_bytes=1048576)])]) 03/31/2025 02:30:28.773 7f45297a0d68 [kafka.conn] [DEBUG]: Request 514: 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=28, max_bytes=1048576)])]) 03/31/2025 02:30:28.774 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/31/2025 02:30:28.774 7f4529770cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.774 7f4529770cc0 [kafka.conn] [DEBUG]: Response 511 (601.5691757202148 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.775 7f45297aa630 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-6']) to node 1 03/31/2025 02:30:28.775 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-6']) 03/31/2025 02:30:28.775 7f45297aa630 [kafka.conn] [DEBUG]: Request 508: MetadataRequest_v1(topics=['-uve-topic-6']) 03/31/2025 02:30:28.775 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/31/2025 02:30:28.775 7f45297aa630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.776 7f45297aa630 [kafka.conn] [DEBUG]: Response 507 (601.2997627258301 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.776 7f4529770d68 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-14']) to node 1 03/31/2025 02:30:28.776 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-14']) 03/31/2025 02:30:28.776 7f4529770d68 [kafka.conn] [DEBUG]: Request 513: MetadataRequest_v1(topics=['-uve-topic-14']) 03/31/2025 02:30:28.776 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/31/2025 02:30:28.776 7f4529770d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.777 7f4529770d68 [kafka.conn] [DEBUG]: Response 512 (601.409912109375 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.777 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31 03/31/2025 02:30:28.777 7f45299324e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/31/2025 02:30:28.777 7f45299324e0 [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=31, max_bytes=1048576)])]) 03/31/2025 02:30:28.777 7f45299324e0 [kafka.conn] [DEBUG]: Request 511: 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=31, max_bytes=1048576)])]) 03/31/2025 02:30:28.778 7f45298cce10 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-23']) to node 1 03/31/2025 02:30:28.778 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-23']) 03/31/2025 02:30:28.778 7f45298cce10 [kafka.conn] [DEBUG]: Request 534: MetadataRequest_v1(topics=['-uve-topic-23']) 03/31/2025 02:30:28.778 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 533 03/31/2025 02:30:28.778 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.778 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 534 03/31/2025 02:30:28.778 7f45298cce10 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:28.779 7f45298cce10 [kafka.conn] [DEBUG]: Response 533 (602.1444797515869 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=133, last_stable_offset=133, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.779 7f45298cce10 [kafka.conn] [DEBUG]: Response 534 (1.1970996856689453 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-23', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:28.780 7f45298cce10 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/31/2025 02:30:28.800 7f45298b04e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 221 03/31/2025 02:30:28.801 7f45298b04e0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-26']) to node 1 03/31/2025 02:30:28.801 7f45298b04e0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-26']) 03/31/2025 02:30:28.801 7f45298b04e0 [kafka.conn] [DEBUG]: Request 555: MetadataRequest_v1(topics=['-uve-topic-26']) 03/31/2025 02:30:28.824 7f4529932cc0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-20']) to node 1 03/31/2025 02:30:28.824 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-20']) 03/31/2025 02:30:28.825 7f4529932cc0 [kafka.conn] [DEBUG]: Request 544: MetadataRequest_v1(topics=['-uve-topic-20']) 03/31/2025 02:30:28.825 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 543 03/31/2025 02:30:28.825 7f4529932cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.825 7f4529932cc0 [kafka.conn] [DEBUG]: Response 543 (602.8187274932861 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=199, last_stable_offset=199, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.893 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 526 03/31/2025 02:30:28.893 7f45298cc8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.893 7f45298cc8d0 [kafka.conn] [DEBUG]: Response 526 (602.0832061767578 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.894 7f45297aa0f0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-9']) to node 1 03/31/2025 02:30:28.894 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-9']) 03/31/2025 02:30:28.894 7f45297aa0f0 [kafka.conn] [DEBUG]: Request 506: MetadataRequest_v1(topics=['-uve-topic-9']) 03/31/2025 02:30:28.895 7f4529770eb8 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-12']) to node 1 03/31/2025 02:30:28.895 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-12']) 03/31/2025 02:30:28.895 7f4529770eb8 [kafka.conn] [DEBUG]: Request 510: MetadataRequest_v1(topics=['-uve-topic-12']) 03/31/2025 02:30:28.895 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/31/2025 02:30:28.895 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.895 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/31/2025 02:30:28.895 7f45297aa0f0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:28.896 7f45297aa0f0 [kafka.conn] [DEBUG]: Response 505 (603.5740375518799 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.896 7f45297aa0f0 [kafka.conn] [DEBUG]: Response 506 (1.665353775024414 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-9', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:28.897 7f45297aa0f0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/31/2025 02:30:28.897 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/31/2025 02:30:28.897 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.897 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/31/2025 02:30:28.897 7f4529770eb8 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:28.898 7f4529770eb8 [kafka.conn] [DEBUG]: Response 509 (604.888916015625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:28.898 7f4529770eb8 [kafka.conn] [DEBUG]: Response 510 (3.221273422241211 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-12', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:28.899 7f4529770eb8 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/31/2025 02:30:28.899 7f45297aa8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 03/31/2025 02:30:28.899 7f45297aa8d0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-5']) to node 1 03/31/2025 02:30:28.899 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-5']) 03/31/2025 02:30:28.899 7f45297aa8d0 [kafka.conn] [DEBUG]: Request 505: MetadataRequest_v1(topics=['-uve-topic-5']) 03/31/2025 02:30:28.900 7f4529d236d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 11 03/31/2025 02:30:28.900 7f4529d236d8 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-4']) to node 1 03/31/2025 02:30:28.900 7f4529d236d8 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-4']) 03/31/2025 02:30:28.900 7f4529d236d8 [kafka.conn] [DEBUG]: Request 507: MetadataRequest_v1(topics=['-uve-topic-4']) 03/31/2025 02:30:28.900 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/31/2025 02:30:28.900 7f45297aa8d0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:28.901 7f45297aa8d0 [kafka.conn] [DEBUG]: Response 505 (1.3911724090576172 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-5', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:28.902 7f45297aa8d0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/31/2025 02:30:28.924 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/31/2025 02:30:28.924 7f45297aa390 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:28.925 7f45297aa390 [kafka.conn] [DEBUG]: Response 507 (602.1895408630371 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-8', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:28.926 7f45297aa390 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/31/2025 02:30:28.926 7f4529140a20 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-27']) to node 1 03/31/2025 02:30:28.926 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-27']) 03/31/2025 02:30:28.926 7f4529140a20 [kafka.conn] [DEBUG]: Request 537: MetadataRequest_v1(topics=['-uve-topic-27']) 03/31/2025 02:30:28.926 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 03/31/2025 02:30:28.926 7f4529140a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:28.927 7f4529140a20 [kafka.conn] [DEBUG]: Response 536 (602.8168201446533 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=153, last_stable_offset=153, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:29.001 7f452996dc18 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-16']) to node 1 03/31/2025 02:30:29.002 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-16']) 03/31/2025 02:30:29.002 7f452996dc18 [kafka.conn] [DEBUG]: Request 523: MetadataRequest_v1(topics=['-uve-topic-16']) 03/31/2025 02:30:29.002 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 03/31/2025 02:30:29.002 7f452996dc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:29.002 7f452996dc18 [kafka.conn] [DEBUG]: Response 522 (602.6227474212646 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=83, last_stable_offset=83, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:29.003 7f4529969b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 116 03/31/2025 02:30:29.003 7f4529969b70 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-3']) to node 1 03/31/2025 02:30:29.003 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-3']) 03/31/2025 02:30:29.003 7f4529969b70 [kafka.conn] [DEBUG]: Request 529: MetadataRequest_v1(topics=['-uve-topic-3']) 03/31/2025 02:30:29.004 7f4529d3de10 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-13']) to node 1 03/31/2025 02:30:29.004 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-13']) 03/31/2025 02:30:29.004 7f4529d3de10 [kafka.conn] [DEBUG]: Request 510: MetadataRequest_v1(topics=['-uve-topic-13']) 03/31/2025 02:30:29.004 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/31/2025 02:30:29.004 7f4529d3de10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/31/2025 02:30:29.004 7f4529d3de10 [kafka.conn] [DEBUG]: Response 509 (603.503942489624 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 03/31/2025 02:30:29.005 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 03/31/2025 02:30:29.005 7f4529969b70 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/31/2025 02:30:29.005 7f4529969b70 [kafka.conn] [DEBUG]: Response 529 (1.9640922546386719 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-3', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 03/31/2025 02:30:29.006 7f4529969b70 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)