01/13/2025 02:51:45.173 7f52af48b2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0 01/13/2025 02:51:45.175 7f52af48b2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.175 7f52af48b2e8 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.176 7f52af48b2e8 [kafka.conn] [DEBUG]: Request 2105: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.186 7f52aeeeca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2076 01/13/2025 02:51:45.187 7f52aeeeca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.187 7f52aeeeca20 [kafka.conn] [DEBUG]: Response 2076 (620.4533576965332 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=86, last_stable_offset=86, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.188 7f52aeeecb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2154 01/13/2025 02:51:45.188 7f52aeeecb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.188 7f52aeeecb70 [kafka.conn] [DEBUG]: Response 2154 (620.3222274780273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=196, last_stable_offset=196, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.189 7f52af49e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2117 01/13/2025 02:51:45.189 7f52af49e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.189 7f52af49e0f0 [kafka.conn] [DEBUG]: Response 2117 (620.1014518737793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=306, last_stable_offset=306, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.189 7f52af01aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 01/13/2025 02:51:45.189 7f52af01aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.190 7f52af01aa20 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/13/2025 02:51:45.190 7f52af01aa20 [kafka.conn] [DEBUG]: Request 2096: 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)])]) 01/13/2025 02:51:45.190 7f52af4f9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 01/13/2025 02:51:45.191 7f52af4f9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.191 7f52af4f9048 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.191 7f52af4f9048 [kafka.conn] [DEBUG]: Request 2046: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.192 7f52af13b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2164 01/13/2025 02:51:45.192 7f52af13b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.192 7f52af13b828 [kafka.conn] [DEBUG]: Response 2164 (619.6935176849365 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=252, last_stable_offset=252, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.193 7f52af49e4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2045 01/13/2025 02:51:45.193 7f52af49e4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.194 7f52af49e4e0 [kafka.conn] [DEBUG]: Response 2045 (619.708776473999 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.194 7f52af01a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2033 01/13/2025 02:51:45.194 7f52af01a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.194 7f52af01a978 [kafka.conn] [DEBUG]: Response 2033 (619.408369064331 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.195 7f52af13bc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2139 01/13/2025 02:51:45.195 7f52af13bc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.195 7f52af13bc18 [kafka.conn] [DEBUG]: Response 2139 (619.1577911376953 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=252, last_stable_offset=252, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.196 7f52af01ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 01/13/2025 02:51:45.196 7f52af01ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.196 7f52af01ab70 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.196 7f52af01ab70 [kafka.conn] [DEBUG]: Request 2046: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.196 7f52af514048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0 01/13/2025 02:51:45.197 7f52af514048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.197 7f52af514048 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.197 7f52af514048 [kafka.conn] [DEBUG]: Request 2045: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.200 7f52af49b978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2095 01/13/2025 02:51:45.200 7f52af49b978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.200 7f52af49b978 [kafka.conn] [DEBUG]: Response 2095 (609.950065612793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.206 7f52af50f588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2096 01/13/2025 02:51:45.206 7f52af50f588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.206 7f52af50f588 [kafka.conn] [DEBUG]: Response 2096 (602.7112007141113 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.207 7f52af0eaa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2035 01/13/2025 02:51:45.207 7f52af0eaa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.207 7f52af0eaa20 [kafka.conn] [DEBUG]: Response 2035 (602.7467250823975 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.208 7f52af493588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2097 01/13/2025 02:51:45.208 7f52af493588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.208 7f52af493588 [kafka.conn] [DEBUG]: Response 2097 (602.4703979492188 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.255 7f52af486e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2060 01/13/2025 02:51:45.256 7f52af486e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.256 7f52af486e10 [kafka.protocol.parser] [DEBUG]: 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=2060, max_bytes=1048576)])]) 01/13/2025 02:51:45.256 7f52af486e10 [kafka.conn] [DEBUG]: Request 2935: 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=2060, max_bytes=1048576)])]) 01/13/2025 02:51:45.277 7f52af13b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2071 01/13/2025 02:51:45.277 7f52af13b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.277 7f52af13b4e0 [kafka.conn] [DEBUG]: Response 2071 (602.1504402160645 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=137, last_stable_offset=137, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.414 7f52af01ad68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 01/13/2025 02:51:45.414 7f52af01ad68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.414 7f52af01ad68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.415 7f52af01ad68 [kafka.conn] [DEBUG]: Request 2035: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.417 7f52af13be10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 84 01/13/2025 02:51:45.417 7f52af13be10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.417 7f52af13be10 [kafka.protocol.parser] [DEBUG]: 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=84, max_bytes=1048576)])]) 01/13/2025 02:51:45.418 7f52af13be10 [kafka.conn] [DEBUG]: Request 2123: 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=84, max_bytes=1048576)])]) 01/13/2025 02:51:45.418 7f52af0e7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 492 01/13/2025 02:51:45.418 7f52af0e7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.418 7f52af0e7780 [kafka.protocol.parser] [DEBUG]: 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=492, max_bytes=1048576)])]) 01/13/2025 02:51:45.418 7f52af0e7780 [kafka.conn] [DEBUG]: Request 2167: 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=492, max_bytes=1048576)])]) 01/13/2025 02:51:45.548 7f52af4f76d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2141 01/13/2025 02:51:45.548 7f52af4f76d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.549 7f52af4f76d8 [kafka.conn] [DEBUG]: Response 2141 (603.1465530395508 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=86, last_stable_offset=86, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.549 7f52af01a8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2096 01/13/2025 02:51:45.549 7f52af01a8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.549 7f52af01a8d0 [kafka.conn] [DEBUG]: Response 2096 (602.961540222168 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.550 7f52af5cfd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/13/2025 02:51:45.550 7f52af5cfd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.551 7f52af5cfd68 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/13/2025 02:51:45.551 7f52af5cfd68 [kafka.conn] [DEBUG]: Request 2104: 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)])]) 01/13/2025 02:51:45.767 7f52af4f9198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2097 01/13/2025 02:51:45.767 7f52af4f9198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.767 7f52af4f9198 [kafka.conn] [DEBUG]: Response 2097 (603.7800312042236 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.768 7f52af13ba20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2172 01/13/2025 02:51:45.768 7f52af13ba20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.768 7f52af13ba20 [kafka.conn] [DEBUG]: Response 2172 (603.893518447876 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=283, last_stable_offset=283, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.769 7f52aedbf390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2092 01/13/2025 02:51:45.769 7f52aedbf390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.769 7f52aedbf390 [kafka.conn] [DEBUG]: Response 2092 (604.2628288269043 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=168, last_stable_offset=168, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.770 7f52af13b6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2107 01/13/2025 02:51:45.770 7f52af13b6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.770 7f52af13b6d8 [kafka.conn] [DEBUG]: Response 2107 (604.144811630249 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=205, last_stable_offset=205, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.771 7f52aef9d048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2044 01/13/2025 02:51:45.771 7f52aef9d048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.772 7f52aef9d048 [kafka.conn] [DEBUG]: Response 2044 (604.5019626617432 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.774 7f52af52aeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2095 01/13/2025 02:51:45.774 7f52af52aeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.774 7f52af52aeb8 [kafka.conn] [DEBUG]: Response 2095 (601.4721393585205 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.776 7f52af48b2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2105 01/13/2025 02:51:45.777 7f52af48b2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.777 7f52af48b2e8 [kafka.conn] [DEBUG]: Response 2105 (601.2401580810547 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.788 7f52aeeeca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 86 01/13/2025 02:51:45.788 7f52aeeeca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.788 7f52aeeeca20 [kafka.protocol.parser] [DEBUG]: 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=86, max_bytes=1048576)])]) 01/13/2025 02:51:45.789 7f52aeeeca20 [kafka.conn] [DEBUG]: Request 2077: 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=86, max_bytes=1048576)])]) 01/13/2025 02:51:45.789 7f52aeeecb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 196 01/13/2025 02:51:45.789 7f52aeeecb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.789 7f52aeeecb70 [kafka.protocol.parser] [DEBUG]: 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=196, max_bytes=1048576)])]) 01/13/2025 02:51:45.790 7f52aeeecb70 [kafka.conn] [DEBUG]: Request 2155: 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=196, max_bytes=1048576)])]) 01/13/2025 02:51:45.790 7f52af49e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 306 01/13/2025 02:51:45.790 7f52af49e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.790 7f52af49e0f0 [kafka.protocol.parser] [DEBUG]: 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=306, max_bytes=1048576)])]) 01/13/2025 02:51:45.791 7f52af49e0f0 [kafka.conn] [DEBUG]: Request 2118: 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=306, max_bytes=1048576)])]) 01/13/2025 02:51:45.792 7f52af01aa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2096 01/13/2025 02:51:45.792 7f52af01aa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.792 7f52af01aa20 [kafka.conn] [DEBUG]: Response 2096 (602.306604385376 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'')])]) 01/13/2025 02:51:45.793 7f52af4f9048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2046 01/13/2025 02:51:45.793 7f52af4f9048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.793 7f52af4f9048 [kafka.conn] [DEBUG]: Response 2046 (602.1878719329834 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.794 7f52af13b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 252 01/13/2025 02:51:45.794 7f52af13b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.794 7f52af13b828 [kafka.protocol.parser] [DEBUG]: 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=252, max_bytes=1048576)])]) 01/13/2025 02:51:45.794 7f52af13b828 [kafka.conn] [DEBUG]: Request 2165: 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=252, max_bytes=1048576)])]) 01/13/2025 02:51:45.794 7f52af49e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 01/13/2025 02:51:45.795 7f52af49e4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.795 7f52af49e4e0 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.795 7f52af49e4e0 [kafka.conn] [DEBUG]: Request 2046: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.796 7f52af01a978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 01/13/2025 02:51:45.796 7f52af01a978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.796 7f52af01a978 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.796 7f52af01a978 [kafka.conn] [DEBUG]: Request 2034: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.797 7f52af13bc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 252 01/13/2025 02:51:45.797 7f52af13bc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.797 7f52af13bc18 [kafka.protocol.parser] [DEBUG]: 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=252, max_bytes=1048576)])]) 01/13/2025 02:51:45.797 7f52af13bc18 [kafka.conn] [DEBUG]: Request 2140: 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=252, max_bytes=1048576)])]) 01/13/2025 02:51:45.798 7f52af01ab70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2046 01/13/2025 02:51:45.798 7f52af01ab70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.798 7f52af01ab70 [kafka.conn] [DEBUG]: Response 2046 (602.1926403045654 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.799 7f52af514048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2045 01/13/2025 02:51:45.799 7f52af514048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.799 7f52af514048 [kafka.conn] [DEBUG]: Response 2045 (602.3232936859131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:45.800 7f52af49b978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0 01/13/2025 02:51:45.800 7f52af49b978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.801 7f52af49b978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.801 7f52af49b978 [kafka.conn] [DEBUG]: Request 2096: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.807 7f52af50f588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 01/13/2025 02:51:45.807 7f52af50f588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.807 7f52af50f588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.808 7f52af50f588 [kafka.conn] [DEBUG]: Request 2097: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.808 7f52af0eaa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0 01/13/2025 02:51:45.808 7f52af0eaa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.808 7f52af0eaa20 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.809 7f52af0eaa20 [kafka.conn] [DEBUG]: Request 2036: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.810 7f52af493588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0 01/13/2025 02:51:45.810 7f52af493588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.810 7f52af493588 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.811 7f52af493588 [kafka.conn] [DEBUG]: Request 2098: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:45.858 7f52af486e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2935 01/13/2025 02:51:45.858 7f52af486e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:45.858 7f52af486e10 [kafka.conn] [DEBUG]: Response 2935 (601.900577545166 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2061, last_stable_offset=2061, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x08\x0c\x00\x00\x00\xfa\x00\x00\x00\x00\x02\xbd\x85\x98\xbf\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\x8e\x03\x00\x00\x00\xd0\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 01/13/2025 02:51:45.858 7f52af486e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2060 to buffered record list 01/13/2025 02:51:45.878 7f52af13b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 137 01/13/2025 02:51:45.879 7f52af13b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.879 7f52af13b4e0 [kafka.protocol.parser] [DEBUG]: 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=137, max_bytes=1048576)])]) 01/13/2025 02:51:45.879 7f52af13b4e0 [kafka.conn] [DEBUG]: Request 2072: 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=137, max_bytes=1048576)])]) 01/13/2025 02:51:45.959 7f52af486e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2061 01/13/2025 02:51:45.960 7f52af486e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:45.960 7f52af486e10 [kafka.protocol.parser] [DEBUG]: 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=2061, max_bytes=1048576)])]) 01/13/2025 02:51:45.960 7f52af486e10 [kafka.conn] [DEBUG]: Request 2936: 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=2061, max_bytes=1048576)])]) 01/13/2025 02:51:46.016 7f52af01ad68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2035 01/13/2025 02:51:46.016 7f52af01ad68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.017 7f52af01ad68 [kafka.conn] [DEBUG]: Response 2035 (601.9439697265625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.018 7f52af13be10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2123 01/13/2025 02:51:46.018 7f52af13be10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.019 7f52af13be10 [kafka.conn] [DEBUG]: Response 2123 (601.2508869171143 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=84, last_stable_offset=84, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.019 7f52af0e7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2167 01/13/2025 02:51:46.020 7f52af0e7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.020 7f52af0e7780 [kafka.conn] [DEBUG]: Response 2167 (601.3379096984863 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=492, last_stable_offset=492, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.149 7f52af4f76d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 86 01/13/2025 02:51:46.150 7f52af4f76d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.150 7f52af4f76d8 [kafka.protocol.parser] [DEBUG]: 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=86, max_bytes=1048576)])]) 01/13/2025 02:51:46.151 7f52af4f76d8 [kafka.conn] [DEBUG]: Request 2142: 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=86, max_bytes=1048576)])]) 01/13/2025 02:51:46.152 7f52af01a8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 01/13/2025 02:51:46.152 7f52af01a8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.152 7f52af01a8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.153 7f52af01a8d0 [kafka.conn] [DEBUG]: Request 2097: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.154 7f52af5cfd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2104 01/13/2025 02:51:46.154 7f52af5cfd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.154 7f52af5cfd68 [kafka.conn] [DEBUG]: Response 2104 (603.1777858734131 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'')])]) 01/13/2025 02:51:46.368 7f52af4f9198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0 01/13/2025 02:51:46.369 7f52af4f9198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.369 7f52af4f9198 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.369 7f52af4f9198 [kafka.conn] [DEBUG]: Request 2098: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.370 7f52af13ba20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 283 01/13/2025 02:51:46.370 7f52af13ba20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.370 7f52af13ba20 [kafka.protocol.parser] [DEBUG]: 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=283, max_bytes=1048576)])]) 01/13/2025 02:51:46.370 7f52af13ba20 [kafka.conn] [DEBUG]: Request 2173: 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=283, max_bytes=1048576)])]) 01/13/2025 02:51:46.371 7f52aedbf390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 168 01/13/2025 02:51:46.371 7f52aedbf390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.371 7f52aedbf390 [kafka.protocol.parser] [DEBUG]: 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=168, max_bytes=1048576)])]) 01/13/2025 02:51:46.372 7f52aedbf390 [kafka.conn] [DEBUG]: Request 2093: 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=168, max_bytes=1048576)])]) 01/13/2025 02:51:46.372 7f52af13b6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 205 01/13/2025 02:51:46.372 7f52af13b6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.372 7f52af13b6d8 [kafka.protocol.parser] [DEBUG]: 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=205, max_bytes=1048576)])]) 01/13/2025 02:51:46.373 7f52af13b6d8 [kafka.conn] [DEBUG]: Request 2108: 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=205, max_bytes=1048576)])]) 01/13/2025 02:51:46.373 7f52aef9d048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0 01/13/2025 02:51:46.373 7f52aef9d048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.373 7f52aef9d048 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.374 7f52aef9d048 [kafka.conn] [DEBUG]: Request 2045: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.375 7f52af52aeb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 01/13/2025 02:51:46.375 7f52af52aeb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.375 7f52af52aeb8 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.376 7f52af52aeb8 [kafka.conn] [DEBUG]: Request 2096: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.378 7f52af48b2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0 01/13/2025 02:51:46.379 7f52af48b2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.379 7f52af48b2e8 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.379 7f52af48b2e8 [kafka.conn] [DEBUG]: Request 2106: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.391 7f52aeeeca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2077 01/13/2025 02:51:46.391 7f52aeeeca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.391 7f52aeeeca20 [kafka.conn] [DEBUG]: Response 2077 (603.1389236450195 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=86, last_stable_offset=86, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.392 7f52aeeecb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2155 01/13/2025 02:51:46.393 7f52aeeecb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.393 7f52aeeecb70 [kafka.conn] [DEBUG]: Response 2155 (603.1777858734131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=196, last_stable_offset=196, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.393 7f52af49e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2118 01/13/2025 02:51:46.393 7f52af49e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.394 7f52af49e0f0 [kafka.conn] [DEBUG]: Response 2118 (602.9808521270752 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=306, last_stable_offset=306, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.394 7f52af01aa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 01/13/2025 02:51:46.394 7f52af01aa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.394 7f52af01aa20 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/13/2025 02:51:46.395 7f52af01aa20 [kafka.conn] [DEBUG]: Request 2097: 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)])]) 01/13/2025 02:51:46.395 7f52af4f9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 01/13/2025 02:51:46.395 7f52af4f9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.395 7f52af4f9048 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.396 7f52af4f9048 [kafka.conn] [DEBUG]: Request 2047: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.397 7f52af13b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2165 01/13/2025 02:51:46.397 7f52af13b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.397 7f52af13b828 [kafka.conn] [DEBUG]: Response 2165 (602.8542518615723 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=252, last_stable_offset=252, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.398 7f52af49e4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2046 01/13/2025 02:51:46.398 7f52af49e4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.398 7f52af49e4e0 [kafka.conn] [DEBUG]: Response 2046 (603.2357215881348 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.399 7f52af01a978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2034 01/13/2025 02:51:46.399 7f52af01a978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.399 7f52af01a978 [kafka.conn] [DEBUG]: Response 2034 (603.2867431640625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.400 7f52af01ab70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0 01/13/2025 02:51:46.400 7f52af01ab70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.400 7f52af01ab70 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.401 7f52af01ab70 [kafka.conn] [DEBUG]: Request 2047: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.401 7f52af13bc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2140 01/13/2025 02:51:46.401 7f52af13bc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.401 7f52af13bc18 [kafka.conn] [DEBUG]: Response 2140 (604.3579578399658 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=253, last_stable_offset=253, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xfc\x00\x00\x00\xf8\x00\x00\x00\x00\x024G\xd1k\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\x8a\x03\x00\x00\x00\xcc\x02ObjectVNTable:default-domain:def...')])]) 01/13/2025 02:51:46.402 7f52af13bc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 252 to buffered record list 01/13/2025 02:51:46.402 7f52af514048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0 01/13/2025 02:51:46.402 7f52af514048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.402 7f52af514048 [kafka.protocol.parser] [DEBUG]: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.403 7f52af514048 [kafka.conn] [DEBUG]: Request 2046: 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=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.404 7f52af49b978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2096 01/13/2025 02:51:46.404 7f52af49b978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.404 7f52af49b978 [kafka.conn] [DEBUG]: Response 2096 (603.3055782318115 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.411 7f52af50f588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2097 01/13/2025 02:51:46.411 7f52af50f588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.411 7f52af50f588 [kafka.conn] [DEBUG]: Response 2097 (603.6496162414551 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.413 7f52af0eaa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2036 01/13/2025 02:51:46.413 7f52af0eaa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.413 7f52af0eaa20 [kafka.conn] [DEBUG]: Response 2036 (604.5010089874268 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.414 7f52af493588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2098 01/13/2025 02:51:46.414 7f52af493588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.414 7f52af493588 [kafka.conn] [DEBUG]: Response 2098 (603.1959056854248 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.481 7f52af13b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2072 01/13/2025 02:51:46.481 7f52af13b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.481 7f52af13b4e0 [kafka.conn] [DEBUG]: Response 2072 (602.0424365997314 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=137, last_stable_offset=137, aborted_transactions=NULL, message_set=b'')])]) 01/13/2025 02:51:46.503 7f52af13bc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 253 01/13/2025 02:51:46.503 7f52af13bc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.503 7f52af13bc18 [kafka.protocol.parser] [DEBUG]: 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=253, max_bytes=1048576)])]) 01/13/2025 02:51:46.503 7f52af13bc18 [kafka.conn] [DEBUG]: Request 2141: 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=253, max_bytes=1048576)])]) 01/13/2025 02:51:46.564 7f52af486e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2936 01/13/2025 02:51:46.564 7f52af486e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/13/2025 02:51:46.564 7f52af486e10 [kafka.conn] [DEBUG]: Response 2936 (604.072093963623 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2063, last_stable_offset=2063, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x08\r\x00\x00\x00\xfa\x00\x00\x00\x00\x025\xc5\x9d\xfd\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\x8e\x03\x00\x00\x00\xd0\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 01/13/2025 02:51:46.564 7f52af486e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2061 to buffered record list 01/13/2025 02:51:46.618 7f52af01ad68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 01/13/2025 02:51:46.618 7f52af01ad68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.618 7f52af01ad68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.618 7f52af01ad68 [kafka.conn] [DEBUG]: Request 2036: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/13/2025 02:51:46.619 7f52af13be10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 84 01/13/2025 02:51:46.619 7f52af13be10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.619 7f52af13be10 [kafka.protocol.parser] [DEBUG]: 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=84, max_bytes=1048576)])]) 01/13/2025 02:51:46.620 7f52af13be10 [kafka.conn] [DEBUG]: Request 2124: 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=84, max_bytes=1048576)])]) 01/13/2025 02:51:46.620 7f52af0e7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 492 01/13/2025 02:51:46.620 7f52af0e7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/13/2025 02:51:46.621 7f52af0e7780 [kafka.protocol.parser] [DEBUG]: 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=492, max_bytes=1048576)])]) 01/13/2025 02:51:46.621 7f52af0e7780 [kafka.conn] [DEBUG]: Request 2168: 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=492, max_bytes=1048576)])])