01/30/2025 02:35:28.689 7f3c77b5be10 [kafka.conn] [DEBUG]: Response 532 (600.8117198944092 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=109, last_stable_offset=109, aborted_transactions=NULL, message_set=b'')])]) 01/30/2025 02:35:28.691 7f3c75fc6cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 01/30/2025 02:35:28.691 7f3c75fc6cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:28.691 7f3c75fc6cc0 [kafka.conn] [DEBUG]: Response 513 (600.7163524627686 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 01/30/2025 02:35:28.701 7f3c783160f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 01/30/2025 02:35:28.701 7f3c783160f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:28.701 7f3c783160f0 [kafka.conn] [DEBUG]: Response 520 (600.7797718048096 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=52, last_stable_offset=52, aborted_transactions=NULL, message_set=b'')])]) 01/30/2025 02:35:28.702 7f3c77a7ec18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 64 01/30/2025 02:35:28.702 7f3c77a7ec18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.702 7f3c77a7ec18 [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=64, max_bytes=1048576)])]) 01/30/2025 02:35:28.703 7f3c77a7ec18 [kafka.conn] [DEBUG]: Request 520: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=64, max_bytes=1048576)])]) 01/30/2025 02:35:28.704 7f3c77b5bac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 139 01/30/2025 02:35:28.704 7f3c77b5bac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.704 7f3c77b5bac8 [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=139, max_bytes=1048576)])]) 01/30/2025 02:35:28.704 7f3c77b5bac8 [kafka.conn] [DEBUG]: Request 531: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=139, max_bytes=1048576)])]) 01/30/2025 02:35:28.781 7f3c75fc6b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 525 01/30/2025 02:35:28.781 7f3c75fc6b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:28.781 7f3c75fc6b70 [kafka.conn] [DEBUG]: Response 525 (601.0992527008057 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=95, last_stable_offset=95, aborted_transactions=NULL, message_set=b'')])]) 01/30/2025 02:35:28.782 7f3c7736d8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 102 01/30/2025 02:35:28.783 7f3c7736d8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.783 7f3c7736d8d0 [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=102, max_bytes=1048576)])]) 01/30/2025 02:35:28.783 7f3c7736d8d0 [kafka.conn] [DEBUG]: Request 529: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=102, max_bytes=1048576)])]) 01/30/2025 02:35:28.797 7f3c75a994e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 18 01/30/2025 02:35:28.797 7f3c75a994e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.797 7f3c75a994e0 [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=18, max_bytes=1048576)])]) 01/30/2025 02:35:28.798 7f3c75a994e0 [kafka.conn] [DEBUG]: Request 512: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 01/30/2025 02:35:28.801 7f3c7831fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 110 01/30/2025 02:35:28.801 7f3c7831fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.801 7f3c7831fb70 [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=110, max_bytes=1048576)])]) 01/30/2025 02:35:28.802 7f3c7831fb70 [kafka.conn] [DEBUG]: Request 528: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=110, max_bytes=1048576)])]) 01/30/2025 02:35:28.857 7f3c78316438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 01/30/2025 02:35:28.857 7f3c78316438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:28.857 7f3c78316438 [kafka.conn] [DEBUG]: Response 521 (601.7467975616455 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=48, last_stable_offset=48, aborted_transactions=NULL, message_set=b'')])]) 01/30/2025 02:35:28.880 7f3c77a7e978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 557 01/30/2025 02:35:28.880 7f3c77a7e978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:28.880 7f3c77a7e978 [kafka.conn] [DEBUG]: Response 557 (600.8317470550537 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=267, last_stable_offset=267, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x01\t\x00\x00\x02\x0f\x00\x00\x00\x00\x02\xc2\xc3\xcfF\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/30/2025 02:35:28.880 7f3c77a7e978 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 265 to buffered record list 01/30/2025 02:35:28.901 7f3c78316198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 27 01/30/2025 02:35:28.901 7f3c78316198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.901 7f3c78316198 [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=27, max_bytes=1048576)])]) 01/30/2025 02:35:28.902 7f3c78316198 [kafka.conn] [DEBUG]: Request 519: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=27, max_bytes=1048576)])]) 01/30/2025 02:35:28.958 7f3c77b5bb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 159 01/30/2025 02:35:28.958 7f3c77b5bb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.958 7f3c77b5bb70 [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=159, max_bytes=1048576)])]) 01/30/2025 02:35:28.958 7f3c77b5bb70 [kafka.conn] [DEBUG]: Request 547: 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=159, max_bytes=1048576)])]) 01/30/2025 02:35:28.978 7f3c782a0c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 01/30/2025 02:35:28.978 7f3c782a0c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:28.979 7f3c782a0c18 [kafka.conn] [DEBUG]: Response 510 (600.9464263916016 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=11, last_stable_offset=11, aborted_transactions=NULL, message_set=b'')])]) 01/30/2025 02:35:28.981 7f3c77a7e978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 267 01/30/2025 02:35:28.981 7f3c77a7e978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:28.981 7f3c77a7e978 [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=267, max_bytes=1048576)])]) 01/30/2025 02:35:28.981 7f3c77a7e978 [kafka.conn] [DEBUG]: Request 558: 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=267, max_bytes=1048576)])]) 01/30/2025 02:35:29.060 7f3c7836ef60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 799 01/30/2025 02:35:29.061 7f3c7836ef60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/30/2025 02:35:29.061 7f3c7836ef60 [kafka.conn] [DEBUG]: Response 799 (601.0434627532959 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2397, last_stable_offset=2397, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t\\\x00\x00\x01\x04\x00\x00\x00\x00\x02\x873\xcf\xa2\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...')])]) 01/30/2025 02:35:29.061 7f3c7836ef60 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2396 to buffered record list 01/30/2025 02:35:29.075 7f3c78322630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 01/30/2025 02:35:29.075 7f3c78322630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/30/2025 02:35:29.075 7f3c78322630 [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/30/2025 02:35:29.075 7f3c78322630 [kafka.conn] [DEBUG]: Request 507: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/30/2025 02:35:29.076 7f3c7831d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0