03/27/2025 02:41:46.642 7f07da903b70 [kafka.conn] [DEBUG]: Response 520 (600.8551120758057 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:46.772 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 551 03/27/2025 02:41:46.772 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:41:46.773 7f07da7bc828 [kafka.conn] [DEBUG]: Response 551 (601.6051769256592 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.29', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-21', 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/27/2025 02:41:46.774 7f07da7bc828 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:41:46.774 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 150 03/27/2025 02:41:46.774 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.774 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 03/27/2025 02:41:46.774 7f07da7bc588 [kafka.conn] [DEBUG]: Request 549: 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=150, max_bytes=1048576)])]) 03/27/2025 02:41:46.777 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 550 03/27/2025 02:41:46.777 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:46.777 7f07da7bc390 [kafka.conn] [DEBUG]: Response 550 (600.8279323577881 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=186, last_stable_offset=186, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:46.848 7f07dabaea20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 41 03/27/2025 02:41:46.849 7f07dabaea20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.849 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: 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=41, max_bytes=1048576)])]) 03/27/2025 02:41:46.849 7f07dabaea20 [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-11', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 03/27/2025 02:41:46.850 7f07dabae2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 52 03/27/2025 02:41:46.850 7f07dabae2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.850 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: 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=52, max_bytes=1048576)])]) 03/27/2025 02:41:46.850 7f07dabae2e8 [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-12', partitions=[(partition=0, offset=52, max_bytes=1048576)])]) 03/27/2025 02:41:46.853 7f07daba5048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 6 03/27/2025 02:41:46.853 7f07daba5048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.853 7f07daba5048 [kafka.protocol.parser] [DEBUG]: 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=6, max_bytes=1048576)])]) 03/27/2025 02:41:46.853 7f07daba5048 [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-10', partitions=[(partition=0, offset=6, max_bytes=1048576)])]) 03/27/2025 02:41:46.935 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:41:46.935 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:46.935 7f07d91e5cc0 [kafka.conn] [DEBUG]: Response 510 (601.508378982544 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=9, last_stable_offset=9, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:46.936 7f07da9c7eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/27/2025 02:41:46.936 7f07da9c7eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.936 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: 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:41:46.936 7f07da9c7eb8 [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-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:46.937 7f07dabae240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/27/2025 02:41:46.937 7f07dabae240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:46.937 7f07dabae240 [kafka.conn] [DEBUG]: Response 518 (600.8620262145996 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:46.940 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 203 03/27/2025 02:41:46.940 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.940 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: 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=203, max_bytes=1048576)])]) 03/27/2025 02:41:46.940 7f07da4b56d8 [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-28', partitions=[(partition=0, offset=203, max_bytes=1048576)])]) 03/27/2025 02:41:46.941 7f07da903390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 15 03/27/2025 02:41:46.942 7f07da903390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.942 7f07da903390 [kafka.protocol.parser] [DEBUG]: 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=15, max_bytes=1048576)])]) 03/27/2025 02:41:46.942 7f07da903390 [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-18', partitions=[(partition=0, offset=15, max_bytes=1048576)])]) 03/27/2025 02:41:46.942 7f07da7bc2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 140 03/27/2025 02:41:46.942 7f07da7bc2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.942 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: 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=140, max_bytes=1048576)])]) 03/27/2025 02:41:46.943 7f07da7bc2e8 [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-24', partitions=[(partition=0, offset=140, max_bytes=1048576)])]) 03/27/2025 02:41:46.945 7f07daba0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 03/27/2025 02:41:46.945 7f07daba0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.945 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 03/27/2025 02:41:46.945 7f07daba0cc0 [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-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:46.953 7f07da3d0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 17 03/27/2025 02:41:46.953 7f07da3d0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.953 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: 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=17, max_bytes=1048576)])]) 03/27/2025 02:41:46.953 7f07da3d0f60 [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-8', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/27/2025 02:41:46.965 7f07da903630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 24 03/27/2025 02:41:46.965 7f07da903630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:46.965 7f07da903630 [kafka.protocol.parser] [DEBUG]: 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=24, max_bytes=1048576)])]) 03/27/2025 02:41:46.965 7f07da903630 [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-16', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 03/27/2025 02:41:46.966 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 770 03/27/2025 02:41:46.966 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:46.966 7f07daba06d8 [kafka.conn] [DEBUG]: Response 770 (603.1291484832764 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2404, last_stable_offset=2404, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.021 7f07da4b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 118 03/27/2025 02:41:47.021 7f07da4b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.021 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: 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=118, max_bytes=1048576)])]) 03/27/2025 02:41:47.022 7f07da4b5eb8 [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-25', partitions=[(partition=0, offset=118, max_bytes=1048576)])]) 03/27/2025 02:41:47.022 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 137 03/27/2025 02:41:47.022 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.022 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: 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=137, max_bytes=1048576)])]) 03/27/2025 02:41:47.023 7f07dab7e2e8 [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-2', partitions=[(partition=0, offset=137, max_bytes=1048576)])]) 03/27/2025 02:41:47.023 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 03/27/2025 02:41:47.023 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.023 7f07da4b5978 [kafka.conn] [DEBUG]: Response 537 (604.468822479248 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=144, last_stable_offset=144, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.024 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 03/27/2025 02:41:47.024 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:41:47.024 7f07da4b5630 [kafka.conn] [DEBUG]: Response 530 (604.5167446136475 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.29', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-29', 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=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 03/27/2025 02:41:47.025 7f07da4b5630 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:41:47.061 7f07daba0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 03/27/2025 02:41:47.061 7f07daba0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.061 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: 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=18, max_bytes=1048576)])]) 03/27/2025 02:41:47.062 7f07daba0e10 [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-6', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 03/27/2025 02:41:47.063 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 03/27/2025 02:41:47.063 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.063 7f07da9c7c18 [kafka.conn] [DEBUG]: Response 517 (600.8837223052979 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.092 7f07da9032e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 131 03/27/2025 02:41:47.092 7f07da9032e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.092 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: 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=131, max_bytes=1048576)])]) 03/27/2025 02:41:47.093 7f07da9032e8 [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-20', partitions=[(partition=0, offset=131, max_bytes=1048576)])]) 03/27/2025 02:41:47.122 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 03/27/2025 02:41:47.123 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:41:47.123 7f07da4b5c18 [kafka.conn] [DEBUG]: Response 540 (602.2379398345947 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.29', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-26', 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/27/2025 02:41:47.124 7f07da4b5c18 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:41:47.166 7f07da9c7ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 11 03/27/2025 02:41:47.166 7f07da9c7ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.166 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: 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=11, max_bytes=1048576)])]) 03/27/2025 02:41:47.167 7f07da9c7ac8 [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-9', partitions=[(partition=0, offset=11, max_bytes=1048576)])]) 03/27/2025 02:41:47.167 7f07dab3a198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:41:47.167 7f07dab3a198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.167 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: 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/27/2025 02:41:47.168 7f07dab3a198 [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-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:47.169 7f07dabaeb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 22 03/27/2025 02:41:47.169 7f07dabaeb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.169 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: 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=22, max_bytes=1048576)])]) 03/27/2025 02:41:47.169 7f07dabaeb70 [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-19', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 03/27/2025 02:41:47.211 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/27/2025 02:41:47.211 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.211 7f07da9038d0 [kafka.conn] [DEBUG]: Response 520 (601.1321544647217 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=60, last_stable_offset=60, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.241 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:41:47.241 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.242 7f07dabaee10 [kafka.conn] [DEBUG]: Response 513 (601.2008190155029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.243 7f07da903b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 56 03/27/2025 02:41:47.243 7f07da903b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.243 7f07da903b70 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 03/27/2025 02:41:47.244 7f07da903b70 [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-14', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 03/27/2025 02:41:47.374 7f07da7bc828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 228 03/27/2025 02:41:47.374 7f07da7bc828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.375 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: 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=228, max_bytes=1048576)])]) 03/27/2025 02:41:47.375 7f07da7bc828 [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-21', partitions=[(partition=0, offset=228, max_bytes=1048576)])]) 03/27/2025 02:41:47.375 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 549 03/27/2025 02:41:47.375 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.376 7f07da7bc588 [kafka.conn] [DEBUG]: Response 549 (601.306676864624 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.377 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 186 03/27/2025 02:41:47.378 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.378 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: 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=186, max_bytes=1048576)])]) 03/27/2025 02:41:47.378 7f07da7bc390 [kafka.conn] [DEBUG]: Request 551: 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=186, max_bytes=1048576)])]) 03/27/2025 02:41:47.450 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/27/2025 02:41:47.450 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.450 7f07dabaea20 [kafka.conn] [DEBUG]: Response 518 (601.3505458831787 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.451 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/27/2025 02:41:47.451 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.451 7f07dabae2e8 [kafka.conn] [DEBUG]: Response 520 (600.7752418518066 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=52, last_stable_offset=52, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.454 7f07daba5048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:41:47.454 7f07daba5048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.454 7f07daba5048 [kafka.conn] [DEBUG]: Response 508 (600.7821559906006 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.536 7f07d91e5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 9 03/27/2025 02:41:47.538 7f07d91e5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.538 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: 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=9, max_bytes=1048576)])]) 03/27/2025 02:41:47.539 7f07d91e5cc0 [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-5', partitions=[(partition=0, offset=9, max_bytes=1048576)])]) 03/27/2025 02:41:47.539 7f07dabae240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 61 03/27/2025 02:41:47.539 7f07dabae240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.539 7f07dabae240 [kafka.protocol.parser] [DEBUG]: 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=61, max_bytes=1048576)])]) 03/27/2025 02:41:47.540 7f07dabae240 [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-13', partitions=[(partition=0, offset=61, max_bytes=1048576)])]) 03/27/2025 02:41:47.540 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/27/2025 02:41:47.540 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.540 7f07da9c7eb8 [kafka.conn] [DEBUG]: Response 505 (604.1252613067627 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.541 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 03/27/2025 02:41:47.541 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.541 7f07da4b56d8 [kafka.conn] [DEBUG]: Response 541 (600.8212566375732 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=205, last_stable_offset=205, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xcb\x00\x00\x02\x0f\x00\x00\x00\x00\x02|\x80\x99x\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 03/27/2025 02:41:47.541 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 203 to buffered record list 03/27/2025 02:41:47.542 7f07da903390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:47.542 7f07da903390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.543 7f07da903390 [kafka.conn] [DEBUG]: Response 512 (600.7990837097168 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.543 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 03/27/2025 02:41:47.543 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.543 7f07da7bc2e8 [kafka.conn] [DEBUG]: Response 536 (600.7812023162842 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=140, last_stable_offset=140, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.546 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:41:47.546 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.546 7f07daba0cc0 [kafka.conn] [DEBUG]: Response 507 (600.8090972900391 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.554 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:47.554 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.554 7f07da3d0f60 [kafka.conn] [DEBUG]: Response 512 (600.9588241577148 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.566 7f07da903630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:47.566 7f07da903630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.566 7f07da903630 [kafka.conn] [DEBUG]: Response 512 (601.0277271270752 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.566 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2404 03/27/2025 02:41:47.567 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.567 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: 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=2404, max_bytes=1048576)])]) 03/27/2025 02:41:47.567 7f07daba06d8 [kafka.conn] [DEBUG]: Request 771: 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=2404, max_bytes=1048576)])]) 03/27/2025 02:41:47.567 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 771 03/27/2025 02:41:47.567 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.568 7f07daba06d8 [kafka.conn] [DEBUG]: Response 771 (0.7529258728027344 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2405, last_stable_offset=2405, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\td\x00\x00\x01\x04\x00\x00\x00\x00\x02k\xc1E\x0f\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/27/2025 02:41:47.568 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2404 to buffered record list 03/27/2025 02:41:47.624 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 03/27/2025 02:41:47.625 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.625 7f07da4b5eb8 [kafka.conn] [DEBUG]: Response 528 (603.062629699707 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.625 7f07da4b5978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 144 03/27/2025 02:41:47.625 7f07da4b5978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.625 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: 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=144, max_bytes=1048576)])]) 03/27/2025 02:41:47.626 7f07da4b5978 [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-27', partitions=[(partition=0, offset=144, max_bytes=1048576)])]) 03/27/2025 02:41:47.626 7f07da4b5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 113 03/27/2025 02:41:47.626 7f07da4b5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.626 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: 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=113, max_bytes=1048576)])]) 03/27/2025 02:41:47.626 7f07da4b5630 [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-29', partitions=[(partition=0, offset=113, max_bytes=1048576)])]) 03/27/2025 02:41:47.627 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 535 03/27/2025 02:41:47.627 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.627 7f07dab7e2e8 [kafka.conn] [DEBUG]: Response 535 (604.403018951416 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=137, last_stable_offset=137, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.642 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 205 03/27/2025 02:41:47.642 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.642 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: 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=205, max_bytes=1048576)])]) 03/27/2025 02:41:47.642 7f07da4b56d8 [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-28', partitions=[(partition=0, offset=205, max_bytes=1048576)])]) 03/27/2025 02:41:47.662 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:47.663 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.663 7f07daba0e10 [kafka.conn] [DEBUG]: Response 512 (601.1507511138916 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.664 7f07da9c7c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 03/27/2025 02:41:47.664 7f07da9c7c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.664 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 03/27/2025 02:41:47.664 7f07da9c7c18 [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-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 03/27/2025 02:41:47.668 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2405 03/27/2025 02:41:47.669 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.669 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: 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=2405, max_bytes=1048576)])]) 03/27/2025 02:41:47.669 7f07daba06d8 [kafka.conn] [DEBUG]: Request 772: 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=2405, max_bytes=1048576)])]) 03/27/2025 02:41:47.694 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 03/27/2025 02:41:47.694 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.694 7f07da9032e8 [kafka.conn] [DEBUG]: Response 529 (601.3422012329102 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=131, last_stable_offset=131, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.724 7f07da4b5c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 178 03/27/2025 02:41:47.724 7f07da4b5c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.724 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: 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=178, max_bytes=1048576)])]) 03/27/2025 02:41:47.725 7f07da4b5c18 [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-26', partitions=[(partition=0, offset=178, max_bytes=1048576)])]) 03/27/2025 02:41:47.768 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:41:47.768 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.768 7f07da9c7ac8 [kafka.conn] [DEBUG]: Response 511 (601.381778717041 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.768 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/27/2025 02:41:47.768 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.769 7f07dab3a198 [kafka.conn] [DEBUG]: Response 506 (601.0932922363281 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:41:47.770 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:41:47.770 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.770 7f07dabaeb70 [kafka.conn] [DEBUG]: Response 511 (600.722074508667 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.812 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 60 03/27/2025 02:41:47.812 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.812 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: 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=60, max_bytes=1048576)])]) 03/27/2025 02:41:47.813 7f07da9038d0 [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-15', partitions=[(partition=0, offset=60, max_bytes=1048576)])]) 03/27/2025 02:41:47.842 7f07dabaee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 36 03/27/2025 02:41:47.842 7f07dabaee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.842 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 03/27/2025 02:41:47.843 7f07dabaee10 [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-17', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 03/27/2025 02:41:47.844 7f07da903b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 03/27/2025 02:41:47.844 7f07da903b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.844 7f07da903b70 [kafka.conn] [DEBUG]: Response 521 (600.853681564331 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.976 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 552 03/27/2025 02:41:47.976 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.976 7f07da7bc828 [kafka.conn] [DEBUG]: Response 552 (601.3662815093994 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=228, last_stable_offset=228, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:47.977 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 150 03/27/2025 02:41:47.977 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:47.977 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 03/27/2025 02:41:47.977 7f07da7bc588 [kafka.conn] [DEBUG]: Request 550: 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=150, max_bytes=1048576)])]) 03/27/2025 02:41:47.978 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 551 03/27/2025 02:41:47.978 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:47.979 7f07da7bc390 [kafka.conn] [DEBUG]: Response 551 (600.8608341217041 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xba\x00\x00\x02\x13\x00\x00\x00\x00\x02\xd8J\xae\xc3\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 03/27/2025 02:41:47.979 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 186 to buffered record list 03/27/2025 02:41:48.051 7f07dabaea20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 41 03/27/2025 02:41:48.051 7f07dabaea20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.051 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: 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=41, max_bytes=1048576)])]) 03/27/2025 02:41:48.052 7f07dabaea20 [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-11', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 03/27/2025 02:41:48.052 7f07dabae2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 52 03/27/2025 02:41:48.052 7f07dabae2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.052 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: 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=52, max_bytes=1048576)])]) 03/27/2025 02:41:48.052 7f07dabae2e8 [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-12', partitions=[(partition=0, offset=52, max_bytes=1048576)])]) 03/27/2025 02:41:48.055 7f07daba5048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 6 03/27/2025 02:41:48.055 7f07daba5048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.055 7f07daba5048 [kafka.protocol.parser] [DEBUG]: 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=6, max_bytes=1048576)])]) 03/27/2025 02:41:48.055 7f07daba5048 [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=6, max_bytes=1048576)])]) 03/27/2025 02:41:48.080 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 188 03/27/2025 02:41:48.080 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.080 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: 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=188, max_bytes=1048576)])]) 03/27/2025 02:41:48.080 7f07da7bc390 [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-23', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 03/27/2025 02:41:48.140 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:41:48.141 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.141 7f07d91e5cc0 [kafka.conn] [DEBUG]: Response 511 (602.1251678466797 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=9, last_stable_offset=9, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.141 7f07da9c7eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/27/2025 02:41:48.141 7f07da9c7eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.141 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: 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:41:48.142 7f07da9c7eb8 [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-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:48.142 7f07dabae240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/27/2025 02:41:48.142 7f07dabae240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.142 7f07dabae240 [kafka.conn] [DEBUG]: Response 519 (602.663516998291 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.143 7f07da903390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 15 03/27/2025 02:41:48.143 7f07da903390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.143 7f07da903390 [kafka.protocol.parser] [DEBUG]: 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=15, max_bytes=1048576)])]) 03/27/2025 02:41:48.143 7f07da903390 [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-18', partitions=[(partition=0, offset=15, max_bytes=1048576)])]) 03/27/2025 02:41:48.144 7f07da7bc2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 140 03/27/2025 02:41:48.144 7f07da7bc2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.144 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: 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=140, max_bytes=1048576)])]) 03/27/2025 02:41:48.144 7f07da7bc2e8 [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-24', partitions=[(partition=0, offset=140, max_bytes=1048576)])]) 03/27/2025 02:41:48.147 7f07daba0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 03/27/2025 02:41:48.147 7f07daba0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.147 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 03/27/2025 02:41:48.147 7f07daba0cc0 [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-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:48.155 7f07da3d0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 17 03/27/2025 02:41:48.155 7f07da3d0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.155 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: 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=17, max_bytes=1048576)])]) 03/27/2025 02:41:48.155 7f07da3d0f60 [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-8', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/27/2025 02:41:48.167 7f07da903630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 24 03/27/2025 02:41:48.167 7f07da903630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.167 7f07da903630 [kafka.protocol.parser] [DEBUG]: 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=24, max_bytes=1048576)])]) 03/27/2025 02:41:48.167 7f07da903630 [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-16', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 03/27/2025 02:41:48.225 7f07da4b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 118 03/27/2025 02:41:48.226 7f07da4b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.226 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: 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=118, max_bytes=1048576)])]) 03/27/2025 02:41:48.226 7f07da4b5eb8 [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-25', partitions=[(partition=0, offset=118, max_bytes=1048576)])]) 03/27/2025 02:41:48.227 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 538 03/27/2025 02:41:48.227 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.227 7f07da4b5978 [kafka.conn] [DEBUG]: Response 538 (601.515531539917 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=144, last_stable_offset=144, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.227 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 137 03/27/2025 02:41:48.228 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.228 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: 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=137, max_bytes=1048576)])]) 03/27/2025 02:41:48.228 7f07dab7e2e8 [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-2', partitions=[(partition=0, offset=137, max_bytes=1048576)])]) 03/27/2025 02:41:48.228 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 531 03/27/2025 02:41:48.228 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.228 7f07da4b5630 [kafka.conn] [DEBUG]: Response 531 (602.2615432739258 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=113, last_stable_offset=113, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.229 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 03/27/2025 02:41:48.229 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.229 7f07dab7e2e8 [kafka.conn] [DEBUG]: Response 536 (1.2149810791015625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=139, last_stable_offset=139, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x89\x00\x00\x01\xc7\x00\x00\x00\x00\x02\xef\xb5C\\\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\x90\x03\x00\x00\x00\xd2\x02ObjectVRouter:cn-jenkins-deploy-...')])]) 03/27/2025 02:41:48.229 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 137 to buffered record list 03/27/2025 02:41:48.243 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 542 03/27/2025 02:41:48.243 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.243 7f07da4b56d8 [kafka.conn] [DEBUG]: Response 542 (601.0937690734863 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=205, last_stable_offset=205, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.263 7f07daba0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 03/27/2025 02:41:48.264 7f07daba0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.264 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: 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=18, max_bytes=1048576)])]) 03/27/2025 02:41:48.264 7f07daba0e10 [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-6', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 03/27/2025 02:41:48.265 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/27/2025 02:41:48.265 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.265 7f07da9c7c18 [kafka.conn] [DEBUG]: Response 518 (600.9683609008789 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.269 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 772 03/27/2025 02:41:48.270 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.270 7f07daba06d8 [kafka.conn] [DEBUG]: Response 772 (600.888729095459 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2405, last_stable_offset=2405, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.295 7f07da9032e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 131 03/27/2025 02:41:48.295 7f07da9032e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.295 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: 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=131, max_bytes=1048576)])]) 03/27/2025 02:41:48.295 7f07da9032e8 [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-20', partitions=[(partition=0, offset=131, max_bytes=1048576)])]) 03/27/2025 02:41:48.326 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 03/27/2025 02:41:48.326 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.326 7f07da4b5c18 [kafka.conn] [DEBUG]: Response 541 (601.3805866241455 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=178, last_stable_offset=178, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.330 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 139 03/27/2025 02:41:48.330 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.330 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: 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=139, max_bytes=1048576)])]) 03/27/2025 02:41:48.331 7f07dab7e2e8 [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-2', partitions=[(partition=0, offset=139, max_bytes=1048576)])]) 03/27/2025 02:41:48.369 7f07da9c7ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 11 03/27/2025 02:41:48.369 7f07da9c7ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.369 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: 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=11, max_bytes=1048576)])]) 03/27/2025 02:41:48.370 7f07da9c7ac8 [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-9', partitions=[(partition=0, offset=11, max_bytes=1048576)])]) 03/27/2025 02:41:48.371 7f07dab3a198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:41:48.372 7f07dab3a198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.372 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: 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/27/2025 02:41:48.373 7f07dab3a198 [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-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:48.374 7f07dabaeb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 22 03/27/2025 02:41:48.374 7f07dabaeb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.374 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: 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=22, max_bytes=1048576)])]) 03/27/2025 02:41:48.375 7f07dabaeb70 [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-19', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 03/27/2025 02:41:48.413 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 03/27/2025 02:41:48.414 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.414 7f07da9038d0 [kafka.conn] [DEBUG]: Response 521 (601.3650894165039 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00<\x00\x00\x01\x17\x00\x00\x00\x00\x02\xb7y\xe2\xd6\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\xc8\x03\x00\x00\x00\x8a\x03ObjectVMITable:default-global-sy...')])]) 03/27/2025 02:41:48.414 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-15', partition=0) with offset 60 to buffered record list 03/27/2025 02:41:48.444 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 514 03/27/2025 02:41:48.444 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.444 7f07dabaee10 [kafka.conn] [DEBUG]: Response 514 (601.2885570526123 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.445 7f07da903b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 56 03/27/2025 02:41:48.445 7f07da903b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.445 7f07da903b70 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 03/27/2025 02:41:48.445 7f07da903b70 [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-14', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 03/27/2025 02:41:48.515 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 61 03/27/2025 02:41:48.515 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.515 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: 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=61, max_bytes=1048576)])]) 03/27/2025 02:41:48.515 7f07da9038d0 [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-15', partitions=[(partition=0, offset=61, max_bytes=1048576)])]) 03/27/2025 02:41:48.577 7f07da7bc828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 228 03/27/2025 02:41:48.577 7f07da7bc828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.577 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: 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=228, max_bytes=1048576)])]) 03/27/2025 02:41:48.577 7f07da7bc828 [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-21', partitions=[(partition=0, offset=228, max_bytes=1048576)])]) 03/27/2025 02:41:48.578 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 550 03/27/2025 02:41:48.578 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.578 7f07da7bc588 [kafka.conn] [DEBUG]: Response 550 (601.3505458831787 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=151, last_stable_offset=151, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x96\x00\x00\x00\xfc\x00\x00\x00\x00\x02\xa9o\xb7\x01\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\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...')])]) 03/27/2025 02:41:48.579 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 150 to buffered record list 03/27/2025 02:41:48.653 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/27/2025 02:41:48.653 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.653 7f07dabaea20 [kafka.conn] [DEBUG]: Response 519 (601.9210815429688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.654 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 03/27/2025 02:41:48.654 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.654 7f07dabae2e8 [kafka.conn] [DEBUG]: Response 521 (601.9437313079834 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=52, last_stable_offset=52, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.656 7f07daba5048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:41:48.656 7f07daba5048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.656 7f07daba5048 [kafka.conn] [DEBUG]: Response 509 (600.8696556091309 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.679 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 151 03/27/2025 02:41:48.679 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.679 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: 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=151, max_bytes=1048576)])]) 03/27/2025 02:41:48.680 7f07da7bc588 [kafka.conn] [DEBUG]: Request 551: 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=151, max_bytes=1048576)])]) 03/27/2025 02:41:48.681 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 552 03/27/2025 02:41:48.681 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.681 7f07da7bc390 [kafka.conn] [DEBUG]: Response 552 (601.0949611663818 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.741 7f07d91e5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 9 03/27/2025 02:41:48.742 7f07d91e5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.742 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: 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=9, max_bytes=1048576)])]) 03/27/2025 02:41:48.742 7f07d91e5cc0 [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-5', partitions=[(partition=0, offset=9, max_bytes=1048576)])]) 03/27/2025 02:41:48.743 7f07dabae240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 61 03/27/2025 02:41:48.743 7f07dabae240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.743 7f07dabae240 [kafka.protocol.parser] [DEBUG]: 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=61, max_bytes=1048576)])]) 03/27/2025 02:41:48.743 7f07dabae240 [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-13', partitions=[(partition=0, offset=61, max_bytes=1048576)])]) 03/27/2025 02:41:48.744 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/27/2025 02:41:48.744 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.744 7f07da9c7eb8 [kafka.conn] [DEBUG]: Response 506 (602.3857593536377 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.744 7f07da903390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:41:48.744 7f07da903390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.745 7f07da903390 [kafka.conn] [DEBUG]: Response 513 (601.1660099029541 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.745 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 03/27/2025 02:41:48.745 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.745 7f07da7bc2e8 [kafka.conn] [DEBUG]: Response 537 (601.0582447052002 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=140, last_stable_offset=140, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.748 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:41:48.748 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.748 7f07daba0cc0 [kafka.conn] [DEBUG]: Response 508 (600.841760635376 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.756 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:41:48.756 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.756 7f07da3d0f60 [kafka.conn] [DEBUG]: Response 513 (601.071834564209 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.768 7f07da903630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:41:48.768 7f07da903630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.768 7f07da903630 [kafka.conn] [DEBUG]: Response 513 (601.104736328125 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.827 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 03/27/2025 02:41:48.827 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.828 7f07da4b5eb8 [kafka.conn] [DEBUG]: Response 529 (601.5377044677734 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.828 7f07da4b5978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 144 03/27/2025 02:41:48.828 7f07da4b5978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.828 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: 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=144, max_bytes=1048576)])]) 03/27/2025 02:41:48.828 7f07da4b5978 [kafka.conn] [DEBUG]: Request 539: 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=144, max_bytes=1048576)])]) 03/27/2025 02:41:48.829 7f07da4b5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 113 03/27/2025 02:41:48.829 7f07da4b5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.829 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: 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=113, max_bytes=1048576)])]) 03/27/2025 02:41:48.829 7f07da4b5630 [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-29', partitions=[(partition=0, offset=113, max_bytes=1048576)])]) 03/27/2025 02:41:48.844 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 205 03/27/2025 02:41:48.844 7f07da4b56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.844 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: 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=205, max_bytes=1048576)])]) 03/27/2025 02:41:48.845 7f07da4b56d8 [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-28', partitions=[(partition=0, offset=205, max_bytes=1048576)])]) 03/27/2025 02:41:48.865 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:41:48.865 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.866 7f07daba0e10 [kafka.conn] [DEBUG]: Response 513 (601.5744209289551 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.866 7f07da9c7c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 03/27/2025 02:41:48.866 7f07da9c7c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.866 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 03/27/2025 02:41:48.867 7f07da9c7c18 [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-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 03/27/2025 02:41:48.876 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2405 03/27/2025 02:41:48.876 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.876 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: 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=2405, max_bytes=1048576)])]) 03/27/2025 02:41:48.876 7f07daba06d8 [kafka.conn] [DEBUG]: Request 773: 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=2405, max_bytes=1048576)])]) 03/27/2025 02:41:48.896 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 03/27/2025 02:41:48.896 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.897 7f07da9032e8 [kafka.conn] [DEBUG]: Response 530 (601.3462543487549 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=131, last_stable_offset=131, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.927 7f07da4b5c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 178 03/27/2025 02:41:48.927 7f07da4b5c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:48.927 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: 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=178, max_bytes=1048576)])]) 03/27/2025 02:41:48.927 7f07da4b5c18 [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-26', partitions=[(partition=0, offset=178, max_bytes=1048576)])]) 03/27/2025 02:41:48.931 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 03/27/2025 02:41:48.932 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.932 7f07dab7e2e8 [kafka.conn] [DEBUG]: Response 537 (601.1505126953125 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=139, last_stable_offset=139, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.976 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:48.977 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.977 7f07da9c7ac8 [kafka.conn] [DEBUG]: Response 512 (606.7943572998047 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:48.977 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:41:48.977 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.978 7f07dab3a198 [kafka.conn] [DEBUG]: Response 507 (604.8815250396729 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:41:48.978 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:48.978 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:48.978 7f07dabaeb70 [kafka.conn] [DEBUG]: Response 512 (603.2049655914307 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.052 7f07dabaee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 36 03/27/2025 02:41:49.052 7f07dabaee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.052 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 03/27/2025 02:41:49.052 7f07dabaee10 [kafka.conn] [DEBUG]: Request 515: 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=36, max_bytes=1048576)])]) 03/27/2025 02:41:49.053 7f07da903b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 03/27/2025 02:41:49.053 7f07da903b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.053 7f07da903b70 [kafka.conn] [DEBUG]: Response 522 (607.8803539276123 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.117 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 03/27/2025 02:41:49.117 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.117 7f07da9038d0 [kafka.conn] [DEBUG]: Response 522 (601.6561985015869 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.178 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 553 03/27/2025 02:41:49.179 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.179 7f07da7bc828 [kafka.conn] [DEBUG]: Response 553 (601.3643741607666 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=228, last_stable_offset=228, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.254 7f07dabaea20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 41 03/27/2025 02:41:49.254 7f07dabaea20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.254 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: 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=41, max_bytes=1048576)])]) 03/27/2025 02:41:49.255 7f07dabaea20 [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-11', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 03/27/2025 02:41:49.255 7f07dabae2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 52 03/27/2025 02:41:49.255 7f07dabae2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.255 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: 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=52, max_bytes=1048576)])]) 03/27/2025 02:41:49.255 7f07dabae2e8 [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-12', partitions=[(partition=0, offset=52, max_bytes=1048576)])]) 03/27/2025 02:41:49.257 7f07daba5048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 6 03/27/2025 02:41:49.257 7f07daba5048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.257 7f07daba5048 [kafka.protocol.parser] [DEBUG]: 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=6, max_bytes=1048576)])]) 03/27/2025 02:41:49.257 7f07daba5048 [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=6, max_bytes=1048576)])]) 03/27/2025 02:41:49.281 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 551 03/27/2025 02:41:49.281 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.281 7f07da7bc588 [kafka.conn] [DEBUG]: Response 551 (601.1340618133545 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=151, last_stable_offset=151, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.282 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 188 03/27/2025 02:41:49.282 7f07da7bc390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.282 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: 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=188, max_bytes=1048576)])]) 03/27/2025 02:41:49.282 7f07da7bc390 [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-23', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 03/27/2025 02:41:49.344 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:41:49.344 7f07d91e5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.344 7f07d91e5cc0 [kafka.conn] [DEBUG]: Response 512 (602.05078125 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=9, last_stable_offset=9, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.345 7f07dabae240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/27/2025 02:41:49.345 7f07dabae240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.345 7f07dabae240 [kafka.conn] [DEBUG]: Response 520 (601.9692420959473 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.345 7f07da9c7eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/27/2025 02:41:49.345 7f07da9c7eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.345 7f07da9c7eb8 [kafka.protocol.parser] [DEBUG]: 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:41:49.346 7f07da9c7eb8 [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-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:49.346 7f07da903390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 15 03/27/2025 02:41:49.346 7f07da903390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.346 7f07da903390 [kafka.protocol.parser] [DEBUG]: 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=15, max_bytes=1048576)])]) 03/27/2025 02:41:49.346 7f07da903390 [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-18', partitions=[(partition=0, offset=15, max_bytes=1048576)])]) 03/27/2025 02:41:49.347 7f07da7bc2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 140 03/27/2025 02:41:49.347 7f07da7bc2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.347 7f07da7bc2e8 [kafka.protocol.parser] [DEBUG]: 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=140, max_bytes=1048576)])]) 03/27/2025 02:41:49.347 7f07da7bc2e8 [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-24', partitions=[(partition=0, offset=140, max_bytes=1048576)])]) 03/27/2025 02:41:49.348 7f07daba0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 03/27/2025 02:41:49.348 7f07daba0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.348 7f07daba0cc0 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 03/27/2025 02:41:49.349 7f07daba0cc0 [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-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:49.357 7f07da3d0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 17 03/27/2025 02:41:49.357 7f07da3d0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.357 7f07da3d0f60 [kafka.protocol.parser] [DEBUG]: 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=17, max_bytes=1048576)])]) 03/27/2025 02:41:49.357 7f07da3d0f60 [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-8', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 03/27/2025 02:41:49.369 7f07da903630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 24 03/27/2025 02:41:49.369 7f07da903630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.369 7f07da903630 [kafka.protocol.parser] [DEBUG]: 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=24, max_bytes=1048576)])]) 03/27/2025 02:41:49.369 7f07da903630 [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-16', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 03/27/2025 02:41:49.428 7f07da4b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 118 03/27/2025 02:41:49.428 7f07da4b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.428 7f07da4b5eb8 [kafka.protocol.parser] [DEBUG]: 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=118, max_bytes=1048576)])]) 03/27/2025 02:41:49.429 7f07da4b5eb8 [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-25', partitions=[(partition=0, offset=118, max_bytes=1048576)])]) 03/27/2025 02:41:49.429 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 539 03/27/2025 02:41:49.429 7f07da4b5978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.429 7f07da4b5978 [kafka.conn] [DEBUG]: Response 539 (601.1860370635986 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=144, last_stable_offset=144, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.430 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 532 03/27/2025 02:41:49.430 7f07da4b5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.430 7f07da4b5630 [kafka.conn] [DEBUG]: Response 532 (601.0684967041016 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=113, last_stable_offset=113, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.445 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 543 03/27/2025 02:41:49.446 7f07da4b56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.446 7f07da4b56d8 [kafka.conn] [DEBUG]: Response 543 (601.1629104614258 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=205, last_stable_offset=205, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.466 7f07daba0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 03/27/2025 02:41:49.466 7f07daba0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.467 7f07daba0e10 [kafka.protocol.parser] [DEBUG]: 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=18, max_bytes=1048576)])]) 03/27/2025 02:41:49.467 7f07daba0e10 [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-6', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 03/27/2025 02:41:49.467 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/27/2025 02:41:49.467 7f07da9c7c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.468 7f07da9c7c18 [kafka.conn] [DEBUG]: Response 519 (601.2005805969238 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.477 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 773 03/27/2025 02:41:49.478 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.478 7f07daba06d8 [kafka.conn] [DEBUG]: Response 773 (601.5651226043701 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2406, last_stable_offset=2406, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\te\x00\x00\x01\x04\x00\x00\x00\x00\x02\xf5\x1d\x9f\x01\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/27/2025 02:41:49.478 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2405 to buffered record list 03/27/2025 02:41:49.497 7f07da9032e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 131 03/27/2025 02:41:49.497 7f07da9032e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.497 7f07da9032e8 [kafka.protocol.parser] [DEBUG]: 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=131, max_bytes=1048576)])]) 03/27/2025 02:41:49.498 7f07da9032e8 [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-20', partitions=[(partition=0, offset=131, max_bytes=1048576)])]) 03/27/2025 02:41:49.529 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 542 03/27/2025 02:41:49.529 7f07da4b5c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.529 7f07da4b5c18 [kafka.conn] [DEBUG]: Response 542 (601.8514633178711 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=178, last_stable_offset=178, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.533 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 139 03/27/2025 02:41:49.533 7f07dab7e2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.533 7f07dab7e2e8 [kafka.protocol.parser] [DEBUG]: 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=139, max_bytes=1048576)])]) 03/27/2025 02:41:49.534 7f07dab7e2e8 [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-2', partitions=[(partition=0, offset=139, max_bytes=1048576)])]) 03/27/2025 02:41:49.577 7f07da9c7ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 11 03/27/2025 02:41:49.578 7f07da9c7ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.578 7f07da9c7ac8 [kafka.protocol.parser] [DEBUG]: 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=11, max_bytes=1048576)])]) 03/27/2025 02:41:49.579 7f07da9c7ac8 [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-9', partitions=[(partition=0, offset=11, max_bytes=1048576)])]) 03/27/2025 02:41:49.580 7f07dab3a198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:41:49.580 7f07dab3a198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.580 7f07dab3a198 [kafka.protocol.parser] [DEBUG]: 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/27/2025 02:41:49.580 7f07dab3a198 [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-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:41:49.581 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2406 03/27/2025 02:41:49.582 7f07daba06d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.582 7f07daba06d8 [kafka.protocol.parser] [DEBUG]: 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=2406, max_bytes=1048576)])]) 03/27/2025 02:41:49.582 7f07daba06d8 [kafka.conn] [DEBUG]: Request 774: 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=2406, max_bytes=1048576)])]) 03/27/2025 02:41:49.583 7f07dabaeb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 22 03/27/2025 02:41:49.583 7f07dabaeb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.583 7f07dabaeb70 [kafka.protocol.parser] [DEBUG]: 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=22, max_bytes=1048576)])]) 03/27/2025 02:41:49.583 7f07dabaeb70 [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-19', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 03/27/2025 02:41:49.653 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 03/27/2025 02:41:49.653 7f07dabaee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.654 7f07dabaee10 [kafka.conn] [DEBUG]: Response 515 (601.5305519104004 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.654 7f07da903b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 56 03/27/2025 02:41:49.654 7f07da903b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.654 7f07da903b70 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 03/27/2025 02:41:49.655 7f07da903b70 [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-14', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 03/27/2025 02:41:49.718 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 61 03/27/2025 02:41:49.718 7f07da9038d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.718 7f07da9038d0 [kafka.protocol.parser] [DEBUG]: 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=61, max_bytes=1048576)])]) 03/27/2025 02:41:49.719 7f07da9038d0 [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-15', partitions=[(partition=0, offset=61, max_bytes=1048576)])]) 03/27/2025 02:41:49.779 7f07da7bc828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 228 03/27/2025 02:41:49.780 7f07da7bc828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.780 7f07da7bc828 [kafka.protocol.parser] [DEBUG]: 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=228, max_bytes=1048576)])]) 03/27/2025 02:41:49.780 7f07da7bc828 [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-21', partitions=[(partition=0, offset=228, max_bytes=1048576)])]) 03/27/2025 02:41:49.856 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/27/2025 02:41:49.856 7f07dabaea20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.857 7f07dabaea20 [kafka.conn] [DEBUG]: Response 520 (602.0152568817139 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.857 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 03/27/2025 02:41:49.857 7f07dabae2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.857 7f07dabae2e8 [kafka.conn] [DEBUG]: Response 522 (601.8779277801514 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=52, last_stable_offset=52, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.858 7f07daba5048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:41:49.858 7f07daba5048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.858 7f07daba5048 [kafka.conn] [DEBUG]: Response 510 (600.8391380310059 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:41:49.881 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 151 03/27/2025 02:41:49.882 7f07da7bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:41:49.882 7f07da7bc588 [kafka.protocol.parser] [DEBUG]: 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=151, max_bytes=1048576)])]) 03/27/2025 02:41:49.882 7f07da7bc588 [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-22', partitions=[(partition=0, offset=151, max_bytes=1048576)])]) 03/27/2025 02:41:49.883 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 553 03/27/2025 02:41:49.883 7f07da7bc390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:41:49.883 7f07da7bc390 [kafka.conn] [DEBUG]: Response 553 (600.9304523468018 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'')])])