02/13/2025 02:40:58.739 7faa943ca8d0 [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-6', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 02/13/2025 02:40:58.741 7faa96e4c438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 29 02/13/2025 02:40:58.741 7faa96e4c438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.741 7faa96e4c438 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 02/13/2025 02:40:58.741 7faa96e4c438 [kafka.conn] [DEBUG]: Request 288: 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=29, max_bytes=1048576)])]) 02/13/2025 02:40:58.744 7faa96a38cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 482 02/13/2025 02:40:58.744 7faa96a38cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:58.744 7faa96a38cc0 [kafka.conn] [DEBUG]: Response 482 (600.9230613708496 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4056, last_stable_offset=4056, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:58.746 7faa95b62a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 02/13/2025 02:40:58.746 7faa95b62a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:58.746 7faa95b62a20 [kafka.conn] [DEBUG]: Response 306 (600.7781028747559 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:58.777 7faa96db1eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4 02/13/2025 02:40:58.777 7faa96db1eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.777 7faa96db1eb8 [kafka.protocol.parser] [DEBUG]: 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)])]) 02/13/2025 02:40:58.777 7faa96db1eb8 [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-7', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 02/13/2025 02:40:58.778 7faa96dbfd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 1 02/13/2025 02:40:58.778 7faa96dbfd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.778 7faa96dbfd68 [kafka.protocol.parser] [DEBUG]: 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)])]) 02/13/2025 02:40:58.778 7faa96dbfd68 [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-9', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 02/13/2025 02:40:58.807 7faa96db1588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 33 02/13/2025 02:40:58.807 7faa96db1588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.807 7faa96db1588 [kafka.protocol.parser] [DEBUG]: 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=33, max_bytes=1048576)])]) 02/13/2025 02:40:58.808 7faa96db1588 [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-14', partitions=[(partition=0, offset=33, max_bytes=1048576)])]) 02/13/2025 02:40:58.826 7faa96a42eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 32 02/13/2025 02:40:58.826 7faa96a42eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.826 7faa96a42eb8 [kafka.protocol.parser] [DEBUG]: 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=32, max_bytes=1048576)])]) 02/13/2025 02:40:58.827 7faa96a42eb8 [kafka.conn] [DEBUG]: Request 289: 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=32, max_bytes=1048576)])]) 02/13/2025 02:40:58.827 7faa96a42f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 40 02/13/2025 02:40:58.827 7faa96a42f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.827 7faa96a42f60 [kafka.protocol.parser] [DEBUG]: 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)])]) 02/13/2025 02:40:58.827 7faa96a42f60 [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-17', partitions=[(partition=0, offset=40, max_bytes=1048576)])]) 02/13/2025 02:40:58.849 7faa96a428d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 330 02/13/2025 02:40:58.850 7faa96a428d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.850 7faa96a428d0 [kafka.protocol.parser] [DEBUG]: 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=330, max_bytes=1048576)])]) 02/13/2025 02:40:58.850 7faa96a428d0 [kafka.conn] [DEBUG]: Request 335: 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=330, max_bytes=1048576)])]) 02/13/2025 02:40:58.850 7faa95b62780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 93 02/13/2025 02:40:58.850 7faa95b62780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.850 7faa95b62780 [kafka.protocol.parser] [DEBUG]: 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=93, max_bytes=1048576)])]) 02/13/2025 02:40:58.851 7faa95b62780 [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-28', partitions=[(partition=0, offset=93, max_bytes=1048576)])]) 02/13/2025 02:40:58.865 7faa96dbfeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 02/13/2025 02:40:58.866 7faa96dbfeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:58.866 7faa96dbfeb8 [kafka.conn] [DEBUG]: Response 281 (601.2563705444336 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:58.902 7faa96da0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 02/13/2025 02:40:58.903 7faa96da0ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.903 7faa96da0ac8 [kafka.protocol.parser] [DEBUG]: 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=6, max_bytes=1048576)])]) 02/13/2025 02:40:58.903 7faa96da0ac8 [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-4', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 02/13/2025 02:40:58.905 7faa968ac780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 02/13/2025 02:40:58.905 7faa968ac780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:58.905 7faa968ac780 [kafka.conn] [DEBUG]: Response 282 (602.1811962127686 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:58.926 7faa96dc8198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 02/13/2025 02:40:58.926 7faa96dc8198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:58.926 7faa96dc8198 [kafka.conn] [DEBUG]: Response 296 (601.2966632843018 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=50, last_stable_offset=50, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:58.945 7faa95c73b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 288 02/13/2025 02:40:58.945 7faa95c73b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.945 7faa95c73b70 [kafka.protocol.parser] [DEBUG]: 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=288, max_bytes=1048576)])]) 02/13/2025 02:40:58.946 7faa95c73b70 [kafka.conn] [DEBUG]: Request 335: 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=288, max_bytes=1048576)])]) 02/13/2025 02:40:58.960 7faa96dc2828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 42 02/13/2025 02:40:58.960 7faa96dc2828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.960 7faa96dc2828 [kafka.protocol.parser] [DEBUG]: 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=42, max_bytes=1048576)])]) 02/13/2025 02:40:58.961 7faa96dc2828 [kafka.conn] [DEBUG]: Request 296: 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=42, max_bytes=1048576)])]) 02/13/2025 02:40:58.997 7faa96a42a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 32 02/13/2025 02:40:58.998 7faa96a42a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:58.998 7faa96a42a20 [kafka.protocol.parser] [DEBUG]: 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=32, max_bytes=1048576)])]) 02/13/2025 02:40:58.999 7faa96a42a20 [kafka.conn] [DEBUG]: Request 291: 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=32, max_bytes=1048576)])]) 02/13/2025 02:40:59.002 7faa968ac978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 02/13/2025 02:40:59.003 7faa968ac978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.003 7faa968ac978 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 02/13/2025 02:40:59.003 7faa968ac978 [kafka.conn] [DEBUG]: Request 282: 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=0, max_bytes=1048576)])]) 02/13/2025 02:40:59.004 7faa96d9ea20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 02/13/2025 02:40:59.004 7faa96d9ea20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.005 7faa96d9ea20 [kafka.conn] [DEBUG]: Response 282 (601.8016338348389 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.008 7faa95bfa8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 02/13/2025 02:40:59.008 7faa95bfa8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.008 7faa95bfa8d0 [kafka.conn] [DEBUG]: Response 304 (601.1056900024414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.018 7faa96dcdd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 02/13/2025 02:40:59.018 7faa96dcdd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.018 7faa96dcdd68 [kafka.conn] [DEBUG]: Response 297 (601.2077331542969 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=51, last_stable_offset=51, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.030 7faa95b62f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 315 02/13/2025 02:40:59.030 7faa95b62f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.030 7faa95b62f60 [kafka.conn] [DEBUG]: Response 315 (601.3555526733398 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=222, last_stable_offset=222, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.096 7faa96a38780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:40:59.096 7faa96a38780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.096 7faa96a38780 [kafka.protocol.parser] [DEBUG]: 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)])]) 02/13/2025 02:40:59.096 7faa96a38780 [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-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:40:59.100 7faa96a424e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 84 02/13/2025 02:40:59.100 7faa96a424e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.100 7faa96a424e0 [kafka.protocol.parser] [DEBUG]: 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=84, max_bytes=1048576)])]) 02/13/2025 02:40:59.100 7faa96a424e0 [kafka.conn] [DEBUG]: Request 296: 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=84, max_bytes=1048576)])]) 02/13/2025 02:40:59.147 7faa96a42438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 165 02/13/2025 02:40:59.147 7faa96a42438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.147 7faa96a42438 [kafka.protocol.parser] [DEBUG]: 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=165, max_bytes=1048576)])]) 02/13/2025 02:40:59.147 7faa96a42438 [kafka.conn] [DEBUG]: Request 315: 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=165, max_bytes=1048576)])]) 02/13/2025 02:40:59.198 7faa96d9e588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 63 02/13/2025 02:40:59.198 7faa96d9e588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.199 7faa96d9e588 [kafka.protocol.parser] [DEBUG]: 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=63, max_bytes=1048576)])]) 02/13/2025 02:40:59.199 7faa96d9e588 [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-2', partitions=[(partition=0, offset=63, max_bytes=1048576)])]) 02/13/2025 02:40:59.199 7faa95b62cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 90 02/13/2025 02:40:59.200 7faa95b62cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.200 7faa95b62cc0 [kafka.protocol.parser] [DEBUG]: 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=90, max_bytes=1048576)])]) 02/13/2025 02:40:59.200 7faa95b62cc0 [kafka.conn] [DEBUG]: Request 298: 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=90, max_bytes=1048576)])]) 02/13/2025 02:40:59.200 7faa95bfa828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 324 02/13/2025 02:40:59.201 7faa95bfa828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.201 7faa95bfa828 [kafka.conn] [DEBUG]: Response 324 (602.2229194641113 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=303, last_stable_offset=303, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.214 7faa96da0eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 02/13/2025 02:40:59.214 7faa96da0eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.215 7faa96da0eb8 [kafka.conn] [DEBUG]: Response 283 (601.3097763061523 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=3, last_stable_offset=3, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.341 7faa943ca8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 02/13/2025 02:40:59.341 7faa943ca8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.341 7faa943ca8d0 [kafka.conn] [DEBUG]: Response 284 (601.771354675293 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.342 7faa96e4c438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 02/13/2025 02:40:59.342 7faa96e4c438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:40:59.342 7faa96e4c438 [kafka.conn] [DEBUG]: Response 288 (600.9373664855957 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:40:59.345 7faa96a38cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4056 02/13/2025 02:40:59.345 7faa96a38cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.345 7faa96a38cc0 [kafka.protocol.parser] [DEBUG]: 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=4056, max_bytes=1048576)])]) 02/13/2025 02:40:59.345 7faa96a38cc0 [kafka.conn] [DEBUG]: Request 483: 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=4056, max_bytes=1048576)])]) 02/13/2025 02:40:59.346 7faa95b62a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 156 02/13/2025 02:40:59.346 7faa95b62a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:40:59.346 7faa95b62a20 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 02/13/2025 02:40:59.347 7faa95b62a20 [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-27', partitions=[(partition=0, offset=156, max_bytes=1048576)])])