03/27/2025 02:37:27.740 7fd2b6c44390 [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=1, max_bytes=1048576)])]) 03/27/2025 02:37:27.740 7fd2b6c44390 [kafka.conn] [DEBUG]: Request 274: 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=1, max_bytes=1048576)])]) 03/27/2025 02:37:27.741 7fd2b6c54390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 301 03/27/2025 02:37:27.741 7fd2b6c54390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.741 7fd2b6c54390 [kafka.conn] [DEBUG]: Response 301 (601.3848781585693 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=241, last_stable_offset=241, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.748 7fd2b7b0aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 59 03/27/2025 02:37:27.748 7fd2b7b0aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.748 7fd2b7b0aa20 [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=59, max_bytes=1048576)])]) 03/27/2025 02:37:27.748 7fd2b7b0aa20 [kafka.conn] [DEBUG]: Request 293: 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=59, max_bytes=1048576)])]) 03/27/2025 02:37:27.749 7fd2b6c718d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 143 03/27/2025 02:37:27.749 7fd2b6c718d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.749 7fd2b6c718d0 [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=143, max_bytes=1048576)])]) 03/27/2025 02:37:27.749 7fd2b6c718d0 [kafka.conn] [DEBUG]: Request 307: 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=143, max_bytes=1048576)])]) 03/27/2025 02:37:27.844 7fd2b6c50f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40 03/27/2025 02:37:27.844 7fd2b6c50f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.845 7fd2b6c50f60 [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=40, max_bytes=1048576)])]) 03/27/2025 02:37:27.845 7fd2b6c50f60 [kafka.conn] [DEBUG]: Request 284: 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=40, max_bytes=1048576)])]) 03/27/2025 02:37:27.845 7fd2b6c48f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 03/27/2025 02:37:27.846 7fd2b6c48f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.846 7fd2b6c48f60 [kafka.conn] [DEBUG]: Response 284 (601.191520690918 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.846 7fd2b6b99eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 40 03/27/2025 02:37:27.846 7fd2b6b99eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.846 7fd2b6b99eb8 [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=40, max_bytes=1048576)])]) 03/27/2025 02:37:27.846 7fd2b6b99eb8 [kafka.conn] [DEBUG]: Request 284: 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=40, max_bytes=1048576)])]) 03/27/2025 02:37:27.847 7fd2b5ce6780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 204 03/27/2025 02:37:27.847 7fd2b5ce6780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.847 7fd2b5ce6780 [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=204, max_bytes=1048576)])]) 03/27/2025 02:37:27.847 7fd2b5ce6780 [kafka.conn] [DEBUG]: Request 304: 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=204, max_bytes=1048576)])]) 03/27/2025 02:37:27.848 7fd2b69d2588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 143 03/27/2025 02:37:27.848 7fd2b69d2588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.848 7fd2b69d2588 [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=143, max_bytes=1048576)])]) 03/27/2025 02:37:27.848 7fd2b69d2588 [kafka.conn] [DEBUG]: Request 300: 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=143, max_bytes=1048576)])]) 03/27/2025 02:37:27.848 7fd2b69d2978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 313 03/27/2025 02:37:27.849 7fd2b69d2978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.849 7fd2b69d2978 [kafka.conn] [DEBUG]: Response 313 (601.9585132598877 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=272, last_stable_offset=272, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.880 7fd2b7bc1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 03/27/2025 02:37:27.880 7fd2b7bc1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.880 7fd2b7bc1828 [kafka.conn] [DEBUG]: Response 289 (601.3453006744385 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=51, last_stable_offset=51, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.905 7fd2b5ce64e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 389 03/27/2025 02:37:27.905 7fd2b5ce64e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.905 7fd2b5ce64e0 [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=389, max_bytes=1048576)])]) 03/27/2025 02:37:27.906 7fd2b5ce64e0 [kafka.conn] [DEBUG]: Request 327: 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=389, max_bytes=1048576)])]) 03/27/2025 02:37:27.936 7fd2b6a0fb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 447 03/27/2025 02:37:27.936 7fd2b6a0fb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.936 7fd2b6a0fb70 [kafka.conn] [DEBUG]: Response 447 (603.1832695007324 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4114, last_stable_offset=4114, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.936 7fd2b5ce6a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 72 03/27/2025 02:37:27.937 7fd2b5ce6a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.937 7fd2b5ce6a20 [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=72, max_bytes=1048576)])]) 03/27/2025 02:37:27.937 7fd2b5ce6a20 [kafka.conn] [DEBUG]: Request 290: 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=72, max_bytes=1048576)])]) 03/27/2025 02:37:27.937 7fd2b69d2c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 03/27/2025 02:37:27.937 7fd2b69d2c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.937 7fd2b69d2c18 [kafka.conn] [DEBUG]: Response 293 (603.9354801177979 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=105, last_stable_offset=105, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.938 7fd2b6a83c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 03/27/2025 02:37:27.938 7fd2b6a83c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.938 7fd2b6a83c18 [kafka.conn] [DEBUG]: Response 274 (603.8563251495361 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.941 7fd2b7aa1780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 275 03/27/2025 02:37:27.941 7fd2b7aa1780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.941 7fd2b7aa1780 [kafka.conn] [DEBUG]: Response 275 (601.0873317718506 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.943 7fd2b6a0f0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 275 03/27/2025 02:37:27.943 7fd2b6a0f0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.943 7fd2b6a0f0f0 [kafka.conn] [DEBUG]: Response 275 (601.2389659881592 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=3, last_stable_offset=3, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.945 7fd2b6c3ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 03/27/2025 02:37:27.945 7fd2b6c3ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.945 7fd2b6c3ccc0 [kafka.conn] [DEBUG]: Response 276 (601.6707420349121 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.946 7fd2b6ba3198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 20 03/27/2025 02:37:27.946 7fd2b6ba3198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.946 7fd2b6ba3198 [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=20, max_bytes=1048576)])]) 03/27/2025 02:37:27.946 7fd2b6ba3198 [kafka.conn] [DEBUG]: Request 281: 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=20, max_bytes=1048576)])]) 03/27/2025 02:37:27.979 7fd2b69d26d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 03/27/2025 02:37:27.979 7fd2b69d26d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:27.980 7fd2b69d26d8 [kafka.conn] [DEBUG]: Response 299 (602.1206378936768 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=147, last_stable_offset=147, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:27.980 7fd2b6c40978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 30 03/27/2025 02:37:27.980 7fd2b6c40978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:27.980 7fd2b6c40978 [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=30, max_bytes=1048576)])]) 03/27/2025 02:37:27.980 7fd2b6c40978 [kafka.conn] [DEBUG]: Request 283: 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=30, max_bytes=1048576)])]) 03/27/2025 02:37:28.034 7fd2b58896d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 1 03/27/2025 02:37:28.035 7fd2b58896d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.035 7fd2b58896d8 [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=1, max_bytes=1048576)])]) 03/27/2025 02:37:28.035 7fd2b58896d8 [kafka.conn] [DEBUG]: Request 274: 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=1, max_bytes=1048576)])]) 03/27/2025 02:37:28.047 7fd2b6a83e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 273 03/27/2025 02:37:28.047 7fd2b6a83e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.047 7fd2b6a83e10 [kafka.conn] [DEBUG]: Response 273 (601.7658710479736 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.048 7fd2b7aa1240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 275 03/27/2025 02:37:28.048 7fd2b7aa1240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.048 7fd2b7aa1240 [kafka.conn] [DEBUG]: Response 275 (601.7513275146484 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.144 7fd2b6c3c048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 03/27/2025 02:37:28.145 7fd2b6c3c048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.145 7fd2b6c3c048 [kafka.conn] [DEBUG]: Response 284 (601.1295318603516 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.244 7fd2b6a0f390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/27/2025 02:37:28.244 7fd2b6a0f390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.244 7fd2b6a0f390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:37:28.244 7fd2b6a0f390 [kafka.conn] [DEBUG]: Request 275: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:37:28.249 7fd2b6c71d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 112 03/27/2025 02:37:28.249 7fd2b6c71d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.250 7fd2b6c71d68 [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=112, max_bytes=1048576)])]) 03/27/2025 02:37:28.250 7fd2b6c71d68 [kafka.conn] [DEBUG]: Request 297: 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=112, max_bytes=1048576)])]) 03/27/2025 02:37:28.256 7fd2b6a0f8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 273 03/27/2025 02:37:28.256 7fd2b6a0f8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.256 7fd2b6a0f8d0 [kafka.conn] [DEBUG]: Response 273 (601.7611026763916 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/27/2025 02:37:28.257 7fd2b6a0f630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 03/27/2025 02:37:28.257 7fd2b6a0f630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.257 7fd2b6a0f630 [kafka.conn] [DEBUG]: Response 287 (601.8595695495605 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=62, last_stable_offset=62, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.341 7fd2b6c44390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 274 03/27/2025 02:37:28.341 7fd2b6c44390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.341 7fd2b6c44390 [kafka.conn] [DEBUG]: Response 274 (601.2659072875977 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.342 7fd2b6c54390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 241 03/27/2025 02:37:28.342 7fd2b6c54390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.342 7fd2b6c54390 [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=241, max_bytes=1048576)])]) 03/27/2025 02:37:28.342 7fd2b6c54390 [kafka.conn] [DEBUG]: Request 302: 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=241, max_bytes=1048576)])]) 03/27/2025 02:37:28.350 7fd2b7b0aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 03/27/2025 02:37:28.350 7fd2b7b0aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.350 7fd2b7b0aa20 [kafka.conn] [DEBUG]: Response 293 (601.860761642456 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=59, last_stable_offset=59, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.351 7fd2b6c718d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 03/27/2025 02:37:28.351 7fd2b6c718d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.351 7fd2b6c718d0 [kafka.conn] [DEBUG]: Response 307 (602.0064353942871 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.446 7fd2b6c50f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 03/27/2025 02:37:28.446 7fd2b6c50f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.446 7fd2b6c50f60 [kafka.conn] [DEBUG]: Response 284 (601.534366607666 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, last_stable_offset=40, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.447 7fd2b6c48f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 41 03/27/2025 02:37:28.447 7fd2b6c48f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.447 7fd2b6c48f60 [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=41, max_bytes=1048576)])]) 03/27/2025 02:37:28.447 7fd2b6c48f60 [kafka.conn] [DEBUG]: Request 285: 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=41, max_bytes=1048576)])]) 03/27/2025 02:37:28.449 7fd2b6b99eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 03/27/2025 02:37:28.449 7fd2b6b99eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.449 7fd2b6b99eb8 [kafka.conn] [DEBUG]: Response 284 (602.5817394256592 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=40, last_stable_offset=40, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.449 7fd2b69d2978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 272 03/27/2025 02:37:28.450 7fd2b69d2978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.450 7fd2b69d2978 [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=272, max_bytes=1048576)])]) 03/27/2025 02:37:28.450 7fd2b69d2978 [kafka.conn] [DEBUG]: Request 314: 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=272, max_bytes=1048576)])]) 03/27/2025 02:37:28.450 7fd2b5ce6780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 03/27/2025 02:37:28.450 7fd2b5ce6780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.450 7fd2b5ce6780 [kafka.conn] [DEBUG]: Response 304 (603.2528877258301 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.451 7fd2b69d2588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 03/27/2025 02:37:28.451 7fd2b69d2588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.451 7fd2b69d2588 [kafka.conn] [DEBUG]: Response 300 (602.7846336364746 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.481 7fd2b7bc1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 51 03/27/2025 02:37:28.481 7fd2b7bc1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.481 7fd2b7bc1828 [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=51, max_bytes=1048576)])]) 03/27/2025 02:37:28.482 7fd2b7bc1828 [kafka.conn] [DEBUG]: Request 290: 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=51, max_bytes=1048576)])]) 03/27/2025 02:37:28.507 7fd2b5ce64e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 327 03/27/2025 02:37:28.507 7fd2b5ce64e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.507 7fd2b5ce64e0 [kafka.conn] [DEBUG]: Response 327 (601.5865802764893 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=389, last_stable_offset=389, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.537 7fd2b6a0fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4114 03/27/2025 02:37:28.537 7fd2b6a0fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.537 7fd2b6a0fb70 [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=4114, max_bytes=1048576)])]) 03/27/2025 02:37:28.537 7fd2b6a0fb70 [kafka.conn] [DEBUG]: Request 448: 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=4114, max_bytes=1048576)])]) 03/27/2025 02:37:28.538 7fd2b69d2c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 105 03/27/2025 02:37:28.538 7fd2b69d2c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.538 7fd2b69d2c18 [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=105, max_bytes=1048576)])]) 03/27/2025 02:37:28.538 7fd2b69d2c18 [kafka.conn] [DEBUG]: Request 294: 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=105, max_bytes=1048576)])]) 03/27/2025 02:37:28.538 7fd2b6a83c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4 03/27/2025 02:37:28.539 7fd2b6a83c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.539 7fd2b6a83c18 [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=4, max_bytes=1048576)])]) 03/27/2025 02:37:28.539 7fd2b6a83c18 [kafka.conn] [DEBUG]: Request 275: 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=4, max_bytes=1048576)])]) 03/27/2025 02:37:28.539 7fd2b5ce6a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 03/27/2025 02:37:28.539 7fd2b5ce6a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.539 7fd2b5ce6a20 [kafka.conn] [DEBUG]: Response 290 (602.5435924530029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=72, last_stable_offset=72, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:37:28.541 7fd2b7aa1780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 4 03/27/2025 02:37:28.541 7fd2b7aa1780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.542 7fd2b7aa1780 [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=4, max_bytes=1048576)])]) 03/27/2025 02:37:28.542 7fd2b7aa1780 [kafka.conn] [DEBUG]: Request 276: 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=4, max_bytes=1048576)])]) 03/27/2025 02:37:28.544 7fd2b6a0f0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 3 03/27/2025 02:37:28.544 7fd2b6a0f0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.544 7fd2b6a0f0f0 [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=3, max_bytes=1048576)])]) 03/27/2025 02:37:28.544 7fd2b6a0f0f0 [kafka.conn] [DEBUG]: Request 276: 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=3, max_bytes=1048576)])]) 03/27/2025 02:37:28.546 7fd2b6c3ccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 03/27/2025 02:37:28.546 7fd2b6c3ccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:37:28.546 7fd2b6c3ccc0 [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=4, max_bytes=1048576)])]) 03/27/2025 02:37:28.546 7fd2b6c3ccc0 [kafka.conn] [DEBUG]: Request 277: 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=4, max_bytes=1048576)])]) 03/27/2025 02:37:28.548 7fd2b6ba3198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 03/27/2025 02:37:28.548 7fd2b6ba3198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:37:28.548 7fd2b6ba3198 [kafka.conn] [DEBUG]: Response 281 (601.7265319824219 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])])