02/03/2025 02:25:52.484 7fe4b60516d8 [kafka.conn] [DEBUG]: Request 277: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 02/03/2025 02:25:52.484 7fe4b6e156d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6 02/03/2025 02:25:52.484 7fe4b6e156d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.484 7fe4b6e156d8 [kafka.protocol.parser] [DEBUG]: 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=6, max_bytes=1048576)])]) 02/03/2025 02:25:52.485 7fe4b6e156d8 [kafka.conn] [DEBUG]: Request 279: 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=6, max_bytes=1048576)])]) 02/03/2025 02:25:52.523 7fe4b6eaf390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 02/03/2025 02:25:52.523 7fe4b6eaf390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.523 7fe4b6eaf390 [kafka.protocol.parser] [DEBUG]: 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=204, max_bytes=1048576)])]) 02/03/2025 02:25:52.524 7fe4b6eaf390 [kafka.conn] [DEBUG]: Request 302: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=204, max_bytes=1048576)])]) 02/03/2025 02:25:52.524 7fe4b6e150f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1 02/03/2025 02:25:52.524 7fe4b6e150f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.524 7fe4b6e150f0 [kafka.protocol.parser] [DEBUG]: 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=1, max_bytes=1048576)])]) 02/03/2025 02:25:52.525 7fe4b6e150f0 [kafka.conn] [DEBUG]: Request 278: 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=1, max_bytes=1048576)])]) 02/03/2025 02:25:52.562 7fe4b6e15048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 37 02/03/2025 02:25:52.563 7fe4b6e15048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.563 7fe4b6e15048 [kafka.protocol.parser] [DEBUG]: 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=37, max_bytes=1048576)])]) 02/03/2025 02:25:52.563 7fe4b6e15048 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 02/03/2025 02:25:52.564 7fe4b6547780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 02/03/2025 02:25:52.564 7fe4b6547780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.564 7fe4b6547780 [kafka.conn] [DEBUG]: Response 299 (601.5498638153076 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.565 7fe4b6eaf6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 164 02/03/2025 02:25:52.565 7fe4b6eaf6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.565 7fe4b6eaf6d8 [kafka.protocol.parser] [DEBUG]: 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=164, max_bytes=1048576)])]) 02/03/2025 02:25:52.565 7fe4b6eaf6d8 [kafka.conn] [DEBUG]: Request 307: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=164, max_bytes=1048576)])]) 02/03/2025 02:25:52.646 7fe4b6eaf978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 02/03/2025 02:25:52.647 7fe4b6eaf978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.647 7fe4b6eaf978 [kafka.conn] [DEBUG]: Response 294 (601.4397144317627 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.647 7fe4b726d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 3 02/03/2025 02:25:52.647 7fe4b726d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.647 7fe4b726d588 [kafka.protocol.parser] [DEBUG]: 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=3, max_bytes=1048576)])]) 02/03/2025 02:25:52.648 7fe4b726d588 [kafka.conn] [DEBUG]: Request 278: 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=3, max_bytes=1048576)])]) 02/03/2025 02:25:52.752 7fe4b7266ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 02/03/2025 02:25:52.752 7fe4b7266ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.752 7fe4b7266ac8 [kafka.conn] [DEBUG]: Response 287 (602.0641326904297 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=42, last_stable_offset=42, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.753 7fe4b6eddc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 02/03/2025 02:25:52.753 7fe4b6eddc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.753 7fe4b6eddc18 [kafka.conn] [DEBUG]: Response 289 (602.2136211395264 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=43, last_stable_offset=43, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.756 7fe4b726dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 02/03/2025 02:25:52.756 7fe4b726dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.756 7fe4b726dd68 [kafka.protocol.parser] [DEBUG]: 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=59, max_bytes=1048576)])]) 02/03/2025 02:25:52.756 7fe4b726dd68 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=59, max_bytes=1048576)])]) 02/03/2025 02:25:52.773 7fe4b6547240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 02/03/2025 02:25:52.773 7fe4b6547240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.773 7fe4b6547240 [kafka.conn] [DEBUG]: Response 294 (601.2794971466064 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=125, last_stable_offset=125, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.774 7fe4b6eafa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 111 02/03/2025 02:25:52.774 7fe4b6eafa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.774 7fe4b6eafa20 [kafka.protocol.parser] [DEBUG]: 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=111, max_bytes=1048576)])]) 02/03/2025 02:25:52.774 7fe4b6eafa20 [kafka.conn] [DEBUG]: Request 300: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=111, max_bytes=1048576)])]) 02/03/2025 02:25:52.774 7fe4b65474e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 163 02/03/2025 02:25:52.774 7fe4b65474e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.774 7fe4b65474e0 [kafka.protocol.parser] [DEBUG]: 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=163, max_bytes=1048576)])]) 02/03/2025 02:25:52.775 7fe4b65474e0 [kafka.conn] [DEBUG]: Request 305: 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=163, max_bytes=1048576)])]) 02/03/2025 02:25:52.775 7fe4b6e15198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:52.775 7fe4b6e15198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.775 7fe4b6e15198 [kafka.conn] [DEBUG]: Response 278 (600.916862487793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.819 7fe4b6ed3048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 02/03/2025 02:25:52.820 7fe4b6ed3048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.820 7fe4b6ed3048 [kafka.conn] [DEBUG]: Response 307 (601.5346050262451 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.849 7fe4b6ed3ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 316 02/03/2025 02:25:52.849 7fe4b6ed3ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.849 7fe4b6ed3ac8 [kafka.conn] [DEBUG]: Response 316 (601.3703346252441 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.856 7fe4b6edd390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 02/03/2025 02:25:52.856 7fe4b6edd390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.856 7fe4b6edd390 [kafka.conn] [DEBUG]: Response 284 (601.1288166046143 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=26, last_stable_offset=26, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.869 7fe4b6e15978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 02/03/2025 02:25:52.869 7fe4b6e15978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.869 7fe4b6e15978 [kafka.conn] [DEBUG]: Response 277 (601.7918586730957 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.870 7fe4b6e15438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 02/03/2025 02:25:52.870 7fe4b6e15438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.870 7fe4b6e15438 [kafka.conn] [DEBUG]: Response 277 (601.7794609069824 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.870 7fe4b6547048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 425 02/03/2025 02:25:52.870 7fe4b6547048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.870 7fe4b6547048 [kafka.protocol.parser] [DEBUG]: 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=425, max_bytes=1048576)])]) 02/03/2025 02:25:52.871 7fe4b6547048 [kafka.conn] [DEBUG]: Request 332: 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=425, max_bytes=1048576)])]) 02/03/2025 02:25:52.871 7fe4b6edd438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 47 02/03/2025 02:25:52.871 7fe4b6edd438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.871 7fe4b6edd438 [kafka.protocol.parser] [DEBUG]: 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=47, max_bytes=1048576)])]) 02/03/2025 02:25:52.871 7fe4b6edd438 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=47, max_bytes=1048576)])]) 02/03/2025 02:25:52.872 7fe4b7266198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38 02/03/2025 02:25:52.872 7fe4b7266198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.872 7fe4b7266198 [kafka.protocol.parser] [DEBUG]: 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=38, max_bytes=1048576)])]) 02/03/2025 02:25:52.872 7fe4b7266198 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 02/03/2025 02:25:52.935 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 449 02/03/2025 02:25:52.935 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.935 7fe4b726a4e0 [kafka.conn] [DEBUG]: Response 449 (601.3069152832031 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4091, last_stable_offset=4091, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xfa\x00\x00\x01\x04\x00\x00\x00\x00\x02\xfa7c\xe2\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...')])]) 02/03/2025 02:25:52.936 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4090 to buffered record list 02/03/2025 02:25:52.955 7fe4b726d780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 02/03/2025 02:25:52.955 7fe4b726d780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:52.955 7fe4b726d780 [kafka.conn] [DEBUG]: Response 277 (601.2508869171143 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:52.967 7fe4b72b8cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 31 02/03/2025 02:25:52.967 7fe4b72b8cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:52.967 7fe4b72b8cc0 [kafka.protocol.parser] [DEBUG]: 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=31, max_bytes=1048576)])]) 02/03/2025 02:25:52.967 7fe4b72b8cc0 [kafka.conn] [DEBUG]: Request 287: 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=31, max_bytes=1048576)])]) 02/03/2025 02:25:53.025 7fe4b726d4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/03/2025 02:25:53.026 7fe4b726d4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.026 7fe4b726d4e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/03/2025 02:25:53.027 7fe4b726d4e0 [kafka.conn] [DEBUG]: Request 276: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/03/2025 02:25:53.027 7fe4b72ca978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 02/03/2025 02:25:53.027 7fe4b72ca978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.028 7fe4b72ca978 [kafka.conn] [DEBUG]: Response 276 (603.154182434082 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.031 7fe4b6edd978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 57 02/03/2025 02:25:53.031 7fe4b6edd978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.031 7fe4b6edd978 [kafka.protocol.parser] [DEBUG]: 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=57, max_bytes=1048576)])]) 02/03/2025 02:25:53.031 7fe4b6edd978 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=57, max_bytes=1048576)])]) 02/03/2025 02:25:53.036 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4091 02/03/2025 02:25:53.036 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.036 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: 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=4091, max_bytes=1048576)])]) 02/03/2025 02:25:53.037 7fe4b726a4e0 [kafka.conn] [DEBUG]: Request 450: 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=4091, max_bytes=1048576)])]) 02/03/2025 02:25:53.086 7fe4b60516d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 02/03/2025 02:25:53.087 7fe4b60516d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.088 7fe4b60516d8 [kafka.conn] [DEBUG]: Response 277 (604.0728092193604 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.089 7fe4b6e156d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 02/03/2025 02:25:53.089 7fe4b6e156d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.089 7fe4b6e156d8 [kafka.conn] [DEBUG]: Response 279 (604.6578884124756 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.126 7fe4b6eaf390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 302 02/03/2025 02:25:53.126 7fe4b6eaf390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.126 7fe4b6eaf390 [kafka.conn] [DEBUG]: Response 302 (602.6487350463867 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.127 7fe4b6e150f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:53.127 7fe4b6e150f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.127 7fe4b6e150f0 [kafka.conn] [DEBUG]: Response 278 (602.43821144104 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.164 7fe4b6e15048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 02/03/2025 02:25:53.164 7fe4b6e15048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.165 7fe4b6e15048 [kafka.conn] [DEBUG]: Response 290 (601.5748977661133 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.165 7fe4b6547780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 146 02/03/2025 02:25:53.165 7fe4b6547780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.166 7fe4b6547780 [kafka.protocol.parser] [DEBUG]: 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=146, max_bytes=1048576)])]) 02/03/2025 02:25:53.166 7fe4b6547780 [kafka.conn] [DEBUG]: Request 300: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=146, max_bytes=1048576)])]) 02/03/2025 02:25:53.166 7fe4b6eaf6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 02/03/2025 02:25:53.167 7fe4b6eaf6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.167 7fe4b6eaf6d8 [kafka.conn] [DEBUG]: Response 307 (601.7701625823975 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=164, last_stable_offset=164, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.247 7fe4b6eaf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 156 02/03/2025 02:25:53.248 7fe4b6eaf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.248 7fe4b6eaf978 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 02/03/2025 02:25:53.248 7fe4b6eaf978 [kafka.conn] [DEBUG]: Request 295: 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=156, max_bytes=1048576)])]) 02/03/2025 02:25:53.249 7fe4b726d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:53.249 7fe4b726d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.249 7fe4b726d588 [kafka.conn] [DEBUG]: Response 278 (601.365327835083 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=3, last_stable_offset=3, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.353 7fe4b7266ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 42 02/03/2025 02:25:53.353 7fe4b7266ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.353 7fe4b7266ac8 [kafka.protocol.parser] [DEBUG]: 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=42, max_bytes=1048576)])]) 02/03/2025 02:25:53.353 7fe4b7266ac8 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=42, max_bytes=1048576)])]) 02/03/2025 02:25:53.354 7fe4b6eddc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 43 02/03/2025 02:25:53.354 7fe4b6eddc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.354 7fe4b6eddc18 [kafka.protocol.parser] [DEBUG]: 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=43, max_bytes=1048576)])]) 02/03/2025 02:25:53.354 7fe4b6eddc18 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=43, max_bytes=1048576)])]) 02/03/2025 02:25:53.357 7fe4b726dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 02/03/2025 02:25:53.357 7fe4b726dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.357 7fe4b726dd68 [kafka.conn] [DEBUG]: Response 293 (601.0994911193848 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=59, last_stable_offset=59, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.374 7fe4b6547240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 125 02/03/2025 02:25:53.374 7fe4b6547240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.374 7fe4b6547240 [kafka.protocol.parser] [DEBUG]: 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=125, max_bytes=1048576)])]) 02/03/2025 02:25:53.374 7fe4b6547240 [kafka.conn] [DEBUG]: Request 295: 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=125, max_bytes=1048576)])]) 02/03/2025 02:25:53.375 7fe4b6eafa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 02/03/2025 02:25:53.376 7fe4b6eafa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.376 7fe4b6eafa20 [kafka.conn] [DEBUG]: Response 300 (601.7029285430908 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.376 7fe4b6e15198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 4 02/03/2025 02:25:53.376 7fe4b6e15198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.376 7fe4b6e15198 [kafka.protocol.parser] [DEBUG]: 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=4, max_bytes=1048576)])]) 02/03/2025 02:25:53.377 7fe4b6e15198 [kafka.conn] [DEBUG]: Request 279: 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=4, max_bytes=1048576)])]) 02/03/2025 02:25:53.377 7fe4b65474e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 305 02/03/2025 02:25:53.377 7fe4b65474e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.377 7fe4b65474e0 [kafka.conn] [DEBUG]: Response 305 (602.3538112640381 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=163, last_stable_offset=163, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.420 7fe4b6ed3048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 146 02/03/2025 02:25:53.421 7fe4b6ed3048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.421 7fe4b6ed3048 [kafka.protocol.parser] [DEBUG]: 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=146, max_bytes=1048576)])]) 02/03/2025 02:25:53.421 7fe4b6ed3048 [kafka.conn] [DEBUG]: Request 308: 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=146, max_bytes=1048576)])]) 02/03/2025 02:25:53.450 7fe4b6ed3ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 204 02/03/2025 02:25:53.450 7fe4b6ed3ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.450 7fe4b6ed3ac8 [kafka.protocol.parser] [DEBUG]: 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=204, max_bytes=1048576)])]) 02/03/2025 02:25:53.450 7fe4b6ed3ac8 [kafka.conn] [DEBUG]: Request 317: 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=204, max_bytes=1048576)])]) 02/03/2025 02:25:53.457 7fe4b6edd390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 26 02/03/2025 02:25:53.457 7fe4b6edd390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.457 7fe4b6edd390 [kafka.protocol.parser] [DEBUG]: 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=26, max_bytes=1048576)])]) 02/03/2025 02:25:53.457 7fe4b6edd390 [kafka.conn] [DEBUG]: Request 285: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=26, max_bytes=1048576)])]) 02/03/2025 02:25:53.470 7fe4b6e15978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 4 02/03/2025 02:25:53.470 7fe4b6e15978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.470 7fe4b6e15978 [kafka.protocol.parser] [DEBUG]: 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=4, max_bytes=1048576)])]) 02/03/2025 02:25:53.470 7fe4b6e15978 [kafka.conn] [DEBUG]: Request 278: 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=4, max_bytes=1048576)])]) 02/03/2025 02:25:53.471 7fe4b6e15438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4 02/03/2025 02:25:53.471 7fe4b6e15438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.471 7fe4b6e15438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 02/03/2025 02:25:53.471 7fe4b6e15438 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 02/03/2025 02:25:53.472 7fe4b6547048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 02/03/2025 02:25:53.472 7fe4b6547048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.472 7fe4b6547048 [kafka.conn] [DEBUG]: Response 332 (601.5403270721436 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=425, last_stable_offset=425, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.473 7fe4b6edd438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 02/03/2025 02:25:53.473 7fe4b6edd438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.473 7fe4b6edd438 [kafka.conn] [DEBUG]: Response 291 (601.5198230743408 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=47, last_stable_offset=47, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.473 7fe4b7266198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 02/03/2025 02:25:53.473 7fe4b7266198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.474 7fe4b7266198 [kafka.conn] [DEBUG]: Response 290 (601.5095710754395 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.556 7fe4b726d780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 02/03/2025 02:25:53.556 7fe4b726d780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.556 7fe4b726d780 [kafka.protocol.parser] [DEBUG]: 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)])]) 02/03/2025 02:25:53.557 7fe4b726d780 [kafka.conn] [DEBUG]: Request 278: 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)])]) 02/03/2025 02:25:53.568 7fe4b72b8cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 02/03/2025 02:25:53.568 7fe4b72b8cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.569 7fe4b72b8cc0 [kafka.conn] [DEBUG]: Response 287 (601.3782024383545 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.628 7fe4b726d4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 276 02/03/2025 02:25:53.628 7fe4b726d4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.628 7fe4b726d4e0 [kafka.conn] [DEBUG]: Response 276 (602.0865440368652 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'')])]) 02/03/2025 02:25:53.629 7fe4b72ca978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0 02/03/2025 02:25:53.629 7fe4b72ca978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.629 7fe4b72ca978 [kafka.protocol.parser] [DEBUG]: 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)])]) 02/03/2025 02:25:53.629 7fe4b72ca978 [kafka.conn] [DEBUG]: Request 277: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/03/2025 02:25:53.632 7fe4b6edd978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 02/03/2025 02:25:53.632 7fe4b6edd978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.632 7fe4b6edd978 [kafka.conn] [DEBUG]: Response 289 (601.0055541992188 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.637 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 450 02/03/2025 02:25:53.639 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.639 7fe4b726a4e0 [kafka.conn] [DEBUG]: Response 450 (602.5435924530029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4092, last_stable_offset=4092, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xfb\x00\x00\x01\x04\x00\x00\x00\x00\x02\x0eD\x04\xbd\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...')])]) 02/03/2025 02:25:53.639 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4091 to buffered record list 02/03/2025 02:25:53.689 7fe4b60516d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2 02/03/2025 02:25:53.689 7fe4b60516d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.689 7fe4b60516d8 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 02/03/2025 02:25:53.690 7fe4b60516d8 [kafka.conn] [DEBUG]: Request 278: 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=2, max_bytes=1048576)])]) 02/03/2025 02:25:53.690 7fe4b6e156d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6 02/03/2025 02:25:53.690 7fe4b6e156d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.690 7fe4b6e156d8 [kafka.protocol.parser] [DEBUG]: 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=6, max_bytes=1048576)])]) 02/03/2025 02:25:53.691 7fe4b6e156d8 [kafka.conn] [DEBUG]: Request 280: 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=6, max_bytes=1048576)])]) 02/03/2025 02:25:53.727 7fe4b6eaf390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 204 02/03/2025 02:25:53.727 7fe4b6eaf390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.727 7fe4b6eaf390 [kafka.protocol.parser] [DEBUG]: 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=204, max_bytes=1048576)])]) 02/03/2025 02:25:53.728 7fe4b6eaf390 [kafka.conn] [DEBUG]: Request 303: 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=204, max_bytes=1048576)])]) 02/03/2025 02:25:53.728 7fe4b6e150f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1 02/03/2025 02:25:53.728 7fe4b6e150f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.728 7fe4b6e150f0 [kafka.protocol.parser] [DEBUG]: 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=1, max_bytes=1048576)])]) 02/03/2025 02:25:53.728 7fe4b6e150f0 [kafka.conn] [DEBUG]: Request 279: 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=1, max_bytes=1048576)])]) 02/03/2025 02:25:53.740 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4092 02/03/2025 02:25:53.740 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.740 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: 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=4092, max_bytes=1048576)])]) 02/03/2025 02:25:53.741 7fe4b726a4e0 [kafka.conn] [DEBUG]: Request 451: 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=4092, max_bytes=1048576)])]) 02/03/2025 02:25:53.766 7fe4b6e15048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 37 02/03/2025 02:25:53.766 7fe4b6e15048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.766 7fe4b6e15048 [kafka.protocol.parser] [DEBUG]: 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=37, max_bytes=1048576)])]) 02/03/2025 02:25:53.766 7fe4b6e15048 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=37, max_bytes=1048576)])]) 02/03/2025 02:25:53.767 7fe4b6547780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 02/03/2025 02:25:53.767 7fe4b6547780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.767 7fe4b6547780 [kafka.conn] [DEBUG]: Response 300 (601.2709140777588 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.768 7fe4b6eaf6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 164 02/03/2025 02:25:53.768 7fe4b6eaf6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.768 7fe4b6eaf6d8 [kafka.protocol.parser] [DEBUG]: 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=164, max_bytes=1048576)])]) 02/03/2025 02:25:53.768 7fe4b6eaf6d8 [kafka.conn] [DEBUG]: Request 308: 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=164, max_bytes=1048576)])]) 02/03/2025 02:25:53.849 7fe4b6eaf978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 02/03/2025 02:25:53.849 7fe4b6eaf978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.850 7fe4b6eaf978 [kafka.conn] [DEBUG]: Response 295 (601.6929149627686 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.850 7fe4b726d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 3 02/03/2025 02:25:53.850 7fe4b726d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.850 7fe4b726d588 [kafka.protocol.parser] [DEBUG]: 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=3, max_bytes=1048576)])]) 02/03/2025 02:25:53.851 7fe4b726d588 [kafka.conn] [DEBUG]: Request 279: 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=3, max_bytes=1048576)])]) 02/03/2025 02:25:53.955 7fe4b7266ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 02/03/2025 02:25:53.955 7fe4b7266ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.955 7fe4b7266ac8 [kafka.conn] [DEBUG]: Response 288 (601.9072532653809 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=42, last_stable_offset=42, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.956 7fe4b6eddc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 02/03/2025 02:25:53.956 7fe4b6eddc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.956 7fe4b6eddc18 [kafka.conn] [DEBUG]: Response 290 (601.9268035888672 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=43, last_stable_offset=43, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.958 7fe4b726dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 02/03/2025 02:25:53.958 7fe4b726dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.958 7fe4b726dd68 [kafka.protocol.parser] [DEBUG]: 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=59, max_bytes=1048576)])]) 02/03/2025 02:25:53.958 7fe4b726dd68 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=59, max_bytes=1048576)])]) 02/03/2025 02:25:53.976 7fe4b6547240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 02/03/2025 02:25:53.976 7fe4b6547240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.976 7fe4b6547240 [kafka.conn] [DEBUG]: Response 295 (601.938009262085 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=125, last_stable_offset=125, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:53.977 7fe4b6eafa20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 111 02/03/2025 02:25:53.977 7fe4b6eafa20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.977 7fe4b6eafa20 [kafka.protocol.parser] [DEBUG]: 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=111, max_bytes=1048576)])]) 02/03/2025 02:25:53.977 7fe4b6eafa20 [kafka.conn] [DEBUG]: Request 301: 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=111, max_bytes=1048576)])]) 02/03/2025 02:25:53.977 7fe4b65474e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 163 02/03/2025 02:25:53.978 7fe4b65474e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:53.978 7fe4b65474e0 [kafka.protocol.parser] [DEBUG]: 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=163, max_bytes=1048576)])]) 02/03/2025 02:25:53.978 7fe4b65474e0 [kafka.conn] [DEBUG]: Request 306: 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=163, max_bytes=1048576)])]) 02/03/2025 02:25:53.978 7fe4b6e15198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 02/03/2025 02:25:53.978 7fe4b6e15198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:53.979 7fe4b6e15198 [kafka.conn] [DEBUG]: Response 279 (602.1249294281006 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.022 7fe4b6ed3048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 308 02/03/2025 02:25:54.022 7fe4b6ed3048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.023 7fe4b6ed3048 [kafka.conn] [DEBUG]: Response 308 (601.5443801879883 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.051 7fe4b6ed3ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 317 02/03/2025 02:25:54.051 7fe4b6ed3ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.052 7fe4b6ed3ac8 [kafka.conn] [DEBUG]: Response 317 (601.3963222503662 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.058 7fe4b6edd390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 02/03/2025 02:25:54.058 7fe4b6edd390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.058 7fe4b6edd390 [kafka.conn] [DEBUG]: Response 285 (601.2475490570068 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=26, last_stable_offset=26, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.072 7fe4b6e15978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:54.072 7fe4b6e15978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.072 7fe4b6e15978 [kafka.conn] [DEBUG]: Response 278 (601.8502712249756 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.073 7fe4b6e15438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:54.073 7fe4b6e15438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.073 7fe4b6e15438 [kafka.conn] [DEBUG]: Response 278 (601.8276214599609 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.073 7fe4b6547048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 425 02/03/2025 02:25:54.073 7fe4b6547048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.073 7fe4b6547048 [kafka.protocol.parser] [DEBUG]: 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=425, max_bytes=1048576)])]) 02/03/2025 02:25:54.074 7fe4b6547048 [kafka.conn] [DEBUG]: Request 333: 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=425, max_bytes=1048576)])]) 02/03/2025 02:25:54.074 7fe4b6edd438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 47 02/03/2025 02:25:54.074 7fe4b6edd438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.074 7fe4b6edd438 [kafka.protocol.parser] [DEBUG]: 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=47, max_bytes=1048576)])]) 02/03/2025 02:25:54.074 7fe4b6edd438 [kafka.conn] [DEBUG]: Request 292: 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=47, max_bytes=1048576)])]) 02/03/2025 02:25:54.075 7fe4b7266198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38 02/03/2025 02:25:54.075 7fe4b7266198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.075 7fe4b7266198 [kafka.protocol.parser] [DEBUG]: 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=38, max_bytes=1048576)])]) 02/03/2025 02:25:54.075 7fe4b7266198 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 02/03/2025 02:25:54.159 7fe4b726d780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:54.159 7fe4b726d780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.159 7fe4b726d780 [kafka.conn] [DEBUG]: Response 278 (602.2586822509766 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.169 7fe4b72b8cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 31 02/03/2025 02:25:54.169 7fe4b72b8cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.169 7fe4b72b8cc0 [kafka.protocol.parser] [DEBUG]: 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=31, max_bytes=1048576)])]) 02/03/2025 02:25:54.170 7fe4b72b8cc0 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=31, max_bytes=1048576)])]) 02/03/2025 02:25:54.229 7fe4b726d4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/03/2025 02:25:54.229 7fe4b726d4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.229 7fe4b726d4e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/03/2025 02:25:54.230 7fe4b726d4e0 [kafka.conn] [DEBUG]: Request 277: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/03/2025 02:25:54.230 7fe4b72ca978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 02/03/2025 02:25:54.230 7fe4b72ca978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.231 7fe4b72ca978 [kafka.conn] [DEBUG]: Response 277 (601.3178825378418 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.233 7fe4b6edd978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 57 02/03/2025 02:25:54.233 7fe4b6edd978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.233 7fe4b6edd978 [kafka.protocol.parser] [DEBUG]: 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=57, max_bytes=1048576)])]) 02/03/2025 02:25:54.233 7fe4b6edd978 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=57, max_bytes=1048576)])]) 02/03/2025 02:25:54.290 7fe4b60516d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 02/03/2025 02:25:54.291 7fe4b60516d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.291 7fe4b60516d8 [kafka.conn] [DEBUG]: Response 278 (601.2792587280273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.291 7fe4b6e156d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 02/03/2025 02:25:54.291 7fe4b6e156d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.292 7fe4b6e156d8 [kafka.conn] [DEBUG]: Response 280 (600.9278297424316 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.329 7fe4b6eaf390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 02/03/2025 02:25:54.329 7fe4b6eaf390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.330 7fe4b6eaf390 [kafka.conn] [DEBUG]: Response 303 (602.0548343658447 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=204, last_stable_offset=204, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.330 7fe4b6e150f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 02/03/2025 02:25:54.330 7fe4b6e150f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.330 7fe4b6e150f0 [kafka.conn] [DEBUG]: Response 279 (602.2367477416992 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.342 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 451 02/03/2025 02:25:54.342 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.342 7fe4b726a4e0 [kafka.conn] [DEBUG]: Response 451 (601.1641025543213 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4093, last_stable_offset=4093, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xfc\x00\x00\x01\x04\x00\x00\x00\x00\x02\xca\x0e?\xa4\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...')])]) 02/03/2025 02:25:54.342 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4092 to buffered record list 02/03/2025 02:25:54.367 7fe4b6e15048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 02/03/2025 02:25:54.368 7fe4b6e15048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.368 7fe4b6e15048 [kafka.conn] [DEBUG]: Response 291 (601.5479564666748 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=37, last_stable_offset=37, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.368 7fe4b6547780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 146 02/03/2025 02:25:54.368 7fe4b6547780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.368 7fe4b6547780 [kafka.protocol.parser] [DEBUG]: 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=146, max_bytes=1048576)])]) 02/03/2025 02:25:54.369 7fe4b6547780 [kafka.conn] [DEBUG]: Request 301: 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=146, max_bytes=1048576)])]) 02/03/2025 02:25:54.369 7fe4b6eaf6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 308 02/03/2025 02:25:54.369 7fe4b6eaf6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.370 7fe4b6eaf6d8 [kafka.conn] [DEBUG]: Response 308 (601.372241973877 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=164, last_stable_offset=164, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.443 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4093 02/03/2025 02:25:54.443 7fe4b726a4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.443 7fe4b726a4e0 [kafka.protocol.parser] [DEBUG]: 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=4093, max_bytes=1048576)])]) 02/03/2025 02:25:54.444 7fe4b726a4e0 [kafka.conn] [DEBUG]: Request 452: 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=4093, max_bytes=1048576)])]) 02/03/2025 02:25:54.450 7fe4b6eaf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 156 02/03/2025 02:25:54.450 7fe4b6eaf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.451 7fe4b6eaf978 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 02/03/2025 02:25:54.451 7fe4b6eaf978 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=156, max_bytes=1048576)])]) 02/03/2025 02:25:54.451 7fe4b726d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 02/03/2025 02:25:54.451 7fe4b726d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.452 7fe4b726d588 [kafka.conn] [DEBUG]: Response 279 (601.2365818023682 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=3, last_stable_offset=3, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.556 7fe4b7266ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 42 02/03/2025 02:25:54.556 7fe4b7266ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.556 7fe4b7266ac8 [kafka.protocol.parser] [DEBUG]: 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=42, max_bytes=1048576)])]) 02/03/2025 02:25:54.556 7fe4b7266ac8 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=42, max_bytes=1048576)])]) 02/03/2025 02:25:54.557 7fe4b6eddc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 43 02/03/2025 02:25:54.557 7fe4b6eddc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.557 7fe4b6eddc18 [kafka.protocol.parser] [DEBUG]: 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=43, max_bytes=1048576)])]) 02/03/2025 02:25:54.557 7fe4b6eddc18 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=43, max_bytes=1048576)])]) 02/03/2025 02:25:54.559 7fe4b726dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 02/03/2025 02:25:54.559 7fe4b726dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.559 7fe4b726dd68 [kafka.conn] [DEBUG]: Response 294 (601.1373996734619 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=59, last_stable_offset=59, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.577 7fe4b6547240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 125 02/03/2025 02:25:54.577 7fe4b6547240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.577 7fe4b6547240 [kafka.protocol.parser] [DEBUG]: 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=125, max_bytes=1048576)])]) 02/03/2025 02:25:54.577 7fe4b6547240 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=125, max_bytes=1048576)])]) 02/03/2025 02:25:54.579 7fe4b6eafa20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 301 02/03/2025 02:25:54.579 7fe4b6eafa20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.579 7fe4b6eafa20 [kafka.conn] [DEBUG]: Response 301 (601.8435955047607 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/03/2025 02:25:54.579 7fe4b6e15198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 4 02/03/2025 02:25:54.579 7fe4b6e15198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/03/2025 02:25:54.580 7fe4b6e15198 [kafka.protocol.parser] [DEBUG]: 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=4, max_bytes=1048576)])]) 02/03/2025 02:25:54.580 7fe4b6e15198 [kafka.conn] [DEBUG]: Request 280: 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=4, max_bytes=1048576)])]) 02/03/2025 02:25:54.580 7fe4b65474e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 02/03/2025 02:25:54.581 7fe4b65474e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/03/2025 02:25:54.581 7fe4b65474e0 [kafka.conn] [DEBUG]: Response 306 (602.8242111206055 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=163, last_stable_offset=163, aborted_transactions=NULL, message_set=b'')])])