02/13/2025 02:38:07.587 7f892aa42588 [kafka.conn] [DEBUG]: Request 504: 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=20, max_bytes=1048576)])]) 02/13/2025 02:38:07.588 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 02/13/2025 02:38:07.588 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.588 7f892a6a5eb8 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:07.588 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 513: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:07.589 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:07.589 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:07.589 7f892aa42978 [kafka.conn] [DEBUG]: Response 506 (601.517915725708 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:07.589 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 02/13/2025 02:38:07.589 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.589 7f892aa0b630 [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)])]) 02/13/2025 02:38:07.590 7f892aa0b630 [kafka.conn] [DEBUG]: Request 499: 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)])]) 02/13/2025 02:38:07.590 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 143 02/13/2025 02:38:07.590 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.590 7f8929cac0f0 [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=143, max_bytes=1048576)])]) 02/13/2025 02:38:07.590 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 538: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=143, max_bytes=1048576)])]) 02/13/2025 02:38:07.603 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 787 02/13/2025 02:38:07.603 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:07.603 7f892aa07630 [kafka.conn] [DEBUG]: Response 787 (601.3033390045166 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2360, last_stable_offset=2360, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t7\x00\x00\x01\x04\x00\x00\x00\x00\x02GDZ\xcd\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/13/2025 02:38:07.603 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2359 to buffered record list 02/13/2025 02:38:07.607 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 17 02/13/2025 02:38:07.607 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.607 7f89297bb4e0 [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=17, max_bytes=1048576)])]) 02/13/2025 02:38:07.608 7f89297bb4e0 [kafka.conn] [DEBUG]: Request 504: 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=17, max_bytes=1048576)])]) 02/13/2025 02:38:07.609 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 498 02/13/2025 02:38:07.609 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:07.609 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 498 (600.7909774780273 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/13/2025 02:38:07.609 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:07.609 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.609 7f892a51c780 [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=10, max_bytes=1048576)])]) 02/13/2025 02:38:07.609 7f892a51c780 [kafka.conn] [DEBUG]: Request 503: 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=10, max_bytes=1048576)])]) 02/13/2025 02:38:07.703 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 313 02/13/2025 02:38:07.703 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.703 7f8929cac8d0 [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=313, max_bytes=1048576)])]) 02/13/2025 02:38:07.703 7f8929cac8d0 [kafka.conn] [DEBUG]: Request 562: 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=313, max_bytes=1048576)])]) 02/13/2025 02:38:07.704 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 18 02/13/2025 02:38:07.704 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.704 7f892a695d68 [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=18, max_bytes=1048576)])]) 02/13/2025 02:38:07.704 7f892a695d68 [kafka.conn] [DEBUG]: Request 506: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 02/13/2025 02:38:07.705 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2360 02/13/2025 02:38:07.705 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.705 7f892aa07630 [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=2360, max_bytes=1048576)])]) 02/13/2025 02:38:07.705 7f892aa07630 [kafka.conn] [DEBUG]: Request 788: 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=2360, max_bytes=1048576)])]) 02/13/2025 02:38:07.705 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 21 02/13/2025 02:38:07.705 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.705 7f892aa3dd68 [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=21, max_bytes=1048576)])]) 02/13/2025 02:38:07.706 7f892aa3dd68 [kafka.conn] [DEBUG]: Request 506: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=21, max_bytes=1048576)])]) 02/13/2025 02:38:07.706 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 111 02/13/2025 02:38:07.706 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.706 7f892aa0b4e0 [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=111, max_bytes=1048576)])]) 02/13/2025 02:38:07.706 7f892aa0b4e0 [kafka.conn] [DEBUG]: Request 521: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=111, max_bytes=1048576)])]) 02/13/2025 02:38:07.707 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:07.707 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:07.707 7f892aa3d438 [kafka.conn] [DEBUG]: Response 506 (601.41921043396 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:07.823 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 02/13/2025 02:38:07.823 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:07.823 7f892aa30198 [kafka.conn] [DEBUG]: Response 515 (601.2239456176758 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:07.823 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 02/13/2025 02:38:07.824 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.824 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:07.824 7f892aa0b828 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:07.824 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 14 02/13/2025 02:38:07.824 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.824 7f892b2946d8 [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=14, max_bytes=1048576)])]) 02/13/2025 02:38:07.825 7f892b2946d8 [kafka.conn] [DEBUG]: Request 505: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 02/13/2025 02:38:07.900 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 500 02/13/2025 02:38:07.901 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:07.901 7f892a51c4e0 [kafka.conn] [DEBUG]: Response 500 (601.1848449707031 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:07.904 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 02/13/2025 02:38:07.904 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.904 7f892aa42240 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:07.905 7f892aa42240 [kafka.conn] [DEBUG]: Request 515: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:07.921 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 134 02/13/2025 02:38:07.921 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.921 7f8928f7fb70 [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=134, max_bytes=1048576)])]) 02/13/2025 02:38:07.921 7f8928f7fb70 [kafka.conn] [DEBUG]: Request 536: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 02/13/2025 02:38:07.958 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 98 02/13/2025 02:38:07.958 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:07.958 7f8929d22198 [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=98, max_bytes=1048576)])]) 02/13/2025 02:38:07.958 7f8929d22198 [kafka.conn] [DEBUG]: Request 527: 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=98, max_bytes=1048576)])]) 02/13/2025 02:38:08.000 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:08.000 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.000 7f892aa34978 [kafka.conn] [DEBUG]: Response 507 (602.1435260772705 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.001 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 02/13/2025 02:38:08.001 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.001 7f8929d22240 [kafka.conn] [DEBUG]: Response 537 (602.0731925964355 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.018 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 02/13/2025 02:38:08.019 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.019 7f8929cac390 [kafka.conn] [DEBUG]: Response 519 (601.7000675201416 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.019 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 559 02/13/2025 02:38:08.019 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.019 7f8928f7fcc0 [kafka.conn] [DEBUG]: Response 559 (601.7324924468994 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=257, last_stable_offset=257, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.038 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 02/13/2025 02:38:08.038 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.038 7f8929cacb70 [kafka.conn] [DEBUG]: Response 517 (600.9669303894043 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.051 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 02/13/2025 02:38:08.052 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.052 7f892a51ca20 [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=5, max_bytes=1048576)])]) 02/13/2025 02:38:08.052 7f892a51ca20 [kafka.conn] [DEBUG]: Request 501: 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=5, max_bytes=1048576)])]) 02/13/2025 02:38:08.092 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 531 02/13/2025 02:38:08.093 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.093 7f8929d22438 [kafka.conn] [DEBUG]: Response 531 (601.1440753936768 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, last_stable_offset=161, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.111 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 527 02/13/2025 02:38:08.111 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.111 7f8929cac630 [kafka.conn] [DEBUG]: Response 527 (601.1519432067871 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.187 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54 02/13/2025 02:38:08.187 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.187 7f892aa420f0 [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=54, max_bytes=1048576)])]) 02/13/2025 02:38:08.187 7f892aa420f0 [kafka.conn] [DEBUG]: Request 515: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])]) 02/13/2025 02:38:08.189 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:08.189 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.189 7f892aa42588 [kafka.conn] [DEBUG]: Response 504 (601.9327640533447 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.189 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24 02/13/2025 02:38:08.189 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.189 7f892aa42978 [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=24, max_bytes=1048576)])]) 02/13/2025 02:38:08.190 7f892aa42978 [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-15', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 02/13/2025 02:38:08.190 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 02/13/2025 02:38:08.190 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.190 7f892a6a5eb8 [kafka.conn] [DEBUG]: Response 513 (602.2078990936279 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.191 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 499 02/13/2025 02:38:08.191 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.191 7f892aa0b630 [kafka.conn] [DEBUG]: Response 499 (601.3562679290771 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'')])]) 02/13/2025 02:38:08.191 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 538 02/13/2025 02:38:08.191 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.191 7f8929cac0f0 [kafka.conn] [DEBUG]: Response 538 (601.3593673706055 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.209 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:08.209 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.209 7f89297bb4e0 [kafka.conn] [DEBUG]: Response 504 (601.578950881958 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.210 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:38:08.210 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.210 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:08.210 7f892aa0bf60 [kafka.conn] [DEBUG]: Request 499: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:08.211 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 02/13/2025 02:38:08.211 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.211 7f892a51c780 [kafka.conn] [DEBUG]: Response 503 (601.7200946807861 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.306 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 562 02/13/2025 02:38:08.306 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.306 7f8929cac8d0 [kafka.conn] [DEBUG]: Response 562 (602.7097702026367 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=313, last_stable_offset=313, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.307 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:08.307 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.307 7f892a695d68 [kafka.conn] [DEBUG]: Response 506 (602.9558181762695 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.307 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 788 02/13/2025 02:38:08.308 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.308 7f892aa07630 [kafka.conn] [DEBUG]: Response 788 (602.8544902801514 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2361, last_stable_offset=2361, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t8\x00\x00\x01\x04\x00\x00\x00\x00\x02u\xa9M\xd8\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/13/2025 02:38:08.308 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2360 to buffered record list 02/13/2025 02:38:08.308 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:08.308 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.308 7f892aa3dd68 [kafka.conn] [DEBUG]: Response 506 (602.8871536254883 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=21, last_stable_offset=21, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.309 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 02/13/2025 02:38:08.309 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.309 7f892aa0b4e0 [kafka.conn] [DEBUG]: Response 521 (602.8451919555664 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.309 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 02/13/2025 02:38:08.309 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.309 7f892aa3d438 [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=19, max_bytes=1048576)])]) 02/13/2025 02:38:08.310 7f892aa3d438 [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-6', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 02/13/2025 02:38:08.409 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2361 02/13/2025 02:38:08.409 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.409 7f892aa07630 [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=2361, max_bytes=1048576)])]) 02/13/2025 02:38:08.409 7f892aa07630 [kafka.conn] [DEBUG]: Request 789: 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=2361, max_bytes=1048576)])]) 02/13/2025 02:38:08.424 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 75 02/13/2025 02:38:08.424 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.424 7f892aa30198 [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=75, max_bytes=1048576)])]) 02/13/2025 02:38:08.424 7f892aa30198 [kafka.conn] [DEBUG]: Request 516: 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=75, max_bytes=1048576)])]) 02/13/2025 02:38:08.425 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 02/13/2025 02:38:08.425 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.425 7f892aa0b828 [kafka.conn] [DEBUG]: Response 510 (601.4208793640137 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.426 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 02/13/2025 02:38:08.426 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.426 7f892b2946d8 [kafka.conn] [DEBUG]: Response 505 (601.386547088623 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.502 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 02/13/2025 02:38:08.502 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.502 7f892a51c4e0 [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=4, max_bytes=1048576)])]) 02/13/2025 02:38:08.502 7f892a51c4e0 [kafka.conn] [DEBUG]: Request 501: 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=4, max_bytes=1048576)])]) 02/13/2025 02:38:08.505 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 02/13/2025 02:38:08.505 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.505 7f892aa42240 [kafka.conn] [DEBUG]: Response 515 (600.9249687194824 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.522 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 02/13/2025 02:38:08.522 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.522 7f8928f7fb70 [kafka.conn] [DEBUG]: Response 536 (600.9776592254639 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.559 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 527 02/13/2025 02:38:08.559 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.559 7f8929d22198 [kafka.conn] [DEBUG]: Response 527 (601.1965274810791 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=98, last_stable_offset=98, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.601 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 22 02/13/2025 02:38:08.601 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.601 7f892aa34978 [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=22, max_bytes=1048576)])]) 02/13/2025 02:38:08.601 7f892aa34978 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 02/13/2025 02:38:08.602 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 184 02/13/2025 02:38:08.602 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.602 7f8929d22240 [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=184, max_bytes=1048576)])]) 02/13/2025 02:38:08.602 7f8929d22240 [kafka.conn] [DEBUG]: Request 538: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=184, max_bytes=1048576)])]) 02/13/2025 02:38:08.619 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 87 02/13/2025 02:38:08.619 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.620 7f8929cac390 [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=87, max_bytes=1048576)])]) 02/13/2025 02:38:08.620 7f8929cac390 [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=87, max_bytes=1048576)])]) 02/13/2025 02:38:08.620 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 257 02/13/2025 02:38:08.620 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.620 7f8928f7fcc0 [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=257, max_bytes=1048576)])]) 02/13/2025 02:38:08.621 7f8928f7fcc0 [kafka.conn] [DEBUG]: Request 560: 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=257, max_bytes=1048576)])]) 02/13/2025 02:38:08.639 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 65 02/13/2025 02:38:08.639 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.639 7f8929cacb70 [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=65, max_bytes=1048576)])]) 02/13/2025 02:38:08.639 7f8929cacb70 [kafka.conn] [DEBUG]: Request 518: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=65, max_bytes=1048576)])]) 02/13/2025 02:38:08.653 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 02/13/2025 02:38:08.653 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.653 7f892a51ca20 [kafka.conn] [DEBUG]: Response 501 (600.9554862976074 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.693 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 161 02/13/2025 02:38:08.694 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.694 7f8929d22438 [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=161, max_bytes=1048576)])]) 02/13/2025 02:38:08.694 7f8929d22438 [kafka.conn] [DEBUG]: Request 532: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=161, max_bytes=1048576)])]) 02/13/2025 02:38:08.712 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 146 02/13/2025 02:38:08.712 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.712 7f8929cac630 [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=146, max_bytes=1048576)])]) 02/13/2025 02:38:08.713 7f8929cac630 [kafka.conn] [DEBUG]: Request 528: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=146, max_bytes=1048576)])]) 02/13/2025 02:38:08.788 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 02/13/2025 02:38:08.788 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.789 7f892aa420f0 [kafka.conn] [DEBUG]: Response 515 (601.2363433837891 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.789 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 20 02/13/2025 02:38:08.789 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.789 7f892aa42588 [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=20, max_bytes=1048576)])]) 02/13/2025 02:38:08.790 7f892aa42588 [kafka.conn] [DEBUG]: Request 505: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 02/13/2025 02:38:08.790 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 02/13/2025 02:38:08.791 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.791 7f892a6a5eb8 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:08.791 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 514: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:08.795 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 02/13/2025 02:38:08.795 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.795 7f892aa0b630 [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)])]) 02/13/2025 02:38:08.795 7f892aa0b630 [kafka.conn] [DEBUG]: Request 500: 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)])]) 02/13/2025 02:38:08.795 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 143 02/13/2025 02:38:08.795 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.795 7f8929cac0f0 [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=143, max_bytes=1048576)])]) 02/13/2025 02:38:08.796 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 539: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=143, max_bytes=1048576)])]) 02/13/2025 02:38:08.796 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:08.796 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.796 7f892aa42978 [kafka.conn] [DEBUG]: Response 507 (606.7790985107422 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:08.810 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 17 02/13/2025 02:38:08.810 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.810 7f89297bb4e0 [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=17, max_bytes=1048576)])]) 02/13/2025 02:38:08.811 7f89297bb4e0 [kafka.conn] [DEBUG]: Request 505: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 02/13/2025 02:38:08.811 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 499 02/13/2025 02:38:08.811 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.812 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 499 (601.525068283081 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/13/2025 02:38:08.812 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:08.812 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.812 7f892a51c780 [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=10, max_bytes=1048576)])]) 02/13/2025 02:38:08.813 7f892a51c780 [kafka.conn] [DEBUG]: Request 504: 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=10, max_bytes=1048576)])]) 02/13/2025 02:38:08.907 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 313 02/13/2025 02:38:08.907 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.907 7f8929cac8d0 [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=313, max_bytes=1048576)])]) 02/13/2025 02:38:08.907 7f8929cac8d0 [kafka.conn] [DEBUG]: Request 563: 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=313, max_bytes=1048576)])]) 02/13/2025 02:38:08.908 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 18 02/13/2025 02:38:08.908 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.908 7f892a695d68 [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=18, max_bytes=1048576)])]) 02/13/2025 02:38:08.909 7f892a695d68 [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-5', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 02/13/2025 02:38:08.909 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 21 02/13/2025 02:38:08.910 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.910 7f892aa3dd68 [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=21, max_bytes=1048576)])]) 02/13/2025 02:38:08.910 7f892aa3dd68 [kafka.conn] [DEBUG]: Request 507: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=21, max_bytes=1048576)])]) 02/13/2025 02:38:08.910 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 111 02/13/2025 02:38:08.911 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:08.911 7f892aa0b4e0 [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=111, max_bytes=1048576)])]) 02/13/2025 02:38:08.911 7f892aa0b4e0 [kafka.conn] [DEBUG]: Request 522: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=111, max_bytes=1048576)])]) 02/13/2025 02:38:08.912 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:08.912 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:08.912 7f892aa3d438 [kafka.conn] [DEBUG]: Response 507 (602.4737358093262 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.010 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 789 02/13/2025 02:38:09.010 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.010 7f892aa07630 [kafka.conn] [DEBUG]: Response 789 (601.2916564941406 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2361, last_stable_offset=2361, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.025 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 02/13/2025 02:38:09.025 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.025 7f892aa30198 [kafka.conn] [DEBUG]: Response 516 (601.2020111083984 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.026 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 02/13/2025 02:38:09.026 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.026 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:09.026 7f892aa0b828 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:09.026 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 14 02/13/2025 02:38:09.026 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.027 7f892b2946d8 [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=14, max_bytes=1048576)])]) 02/13/2025 02:38:09.027 7f892b2946d8 [kafka.conn] [DEBUG]: Request 506: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 02/13/2025 02:38:09.103 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 02/13/2025 02:38:09.103 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.103 7f892a51c4e0 [kafka.conn] [DEBUG]: Response 501 (601.3424396514893 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.106 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 02/13/2025 02:38:09.106 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.106 7f892aa42240 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:09.106 7f892aa42240 [kafka.conn] [DEBUG]: Request 516: 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=56, max_bytes=1048576)])]) 02/13/2025 02:38:09.123 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 134 02/13/2025 02:38:09.123 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.123 7f8928f7fb70 [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=134, max_bytes=1048576)])]) 02/13/2025 02:38:09.123 7f8928f7fb70 [kafka.conn] [DEBUG]: Request 537: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 02/13/2025 02:38:09.161 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 98 02/13/2025 02:38:09.161 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.161 7f8929d22198 [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=98, max_bytes=1048576)])]) 02/13/2025 02:38:09.161 7f8929d22198 [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-22', partitions=[(partition=0, offset=98, max_bytes=1048576)])]) 02/13/2025 02:38:09.203 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:09.203 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.203 7f892aa34978 [kafka.conn] [DEBUG]: Response 508 (601.895809173584 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.204 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 538 02/13/2025 02:38:09.204 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.204 7f8929d22240 [kafka.conn] [DEBUG]: Response 538 (602.0092964172363 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.221 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 02/13/2025 02:38:09.221 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.222 7f8929cac390 [kafka.conn] [DEBUG]: Response 520 (601.8838882446289 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.222 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 560 02/13/2025 02:38:09.222 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.222 7f8928f7fcc0 [kafka.conn] [DEBUG]: Response 560 (601.9124984741211 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=257, last_stable_offset=257, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.240 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 02/13/2025 02:38:09.240 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.240 7f8929cacb70 [kafka.conn] [DEBUG]: Response 518 (601.2179851531982 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.253 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 02/13/2025 02:38:09.254 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.254 7f892a51ca20 [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=5, max_bytes=1048576)])]) 02/13/2025 02:38:09.254 7f892a51ca20 [kafka.conn] [DEBUG]: Request 502: 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=5, max_bytes=1048576)])]) 02/13/2025 02:38:09.296 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 532 02/13/2025 02:38:09.297 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.297 7f8929d22438 [kafka.conn] [DEBUG]: Response 532 (602.837324142456 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, last_stable_offset=161, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.313 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 02/13/2025 02:38:09.313 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.314 7f8929cac630 [kafka.conn] [DEBUG]: Response 528 (601.123571395874 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.389 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54 02/13/2025 02:38:09.389 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.390 7f892aa420f0 [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=54, max_bytes=1048576)])]) 02/13/2025 02:38:09.390 7f892aa420f0 [kafka.conn] [DEBUG]: Request 516: 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=54, max_bytes=1048576)])]) 02/13/2025 02:38:09.390 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 02/13/2025 02:38:09.390 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.391 7f892aa42588 [kafka.conn] [DEBUG]: Response 505 (600.9776592254639 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.396 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 514 02/13/2025 02:38:09.396 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.397 7f892a6a5eb8 [kafka.conn] [DEBUG]: Response 514 (605.7555675506592 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.397 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24 02/13/2025 02:38:09.397 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.397 7f892aa42978 [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=24, max_bytes=1048576)])]) 02/13/2025 02:38:09.397 7f892aa42978 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 02/13/2025 02:38:09.398 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 500 02/13/2025 02:38:09.398 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.398 7f892aa0b630 [kafka.conn] [DEBUG]: Response 500 (602.7736663818359 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'')])]) 02/13/2025 02:38:09.398 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 539 02/13/2025 02:38:09.399 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.399 7f8929cac0f0 [kafka.conn] [DEBUG]: Response 539 (602.9908657073975 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.413 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 02/13/2025 02:38:09.413 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.413 7f89297bb4e0 [kafka.conn] [DEBUG]: Response 505 (602.6566028594971 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.413 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:38:09.413 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.414 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:09.414 7f892aa0bf60 [kafka.conn] [DEBUG]: Request 500: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:09.414 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:09.414 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.414 7f892a51c780 [kafka.conn] [DEBUG]: Response 504 (601.7122268676758 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.509 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 563 02/13/2025 02:38:09.510 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.510 7f8929cac8d0 [kafka.conn] [DEBUG]: Response 563 (602.3514270782471 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=313, last_stable_offset=313, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.510 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:09.510 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.510 7f892a695d68 [kafka.conn] [DEBUG]: Response 507 (602.0312309265137 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.512 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:09.512 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.512 7f892aa3dd68 [kafka.conn] [DEBUG]: Response 507 (602.0705699920654 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=21, last_stable_offset=21, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.513 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 02/13/2025 02:38:09.513 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.513 7f892aa3d438 [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=19, max_bytes=1048576)])]) 02/13/2025 02:38:09.513 7f892aa3d438 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 02/13/2025 02:38:09.514 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 02/13/2025 02:38:09.514 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.514 7f892aa0b4e0 [kafka.conn] [DEBUG]: Response 522 (602.7657985687256 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.611 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2361 02/13/2025 02:38:09.611 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.611 7f892aa07630 [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=2361, max_bytes=1048576)])]) 02/13/2025 02:38:09.611 7f892aa07630 [kafka.conn] [DEBUG]: Request 790: 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=2361, max_bytes=1048576)])]) 02/13/2025 02:38:09.626 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 75 02/13/2025 02:38:09.626 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.626 7f892aa30198 [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=75, max_bytes=1048576)])]) 02/13/2025 02:38:09.626 7f892aa30198 [kafka.conn] [DEBUG]: Request 517: 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=75, max_bytes=1048576)])]) 02/13/2025 02:38:09.627 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 02/13/2025 02:38:09.627 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.627 7f892aa0b828 [kafka.conn] [DEBUG]: Response 511 (601.4482975006104 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.628 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:09.628 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.628 7f892b2946d8 [kafka.conn] [DEBUG]: Response 506 (601.4440059661865 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.705 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 02/13/2025 02:38:09.705 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.705 7f892a51c4e0 [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=4, max_bytes=1048576)])]) 02/13/2025 02:38:09.705 7f892a51c4e0 [kafka.conn] [DEBUG]: Request 502: 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=4, max_bytes=1048576)])]) 02/13/2025 02:38:09.707 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 02/13/2025 02:38:09.707 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.707 7f892aa42240 [kafka.conn] [DEBUG]: Response 516 (600.825309753418 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.724 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 02/13/2025 02:38:09.724 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.724 7f8928f7fb70 [kafka.conn] [DEBUG]: Response 537 (600.914716720581 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.762 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 02/13/2025 02:38:09.762 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.762 7f8929d22198 [kafka.conn] [DEBUG]: Response 528 (601.0274887084961 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=98, last_stable_offset=98, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.804 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 22 02/13/2025 02:38:09.804 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.804 7f892aa34978 [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=22, max_bytes=1048576)])]) 02/13/2025 02:38:09.804 7f892aa34978 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 02/13/2025 02:38:09.805 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 184 02/13/2025 02:38:09.805 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.805 7f8929d22240 [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=184, max_bytes=1048576)])]) 02/13/2025 02:38:09.805 7f8929d22240 [kafka.conn] [DEBUG]: Request 539: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=184, max_bytes=1048576)])]) 02/13/2025 02:38:09.822 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 87 02/13/2025 02:38:09.822 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.822 7f8929cac390 [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=87, max_bytes=1048576)])]) 02/13/2025 02:38:09.823 7f8929cac390 [kafka.conn] [DEBUG]: Request 521: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=87, max_bytes=1048576)])]) 02/13/2025 02:38:09.823 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 257 02/13/2025 02:38:09.823 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.823 7f8928f7fcc0 [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=257, max_bytes=1048576)])]) 02/13/2025 02:38:09.823 7f8928f7fcc0 [kafka.conn] [DEBUG]: Request 561: 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=257, max_bytes=1048576)])]) 02/13/2025 02:38:09.841 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 65 02/13/2025 02:38:09.841 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.841 7f8929cacb70 [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=65, max_bytes=1048576)])]) 02/13/2025 02:38:09.841 7f8929cacb70 [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-23', partitions=[(partition=0, offset=65, max_bytes=1048576)])]) 02/13/2025 02:38:09.855 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 02/13/2025 02:38:09.855 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.855 7f892a51ca20 [kafka.conn] [DEBUG]: Response 502 (601.3050079345703 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.898 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 161 02/13/2025 02:38:09.899 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.899 7f8929d22438 [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=161, max_bytes=1048576)])]) 02/13/2025 02:38:09.899 7f8929d22438 [kafka.conn] [DEBUG]: Request 533: 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=161, max_bytes=1048576)])]) 02/13/2025 02:38:09.915 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 146 02/13/2025 02:38:09.915 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.915 7f8929cac630 [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=146, max_bytes=1048576)])]) 02/13/2025 02:38:09.915 7f8929cac630 [kafka.conn] [DEBUG]: Request 529: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=146, max_bytes=1048576)])]) 02/13/2025 02:38:09.991 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 02/13/2025 02:38:09.991 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.991 7f892aa420f0 [kafka.conn] [DEBUG]: Response 516 (601.2780666351318 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:09.991 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 20 02/13/2025 02:38:09.992 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.992 7f892aa42588 [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=20, max_bytes=1048576)])]) 02/13/2025 02:38:09.992 7f892aa42588 [kafka.conn] [DEBUG]: Request 506: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 02/13/2025 02:38:09.997 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 02/13/2025 02:38:09.997 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.997 7f892a6a5eb8 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:09.997 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 515: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:09.998 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 02/13/2025 02:38:09.998 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:09.998 7f892aa0b630 [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)])]) 02/13/2025 02:38:09.999 7f892aa0b630 [kafka.conn] [DEBUG]: Request 501: 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)])]) 02/13/2025 02:38:09.999 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:09.999 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:09.999 7f892aa42978 [kafka.conn] [DEBUG]: Response 508 (601.9454002380371 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.000 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 143 02/13/2025 02:38:10.000 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.000 7f8929cac0f0 [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=143, max_bytes=1048576)])]) 02/13/2025 02:38:10.000 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 540: 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=143, max_bytes=1048576)])]) 02/13/2025 02:38:10.014 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 17 02/13/2025 02:38:10.014 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.014 7f89297bb4e0 [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=17, max_bytes=1048576)])]) 02/13/2025 02:38:10.015 7f89297bb4e0 [kafka.conn] [DEBUG]: Request 506: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 02/13/2025 02:38:10.015 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:10.015 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.015 7f892a51c780 [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=10, max_bytes=1048576)])]) 02/13/2025 02:38:10.016 7f892a51c780 [kafka.conn] [DEBUG]: Request 505: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 02/13/2025 02:38:10.016 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 500 02/13/2025 02:38:10.016 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.016 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 500 (602.5691032409668 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/13/2025 02:38:10.110 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 313 02/13/2025 02:38:10.110 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.111 7f8929cac8d0 [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=313, max_bytes=1048576)])]) 02/13/2025 02:38:10.111 7f8929cac8d0 [kafka.conn] [DEBUG]: Request 564: 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=313, max_bytes=1048576)])]) 02/13/2025 02:38:10.112 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 18 02/13/2025 02:38:10.112 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.112 7f892a695d68 [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=18, max_bytes=1048576)])]) 02/13/2025 02:38:10.112 7f892a695d68 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 02/13/2025 02:38:10.112 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 21 02/13/2025 02:38:10.112 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.113 7f892aa3dd68 [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=21, max_bytes=1048576)])]) 02/13/2025 02:38:10.113 7f892aa3dd68 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=21, max_bytes=1048576)])]) 02/13/2025 02:38:10.114 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:10.114 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.114 7f892aa3d438 [kafka.conn] [DEBUG]: Response 508 (600.8584499359131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.114 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 111 02/13/2025 02:38:10.114 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.114 7f892aa0b4e0 [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=111, max_bytes=1048576)])]) 02/13/2025 02:38:10.115 7f892aa0b4e0 [kafka.conn] [DEBUG]: Request 523: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=111, max_bytes=1048576)])]) 02/13/2025 02:38:10.212 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 790 02/13/2025 02:38:10.212 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.212 7f892aa07630 [kafka.conn] [DEBUG]: Response 790 (601.1648178100586 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2362, last_stable_offset=2362, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t9\x00\x00\x01\x04\x00\x00\x00\x00\x02\xe5hc\x81\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/13/2025 02:38:10.213 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2361 to buffered record list 02/13/2025 02:38:10.227 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 02/13/2025 02:38:10.227 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.227 7f892aa30198 [kafka.conn] [DEBUG]: Response 517 (600.9092330932617 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.228 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 02/13/2025 02:38:10.228 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.228 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:10.228 7f892aa0b828 [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=29, max_bytes=1048576)])]) 02/13/2025 02:38:10.229 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 14 02/13/2025 02:38:10.229 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.229 7f892b2946d8 [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=14, max_bytes=1048576)])]) 02/13/2025 02:38:10.229 7f892b2946d8 [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-16', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 02/13/2025 02:38:10.306 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 02/13/2025 02:38:10.306 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.306 7f892a51c4e0 [kafka.conn] [DEBUG]: Response 502 (601.0582447052002 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.307 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 02/13/2025 02:38:10.308 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.308 7f892aa42240 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:10.308 7f892aa42240 [kafka.conn] [DEBUG]: Request 517: 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=56, max_bytes=1048576)])]) 02/13/2025 02:38:10.313 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2362 02/13/2025 02:38:10.313 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.313 7f892aa07630 [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=2362, max_bytes=1048576)])]) 02/13/2025 02:38:10.314 7f892aa07630 [kafka.conn] [DEBUG]: Request 791: 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=2362, max_bytes=1048576)])]) 02/13/2025 02:38:10.325 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 134 02/13/2025 02:38:10.325 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.325 7f8928f7fb70 [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=134, max_bytes=1048576)])]) 02/13/2025 02:38:10.325 7f8928f7fb70 [kafka.conn] [DEBUG]: Request 538: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 02/13/2025 02:38:10.363 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 98 02/13/2025 02:38:10.363 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.363 7f8929d22198 [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=98, max_bytes=1048576)])]) 02/13/2025 02:38:10.364 7f8929d22198 [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-22', partitions=[(partition=0, offset=98, max_bytes=1048576)])]) 02/13/2025 02:38:10.406 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:10.406 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.406 7f892aa34978 [kafka.conn] [DEBUG]: Response 509 (601.6068458557129 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.406 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 539 02/13/2025 02:38:10.406 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.406 7f8929d22240 [kafka.conn] [DEBUG]: Response 539 (601.6106605529785 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.424 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 02/13/2025 02:38:10.424 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.424 7f8929cac390 [kafka.conn] [DEBUG]: Response 521 (601.477861404419 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.424 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 561 02/13/2025 02:38:10.425 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.425 7f8928f7fcc0 [kafka.conn] [DEBUG]: Response 561 (601.5167236328125 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=257, last_stable_offset=257, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.442 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 02/13/2025 02:38:10.442 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.442 7f8929cacb70 [kafka.conn] [DEBUG]: Response 519 (600.9278297424316 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.456 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 02/13/2025 02:38:10.456 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.456 7f892a51ca20 [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=5, max_bytes=1048576)])]) 02/13/2025 02:38:10.456 7f892a51ca20 [kafka.conn] [DEBUG]: Request 503: 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=5, max_bytes=1048576)])]) 02/13/2025 02:38:10.501 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 533 02/13/2025 02:38:10.501 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.501 7f8929d22438 [kafka.conn] [DEBUG]: Response 533 (601.9017696380615 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, last_stable_offset=161, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.516 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 02/13/2025 02:38:10.516 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.517 7f8929cac630 [kafka.conn] [DEBUG]: Response 529 (601.3350486755371 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.592 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54 02/13/2025 02:38:10.592 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.592 7f892aa420f0 [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=54, max_bytes=1048576)])]) 02/13/2025 02:38:10.592 7f892aa420f0 [kafka.conn] [DEBUG]: Request 517: 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=54, max_bytes=1048576)])]) 02/13/2025 02:38:10.593 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:10.593 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.593 7f892aa42588 [kafka.conn] [DEBUG]: Response 506 (601.1674404144287 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.598 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 02/13/2025 02:38:10.598 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.598 7f892a6a5eb8 [kafka.conn] [DEBUG]: Response 515 (600.8212566375732 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.599 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 02/13/2025 02:38:10.599 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.599 7f892aa0b630 [kafka.conn] [DEBUG]: Response 501 (600.7585525512695 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'')])]) 02/13/2025 02:38:10.600 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24 02/13/2025 02:38:10.600 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.600 7f892aa42978 [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=24, max_bytes=1048576)])]) 02/13/2025 02:38:10.600 7f892aa42978 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 02/13/2025 02:38:10.600 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 02/13/2025 02:38:10.601 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.601 7f8929cac0f0 [kafka.conn] [DEBUG]: Response 540 (600.8167266845703 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.615 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:10.615 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.615 7f89297bb4e0 [kafka.conn] [DEBUG]: Response 506 (600.8782386779785 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.616 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 02/13/2025 02:38:10.616 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.616 7f892a51c780 [kafka.conn] [DEBUG]: Response 505 (600.8555889129639 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.617 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:38:10.617 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.617 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:10.617 7f892aa0bf60 [kafka.conn] [DEBUG]: Request 501: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:10.712 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 564 02/13/2025 02:38:10.712 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.712 7f8929cac8d0 [kafka.conn] [DEBUG]: Response 564 (601.1950969696045 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=313, last_stable_offset=313, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.713 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:10.713 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.713 7f892a695d68 [kafka.conn] [DEBUG]: Response 508 (601.3534069061279 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.714 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:10.714 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.714 7f892aa3dd68 [kafka.conn] [DEBUG]: Response 508 (601.2692451477051 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=21, last_stable_offset=21, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.714 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 02/13/2025 02:38:10.714 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.714 7f892aa3d438 [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=19, max_bytes=1048576)])]) 02/13/2025 02:38:10.715 7f892aa3d438 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 02/13/2025 02:38:10.715 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 523 02/13/2025 02:38:10.715 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.715 7f892aa0b4e0 [kafka.conn] [DEBUG]: Response 523 (600.8141040802002 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.828 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 75 02/13/2025 02:38:10.828 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.828 7f892aa30198 [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=75, max_bytes=1048576)])]) 02/13/2025 02:38:10.828 7f892aa30198 [kafka.conn] [DEBUG]: Request 518: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=75, max_bytes=1048576)])]) 02/13/2025 02:38:10.829 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 02/13/2025 02:38:10.829 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.830 7f892aa0b828 [kafka.conn] [DEBUG]: Response 512 (601.4201641082764 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.830 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:10.830 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.830 7f892b2946d8 [kafka.conn] [DEBUG]: Response 507 (601.4389991760254 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.907 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 02/13/2025 02:38:10.907 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:10.907 7f892a51c4e0 [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=4, max_bytes=1048576)])]) 02/13/2025 02:38:10.908 7f892a51c4e0 [kafka.conn] [DEBUG]: Request 503: 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=4, max_bytes=1048576)])]) 02/13/2025 02:38:10.909 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 02/13/2025 02:38:10.909 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.909 7f892aa42240 [kafka.conn] [DEBUG]: Response 517 (601.1912822723389 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.914 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 791 02/13/2025 02:38:10.914 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.915 7f892aa07630 [kafka.conn] [DEBUG]: Response 791 (600.9447574615479 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2362, last_stable_offset=2362, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.926 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 538 02/13/2025 02:38:10.926 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.926 7f8928f7fb70 [kafka.conn] [DEBUG]: Response 538 (601.0782718658447 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:10.964 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 02/13/2025 02:38:10.965 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:10.965 7f8929d22198 [kafka.conn] [DEBUG]: Response 529 (601.1888980865479 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=98, last_stable_offset=98, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.006 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 22 02/13/2025 02:38:11.007 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.007 7f892aa34978 [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=22, max_bytes=1048576)])]) 02/13/2025 02:38:11.007 7f892aa34978 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 02/13/2025 02:38:11.007 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 184 02/13/2025 02:38:11.007 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.008 7f8929d22240 [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=184, max_bytes=1048576)])]) 02/13/2025 02:38:11.008 7f8929d22240 [kafka.conn] [DEBUG]: Request 540: 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=184, max_bytes=1048576)])]) 02/13/2025 02:38:11.025 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 87 02/13/2025 02:38:11.025 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.025 7f8929cac390 [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=87, max_bytes=1048576)])]) 02/13/2025 02:38:11.025 7f8929cac390 [kafka.conn] [DEBUG]: Request 522: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=87, max_bytes=1048576)])]) 02/13/2025 02:38:11.026 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 257 02/13/2025 02:38:11.026 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.026 7f8928f7fcc0 [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=257, max_bytes=1048576)])]) 02/13/2025 02:38:11.026 7f8928f7fcc0 [kafka.conn] [DEBUG]: Request 562: 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=257, max_bytes=1048576)])]) 02/13/2025 02:38:11.043 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 65 02/13/2025 02:38:11.043 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.043 7f8929cacb70 [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=65, max_bytes=1048576)])]) 02/13/2025 02:38:11.044 7f8929cacb70 [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-23', partitions=[(partition=0, offset=65, max_bytes=1048576)])]) 02/13/2025 02:38:11.057 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 02/13/2025 02:38:11.057 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.057 7f892a51ca20 [kafka.conn] [DEBUG]: Response 503 (600.9933948516846 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.102 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 161 02/13/2025 02:38:11.102 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.102 7f8929d22438 [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=161, max_bytes=1048576)])]) 02/13/2025 02:38:11.102 7f8929d22438 [kafka.conn] [DEBUG]: Request 534: 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=161, max_bytes=1048576)])]) 02/13/2025 02:38:11.117 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 146 02/13/2025 02:38:11.118 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.118 7f8929cac630 [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=146, max_bytes=1048576)])]) 02/13/2025 02:38:11.118 7f8929cac630 [kafka.conn] [DEBUG]: Request 530: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=146, max_bytes=1048576)])]) 02/13/2025 02:38:11.193 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 02/13/2025 02:38:11.193 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.193 7f892aa420f0 [kafka.conn] [DEBUG]: Response 517 (601.3219356536865 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.194 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 20 02/13/2025 02:38:11.194 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.194 7f892aa42588 [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=20, max_bytes=1048576)])]) 02/13/2025 02:38:11.194 7f892aa42588 [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-14', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 02/13/2025 02:38:11.199 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 02/13/2025 02:38:11.199 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.199 7f892a6a5eb8 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:11.199 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 516: 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=56, max_bytes=1048576)])]) 02/13/2025 02:38:11.200 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 02/13/2025 02:38:11.200 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.200 7f892aa0b630 [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)])]) 02/13/2025 02:38:11.200 7f892aa0b630 [kafka.conn] [DEBUG]: Request 502: 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)])]) 02/13/2025 02:38:11.201 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:11.201 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.201 7f892aa42978 [kafka.conn] [DEBUG]: Response 509 (600.7874011993408 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.201 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 143 02/13/2025 02:38:11.201 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.201 7f8929cac0f0 [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=143, max_bytes=1048576)])]) 02/13/2025 02:38:11.201 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 541: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=143, max_bytes=1048576)])]) 02/13/2025 02:38:11.217 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 17 02/13/2025 02:38:11.217 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.217 7f89297bb4e0 [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=17, max_bytes=1048576)])]) 02/13/2025 02:38:11.217 7f89297bb4e0 [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-13', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 02/13/2025 02:38:11.218 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:11.218 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.218 7f892a51c780 [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=10, max_bytes=1048576)])]) 02/13/2025 02:38:11.218 7f892a51c780 [kafka.conn] [DEBUG]: Request 506: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 02/13/2025 02:38:11.219 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 02/13/2025 02:38:11.219 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.219 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 501 (602.0162105560303 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/13/2025 02:38:11.313 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 313 02/13/2025 02:38:11.313 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.313 7f8929cac8d0 [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=313, max_bytes=1048576)])]) 02/13/2025 02:38:11.313 7f8929cac8d0 [kafka.conn] [DEBUG]: Request 565: 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=313, max_bytes=1048576)])]) 02/13/2025 02:38:11.314 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 18 02/13/2025 02:38:11.314 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.314 7f892a695d68 [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=18, max_bytes=1048576)])]) 02/13/2025 02:38:11.314 7f892a695d68 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 02/13/2025 02:38:11.314 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 21 02/13/2025 02:38:11.314 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.315 7f892aa3dd68 [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=21, max_bytes=1048576)])]) 02/13/2025 02:38:11.315 7f892aa3dd68 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=21, max_bytes=1048576)])]) 02/13/2025 02:38:11.315 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:11.316 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.316 7f892aa3d438 [kafka.conn] [DEBUG]: Response 509 (601.0236740112305 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.316 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 111 02/13/2025 02:38:11.316 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.316 7f892aa0b4e0 [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=111, max_bytes=1048576)])]) 02/13/2025 02:38:11.316 7f892aa0b4e0 [kafka.conn] [DEBUG]: Request 524: 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=111, max_bytes=1048576)])]) 02/13/2025 02:38:11.429 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 02/13/2025 02:38:11.429 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.429 7f892aa30198 [kafka.conn] [DEBUG]: Response 518 (601.2704372406006 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.430 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 02/13/2025 02:38:11.430 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.430 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:11.430 7f892aa0b828 [kafka.conn] [DEBUG]: Request 513: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:11.431 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 14 02/13/2025 02:38:11.431 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.431 7f892b2946d8 [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=14, max_bytes=1048576)])]) 02/13/2025 02:38:11.431 7f892b2946d8 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 02/13/2025 02:38:11.509 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 02/13/2025 02:38:11.509 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.509 7f892a51c4e0 [kafka.conn] [DEBUG]: Response 503 (601.5393733978271 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.510 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 02/13/2025 02:38:11.510 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.510 7f892aa42240 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:11.510 7f892aa42240 [kafka.conn] [DEBUG]: Request 518: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:11.515 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2362 02/13/2025 02:38:11.515 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.515 7f892aa07630 [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=2362, max_bytes=1048576)])]) 02/13/2025 02:38:11.516 7f892aa07630 [kafka.conn] [DEBUG]: Request 792: 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=2362, max_bytes=1048576)])]) 02/13/2025 02:38:11.527 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 134 02/13/2025 02:38:11.527 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.527 7f8928f7fb70 [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=134, max_bytes=1048576)])]) 02/13/2025 02:38:11.527 7f8928f7fb70 [kafka.conn] [DEBUG]: Request 539: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 02/13/2025 02:38:11.566 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 98 02/13/2025 02:38:11.566 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.566 7f8929d22198 [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=98, max_bytes=1048576)])]) 02/13/2025 02:38:11.566 7f8929d22198 [kafka.conn] [DEBUG]: Request 530: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=98, max_bytes=1048576)])]) 02/13/2025 02:38:11.609 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 02/13/2025 02:38:11.609 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.609 7f892aa34978 [kafka.conn] [DEBUG]: Response 510 (601.9227504730225 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.609 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 02/13/2025 02:38:11.610 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.610 7f8929d22240 [kafka.conn] [DEBUG]: Response 540 (601.923942565918 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.627 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 02/13/2025 02:38:11.627 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.627 7f8929cac390 [kafka.conn] [DEBUG]: Response 522 (601.9632816314697 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.628 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 562 02/13/2025 02:38:11.628 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.628 7f8928f7fcc0 [kafka.conn] [DEBUG]: Response 562 (602.0727157592773 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=257, last_stable_offset=257, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.645 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 02/13/2025 02:38:11.645 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.645 7f8929cacb70 [kafka.conn] [DEBUG]: Response 520 (601.5043258666992 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.658 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 02/13/2025 02:38:11.658 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.658 7f892a51ca20 [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=5, max_bytes=1048576)])]) 02/13/2025 02:38:11.658 7f892a51ca20 [kafka.conn] [DEBUG]: Request 504: 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=5, max_bytes=1048576)])]) 02/13/2025 02:38:11.703 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 534 02/13/2025 02:38:11.703 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.703 7f8929d22438 [kafka.conn] [DEBUG]: Response 534 (601.2430191040039 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, last_stable_offset=161, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.719 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 02/13/2025 02:38:11.719 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.719 7f8929cac630 [kafka.conn] [DEBUG]: Response 530 (601.4392375946045 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.794 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54 02/13/2025 02:38:11.794 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.795 7f892aa420f0 [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=54, max_bytes=1048576)])]) 02/13/2025 02:38:11.795 7f892aa420f0 [kafka.conn] [DEBUG]: Request 518: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])]) 02/13/2025 02:38:11.796 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:11.796 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.796 7f892aa42588 [kafka.conn] [DEBUG]: Response 507 (601.7029285430908 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.800 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 02/13/2025 02:38:11.800 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.800 7f892a6a5eb8 [kafka.conn] [DEBUG]: Response 516 (600.9161472320557 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.801 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 02/13/2025 02:38:11.801 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.801 7f892aa0b630 [kafka.conn] [DEBUG]: Response 502 (600.8312702178955 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'')])]) 02/13/2025 02:38:11.801 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24 02/13/2025 02:38:11.801 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.801 7f892aa42978 [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=24, max_bytes=1048576)])]) 02/13/2025 02:38:11.802 7f892aa42978 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 02/13/2025 02:38:11.803 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 02/13/2025 02:38:11.803 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.803 7f8929cac0f0 [kafka.conn] [DEBUG]: Response 541 (601.4726161956787 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.819 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:11.819 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.820 7f89297bb4e0 [kafka.conn] [DEBUG]: Response 507 (602.1459102630615 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.820 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 02/13/2025 02:38:11.820 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.820 7f892a51c780 [kafka.conn] [DEBUG]: Response 506 (602.2884845733643 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.821 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:38:11.821 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.821 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:11.821 7f892aa0bf60 [kafka.conn] [DEBUG]: Request 502: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:11.914 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 565 02/13/2025 02:38:11.914 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.915 7f8929cac8d0 [kafka.conn] [DEBUG]: Response 565 (601.4659404754639 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=313, last_stable_offset=313, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.915 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:11.915 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.916 7f892a695d68 [kafka.conn] [DEBUG]: Response 509 (601.6149520874023 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.916 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 02/13/2025 02:38:11.916 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:11.916 7f892aa3d438 [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=19, max_bytes=1048576)])]) 02/13/2025 02:38:11.917 7f892aa3d438 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 02/13/2025 02:38:11.917 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:11.917 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.918 7f892aa3dd68 [kafka.conn] [DEBUG]: Response 509 (602.7333736419678 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=21, last_stable_offset=21, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:11.918 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 524 02/13/2025 02:38:11.918 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:11.919 7f892aa0b4e0 [kafka.conn] [DEBUG]: Response 524 (602.200984954834 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.030 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 75 02/13/2025 02:38:12.030 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.030 7f892aa30198 [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=75, max_bytes=1048576)])]) 02/13/2025 02:38:12.031 7f892aa30198 [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-12', partitions=[(partition=0, offset=75, max_bytes=1048576)])]) 02/13/2025 02:38:12.032 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 02/13/2025 02:38:12.032 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.032 7f892aa0b828 [kafka.conn] [DEBUG]: Response 513 (601.6232967376709 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.033 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:12.033 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.033 7f892b2946d8 [kafka.conn] [DEBUG]: Response 508 (601.6807556152344 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.110 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 02/13/2025 02:38:12.110 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.111 7f892a51c4e0 [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=4, max_bytes=1048576)])]) 02/13/2025 02:38:12.111 7f892a51c4e0 [kafka.conn] [DEBUG]: Request 504: 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=4, max_bytes=1048576)])]) 02/13/2025 02:38:12.111 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 02/13/2025 02:38:12.112 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.112 7f892aa42240 [kafka.conn] [DEBUG]: Response 518 (601.6120910644531 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.116 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 792 02/13/2025 02:38:12.116 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.116 7f892aa07630 [kafka.conn] [DEBUG]: Response 792 (600.9559631347656 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2363, last_stable_offset=2363, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t:\x00\x00\x01\x04\x00\x00\x00\x00\x02<\xe5\x16\x17\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/13/2025 02:38:12.117 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2362 to buffered record list 02/13/2025 02:38:12.128 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 539 02/13/2025 02:38:12.128 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.128 7f8928f7fb70 [kafka.conn] [DEBUG]: Response 539 (601.1502742767334 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.167 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 02/13/2025 02:38:12.167 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.168 7f8929d22198 [kafka.conn] [DEBUG]: Response 530 (601.1672019958496 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=98, last_stable_offset=98, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.209 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 22 02/13/2025 02:38:12.210 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.210 7f892aa34978 [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=22, max_bytes=1048576)])]) 02/13/2025 02:38:12.210 7f892aa34978 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 02/13/2025 02:38:12.210 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 184 02/13/2025 02:38:12.210 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.211 7f8929d22240 [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=184, max_bytes=1048576)])]) 02/13/2025 02:38:12.211 7f8929d22240 [kafka.conn] [DEBUG]: Request 541: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=184, max_bytes=1048576)])]) 02/13/2025 02:38:12.217 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2363 02/13/2025 02:38:12.217 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.217 7f892aa07630 [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=2363, max_bytes=1048576)])]) 02/13/2025 02:38:12.218 7f892aa07630 [kafka.conn] [DEBUG]: Request 793: 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=2363, max_bytes=1048576)])]) 02/13/2025 02:38:12.228 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 87 02/13/2025 02:38:12.228 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.228 7f8929cac390 [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=87, max_bytes=1048576)])]) 02/13/2025 02:38:12.228 7f8929cac390 [kafka.conn] [DEBUG]: Request 523: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=87, max_bytes=1048576)])]) 02/13/2025 02:38:12.229 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 257 02/13/2025 02:38:12.229 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.229 7f8928f7fcc0 [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=257, max_bytes=1048576)])]) 02/13/2025 02:38:12.229 7f8928f7fcc0 [kafka.conn] [DEBUG]: Request 563: 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=257, max_bytes=1048576)])]) 02/13/2025 02:38:12.246 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 65 02/13/2025 02:38:12.246 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.246 7f8929cacb70 [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=65, max_bytes=1048576)])]) 02/13/2025 02:38:12.246 7f8929cacb70 [kafka.conn] [DEBUG]: Request 521: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=65, max_bytes=1048576)])]) 02/13/2025 02:38:12.259 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:12.259 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.259 7f892a51ca20 [kafka.conn] [DEBUG]: Response 504 (600.9640693664551 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.304 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 161 02/13/2025 02:38:12.304 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.304 7f8929d22438 [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=161, max_bytes=1048576)])]) 02/13/2025 02:38:12.305 7f8929d22438 [kafka.conn] [DEBUG]: Request 535: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=161, max_bytes=1048576)])]) 02/13/2025 02:38:12.320 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 146 02/13/2025 02:38:12.320 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.320 7f8929cac630 [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=146, max_bytes=1048576)])]) 02/13/2025 02:38:12.321 7f8929cac630 [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=146, max_bytes=1048576)])]) 02/13/2025 02:38:12.396 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 02/13/2025 02:38:12.396 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.396 7f892aa420f0 [kafka.conn] [DEBUG]: Response 518 (601.5281677246094 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.397 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 20 02/13/2025 02:38:12.397 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.397 7f892aa42588 [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=20, max_bytes=1048576)])]) 02/13/2025 02:38:12.397 7f892aa42588 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 02/13/2025 02:38:12.400 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 02/13/2025 02:38:12.400 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.401 7f892a6a5eb8 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:12.401 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 517: 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=56, max_bytes=1048576)])]) 02/13/2025 02:38:12.401 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 02/13/2025 02:38:12.401 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.401 7f892aa0b630 [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)])]) 02/13/2025 02:38:12.402 7f892aa0b630 [kafka.conn] [DEBUG]: Request 503: 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)])]) 02/13/2025 02:38:12.403 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 02/13/2025 02:38:12.403 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.403 7f892aa42978 [kafka.conn] [DEBUG]: Response 510 (601.2296676635742 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.403 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 143 02/13/2025 02:38:12.403 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.403 7f8929cac0f0 [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=143, max_bytes=1048576)])]) 02/13/2025 02:38:12.404 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 542: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=143, max_bytes=1048576)])]) 02/13/2025 02:38:12.420 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 17 02/13/2025 02:38:12.420 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.420 7f89297bb4e0 [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=17, max_bytes=1048576)])]) 02/13/2025 02:38:12.421 7f89297bb4e0 [kafka.conn] [DEBUG]: Request 508: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 02/13/2025 02:38:12.421 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:12.421 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.421 7f892a51c780 [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=10, max_bytes=1048576)])]) 02/13/2025 02:38:12.421 7f892a51c780 [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-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 02/13/2025 02:38:12.422 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 02/13/2025 02:38:12.422 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.422 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 502 (600.9230613708496 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/13/2025 02:38:12.515 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 313 02/13/2025 02:38:12.516 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.516 7f8929cac8d0 [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=313, max_bytes=1048576)])]) 02/13/2025 02:38:12.516 7f8929cac8d0 [kafka.conn] [DEBUG]: Request 566: 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=313, max_bytes=1048576)])]) 02/13/2025 02:38:12.516 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 18 02/13/2025 02:38:12.516 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.516 7f892a695d68 [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=18, max_bytes=1048576)])]) 02/13/2025 02:38:12.517 7f892a695d68 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 02/13/2025 02:38:12.518 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 21 02/13/2025 02:38:12.518 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.518 7f892aa3dd68 [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=21, max_bytes=1048576)])]) 02/13/2025 02:38:12.518 7f892aa3dd68 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=21, max_bytes=1048576)])]) 02/13/2025 02:38:12.519 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 02/13/2025 02:38:12.519 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.519 7f892aa3d438 [kafka.conn] [DEBUG]: Response 510 (602.3213863372803 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.519 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 111 02/13/2025 02:38:12.519 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.520 7f892aa0b4e0 [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=111, max_bytes=1048576)])]) 02/13/2025 02:38:12.520 7f892aa0b4e0 [kafka.conn] [DEBUG]: Request 525: 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=111, max_bytes=1048576)])]) 02/13/2025 02:38:12.631 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 02/13/2025 02:38:12.632 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.632 7f892aa30198 [kafka.conn] [DEBUG]: Response 519 (601.2489795684814 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.632 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 02/13/2025 02:38:12.633 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.633 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:12.633 7f892aa0b828 [kafka.conn] [DEBUG]: Request 514: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:12.633 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 14 02/13/2025 02:38:12.633 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.633 7f892b2946d8 [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=14, max_bytes=1048576)])]) 02/13/2025 02:38:12.633 7f892b2946d8 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 02/13/2025 02:38:12.712 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:12.712 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.712 7f892a51c4e0 [kafka.conn] [DEBUG]: Response 504 (601.3791561126709 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.713 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 02/13/2025 02:38:12.713 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.713 7f892aa42240 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:12.713 7f892aa42240 [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-17', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:12.729 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 134 02/13/2025 02:38:12.730 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.730 7f8928f7fb70 [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=134, max_bytes=1048576)])]) 02/13/2025 02:38:12.730 7f8928f7fb70 [kafka.conn] [DEBUG]: Request 540: 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=134, max_bytes=1048576)])]) 02/13/2025 02:38:12.768 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 98 02/13/2025 02:38:12.768 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.768 7f8929d22198 [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=98, max_bytes=1048576)])]) 02/13/2025 02:38:12.769 7f8929d22198 [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-22', partitions=[(partition=0, offset=98, max_bytes=1048576)])]) 02/13/2025 02:38:12.811 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 02/13/2025 02:38:12.812 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.812 7f892aa34978 [kafka.conn] [DEBUG]: Response 511 (601.7646789550781 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.812 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 02/13/2025 02:38:12.812 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.813 7f8929d22240 [kafka.conn] [DEBUG]: Response 541 (601.7856597900391 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.818 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 793 02/13/2025 02:38:12.818 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.818 7f892aa07630 [kafka.conn] [DEBUG]: Response 793 (600.7769107818604 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2364, last_stable_offset=2364, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t;\x00\x00\x01\x04\x00\x00\x00\x00\x028[X\x91\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/13/2025 02:38:12.819 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2363 to buffered record list 02/13/2025 02:38:12.830 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 523 02/13/2025 02:38:12.830 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.830 7f8929cac390 [kafka.conn] [DEBUG]: Response 523 (601.670503616333 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.830 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 563 02/13/2025 02:38:12.830 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.831 7f8928f7fcc0 [kafka.conn] [DEBUG]: Response 563 (601.5691757202148 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=257, last_stable_offset=257, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.847 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 02/13/2025 02:38:12.847 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.847 7f8929cacb70 [kafka.conn] [DEBUG]: Response 521 (600.9311676025391 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.860 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 02/13/2025 02:38:12.860 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.860 7f892a51ca20 [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=5, max_bytes=1048576)])]) 02/13/2025 02:38:12.860 7f892a51ca20 [kafka.conn] [DEBUG]: Request 505: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 02/13/2025 02:38:12.905 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 535 02/13/2025 02:38:12.905 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.906 7f8929d22438 [kafka.conn] [DEBUG]: Response 535 (601.1030673980713 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, last_stable_offset=161, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.919 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2364 02/13/2025 02:38:12.919 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.919 7f892aa07630 [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=2364, max_bytes=1048576)])]) 02/13/2025 02:38:12.920 7f892aa07630 [kafka.conn] [DEBUG]: Request 794: 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=2364, max_bytes=1048576)])]) 02/13/2025 02:38:12.922 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 531 02/13/2025 02:38:12.922 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.922 7f8929cac630 [kafka.conn] [DEBUG]: Response 531 (601.3567447662354 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:12.997 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54 02/13/2025 02:38:12.997 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:12.997 7f892aa420f0 [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=54, max_bytes=1048576)])]) 02/13/2025 02:38:12.998 7f892aa420f0 [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-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])]) 02/13/2025 02:38:12.998 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:12.998 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:12.999 7f892aa42588 [kafka.conn] [DEBUG]: Response 508 (601.5677452087402 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.001 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 02/13/2025 02:38:13.001 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.001 7f892a6a5eb8 [kafka.conn] [DEBUG]: Response 517 (600.7959842681885 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.002 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 02/13/2025 02:38:13.002 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.002 7f892aa0b630 [kafka.conn] [DEBUG]: Response 503 (600.74782371521 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'')])]) 02/13/2025 02:38:13.003 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24 02/13/2025 02:38:13.003 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.003 7f892aa42978 [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=24, max_bytes=1048576)])]) 02/13/2025 02:38:13.004 7f892aa42978 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 02/13/2025 02:38:13.004 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 542 02/13/2025 02:38:13.004 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.004 7f8929cac0f0 [kafka.conn] [DEBUG]: Response 542 (600.7473468780518 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.022 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:13.022 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.022 7f89297bb4e0 [kafka.conn] [DEBUG]: Response 508 (601.5884876251221 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.023 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:38:13.023 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.023 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:13.023 7f892aa0bf60 [kafka.conn] [DEBUG]: Request 503: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 02/13/2025 02:38:13.023 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 02/13/2025 02:38:13.023 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.024 7f892a51c780 [kafka.conn] [DEBUG]: Response 507 (602.4906635284424 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.117 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 566 02/13/2025 02:38:13.118 7f8929cac8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.118 7f8929cac8d0 [kafka.conn] [DEBUG]: Response 566 (601.9001007080078 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=313, last_stable_offset=313, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.118 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 02/13/2025 02:38:13.118 7f892a695d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.118 7f892a695d68 [kafka.conn] [DEBUG]: Response 510 (601.921558380127 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.119 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 02/13/2025 02:38:13.119 7f892aa3dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.119 7f892aa3dd68 [kafka.conn] [DEBUG]: Response 510 (600.7909774780273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=21, last_stable_offset=21, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.119 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 19 02/13/2025 02:38:13.120 7f892aa3d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.120 7f892aa3d438 [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=19, max_bytes=1048576)])]) 02/13/2025 02:38:13.120 7f892aa3d438 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=19, max_bytes=1048576)])]) 02/13/2025 02:38:13.120 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 525 02/13/2025 02:38:13.120 7f892aa0b4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.121 7f892aa0b4e0 [kafka.conn] [DEBUG]: Response 525 (600.9142398834229 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=111, last_stable_offset=111, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.232 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 75 02/13/2025 02:38:13.233 7f892aa30198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.233 7f892aa30198 [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=75, max_bytes=1048576)])]) 02/13/2025 02:38:13.233 7f892aa30198 [kafka.conn] [DEBUG]: Request 520: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=75, max_bytes=1048576)])]) 02/13/2025 02:38:13.234 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 514 02/13/2025 02:38:13.234 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.234 7f892aa0b828 [kafka.conn] [DEBUG]: Response 514 (601.4602184295654 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.235 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:13.235 7f892b2946d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.235 7f892b2946d8 [kafka.conn] [DEBUG]: Response 509 (601.4862060546875 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.313 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 02/13/2025 02:38:13.313 7f892a51c4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.313 7f892a51c4e0 [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=4, max_bytes=1048576)])]) 02/13/2025 02:38:13.314 7f892a51c4e0 [kafka.conn] [DEBUG]: Request 505: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 02/13/2025 02:38:13.314 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 02/13/2025 02:38:13.314 7f892aa42240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.314 7f892aa42240 [kafka.conn] [DEBUG]: Response 519 (601.5114784240723 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.331 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 02/13/2025 02:38:13.331 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.331 7f8928f7fb70 [kafka.conn] [DEBUG]: Response 540 (601.4847755432129 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.369 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 531 02/13/2025 02:38:13.370 7f8929d22198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.370 7f8929d22198 [kafka.conn] [DEBUG]: Response 531 (601.1908054351807 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=98, last_stable_offset=98, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.412 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 22 02/13/2025 02:38:13.413 7f892aa34978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.413 7f892aa34978 [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=22, max_bytes=1048576)])]) 02/13/2025 02:38:13.413 7f892aa34978 [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-10', partitions=[(partition=0, offset=22, max_bytes=1048576)])]) 02/13/2025 02:38:13.413 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 184 02/13/2025 02:38:13.413 7f8929d22240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.413 7f8929d22240 [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=184, max_bytes=1048576)])]) 02/13/2025 02:38:13.414 7f8929d22240 [kafka.conn] [DEBUG]: Request 542: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=184, max_bytes=1048576)])]) 02/13/2025 02:38:13.430 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 87 02/13/2025 02:38:13.431 7f8929cac390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.431 7f8929cac390 [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=87, max_bytes=1048576)])]) 02/13/2025 02:38:13.431 7f8929cac390 [kafka.conn] [DEBUG]: Request 524: 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=87, max_bytes=1048576)])]) 02/13/2025 02:38:13.431 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 257 02/13/2025 02:38:13.431 7f8928f7fcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.431 7f8928f7fcc0 [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=257, max_bytes=1048576)])]) 02/13/2025 02:38:13.432 7f8928f7fcc0 [kafka.conn] [DEBUG]: Request 564: 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=257, max_bytes=1048576)])]) 02/13/2025 02:38:13.447 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 65 02/13/2025 02:38:13.448 7f8929cacb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.448 7f8929cacb70 [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=65, max_bytes=1048576)])]) 02/13/2025 02:38:13.448 7f8929cacb70 [kafka.conn] [DEBUG]: Request 522: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=65, max_bytes=1048576)])]) 02/13/2025 02:38:13.461 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 02/13/2025 02:38:13.461 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.461 7f892a51ca20 [kafka.conn] [DEBUG]: Response 505 (601.0735034942627 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.506 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 161 02/13/2025 02:38:13.506 7f8929d22438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.506 7f8929d22438 [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=161, max_bytes=1048576)])]) 02/13/2025 02:38:13.507 7f8929d22438 [kafka.conn] [DEBUG]: Request 536: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=161, max_bytes=1048576)])]) 02/13/2025 02:38:13.520 7f892aa07630 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-0']) to node 1 02/13/2025 02:38:13.521 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-0']) 02/13/2025 02:38:13.521 7f892aa07630 [kafka.conn] [DEBUG]: Request 795: MetadataRequest_v1(topics=['-uve-topic-0']) 02/13/2025 02:38:13.521 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 794 02/13/2025 02:38:13.521 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.521 7f892aa07630 [kafka.conn] [DEBUG]: Response 794 (601.5374660491943 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2365, last_stable_offset=2365, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t<\x00\x00\x01\x0f\x00\x00\x00\x00\x02\xb38\xb8\xf0\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\xb8\x03\x00\x00\x00\xfa\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])]) 02/13/2025 02:38:13.521 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2364 to buffered record list 02/13/2025 02:38:13.523 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 146 02/13/2025 02:38:13.523 7f8929cac630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.523 7f8929cac630 [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=146, max_bytes=1048576)])]) 02/13/2025 02:38:13.523 7f8929cac630 [kafka.conn] [DEBUG]: Request 532: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=146, max_bytes=1048576)])]) 02/13/2025 02:38:13.599 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 02/13/2025 02:38:13.599 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.599 7f892aa420f0 [kafka.conn] [DEBUG]: Response 519 (601.6209125518799 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.599 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 20 02/13/2025 02:38:13.600 7f892aa42588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.600 7f892aa42588 [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=20, max_bytes=1048576)])]) 02/13/2025 02:38:13.600 7f892aa42588 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 02/13/2025 02:38:13.602 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 02/13/2025 02:38:13.602 7f892a6a5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.602 7f892a6a5eb8 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:13.602 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 518: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:13.603 7f892aa0b630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 02/13/2025 02:38:13.603 7f892aa0b630 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-2']) to node 1 02/13/2025 02:38:13.603 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-2']) 02/13/2025 02:38:13.603 7f892aa0b630 [kafka.conn] [DEBUG]: Request 504: MetadataRequest_v1(topics=['-uve-topic-2']) 02/13/2025 02:38:13.604 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 02/13/2025 02:38:13.604 7f892aa42978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.604 7f892aa42978 [kafka.conn] [DEBUG]: Response 511 (600.8040904998779 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=24, last_stable_offset=24, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.605 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 143 02/13/2025 02:38:13.605 7f8929cac0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.605 7f8929cac0f0 [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=143, max_bytes=1048576)])]) 02/13/2025 02:38:13.605 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 543: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=143, max_bytes=1048576)])]) 02/13/2025 02:38:13.622 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 795 02/13/2025 02:38:13.622 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 02/13/2025 02:38:13.623 7f892aa07630 [kafka.conn] [DEBUG]: Response 795 (102.0514965057373 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.45', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-0', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 02/13/2025 02:38:13.624 7f892aa07630 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 02/13/2025 02:38:13.624 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 17 02/13/2025 02:38:13.624 7f89297bb4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.624 7f89297bb4e0 [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=17, max_bytes=1048576)])]) 02/13/2025 02:38:13.624 7f89297bb4e0 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=17, max_bytes=1048576)])]) 02/13/2025 02:38:13.624 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:13.625 7f892a51c780 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-9']) to node 1 02/13/2025 02:38:13.625 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-9']) 02/13/2025 02:38:13.625 7f892a51c780 [kafka.conn] [DEBUG]: Request 508: MetadataRequest_v1(topics=['-uve-topic-9']) 02/13/2025 02:38:13.625 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 02/13/2025 02:38:13.625 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.625 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 503 (602.5209426879883 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/13/2025 02:38:13.626 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 02/13/2025 02:38:13.626 7f892a51c780 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 02/13/2025 02:38:13.626 7f892a51c780 [kafka.conn] [DEBUG]: Response 508 (1.6474723815917969 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.45', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-9', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 02/13/2025 02:38:13.627 7f892a51c780 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 02/13/2025 02:38:13.718 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 313 02/13/2025 02:38:13.719 7f8929cac8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.719 7f8929cac8d0 [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=313, max_bytes=1048576)])]) 02/13/2025 02:38:13.719 7f8929cac8d0 [kafka.conn] [DEBUG]: Request 567: 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=313, max_bytes=1048576)])]) 02/13/2025 02:38:13.719 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 18 02/13/2025 02:38:13.719 7f892a695d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.719 7f892a695d68 [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=18, max_bytes=1048576)])]) 02/13/2025 02:38:13.720 7f892a695d68 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=18, max_bytes=1048576)])]) 02/13/2025 02:38:13.720 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 21 02/13/2025 02:38:13.720 7f892aa3dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.720 7f892aa3dd68 [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=21, max_bytes=1048576)])]) 02/13/2025 02:38:13.720 7f892aa3dd68 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=21, max_bytes=1048576)])]) 02/13/2025 02:38:13.721 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 02/13/2025 02:38:13.721 7f892aa3d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.721 7f892aa3d438 [kafka.conn] [DEBUG]: Response 511 (601.3078689575195 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=19, last_stable_offset=19, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.721 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 111 02/13/2025 02:38:13.722 7f892aa0b4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.722 7f892aa0b4e0 [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=111, max_bytes=1048576)])]) 02/13/2025 02:38:13.722 7f892aa0b4e0 [kafka.conn] [DEBUG]: Request 526: 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=111, max_bytes=1048576)])]) 02/13/2025 02:38:13.834 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 02/13/2025 02:38:13.834 7f892aa30198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.834 7f892aa30198 [kafka.conn] [DEBUG]: Response 520 (601.1834144592285 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=75, last_stable_offset=75, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.835 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 29 02/13/2025 02:38:13.835 7f892aa0b828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.835 7f892aa0b828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:13.835 7f892aa0b828 [kafka.conn] [DEBUG]: Request 515: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 02/13/2025 02:38:13.835 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 14 02/13/2025 02:38:13.835 7f892b2946d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.835 7f892b2946d8 [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=14, max_bytes=1048576)])]) 02/13/2025 02:38:13.836 7f892b2946d8 [kafka.conn] [DEBUG]: Request 510: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 02/13/2025 02:38:13.915 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 02/13/2025 02:38:13.915 7f892a51c4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:13.915 7f892a51c4e0 [kafka.conn] [DEBUG]: Response 505 (601.299524307251 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:13.915 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 02/13/2025 02:38:13.915 7f892aa42240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.915 7f892aa42240 [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=56, max_bytes=1048576)])]) 02/13/2025 02:38:13.916 7f892aa42240 [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-17', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 02/13/2025 02:38:13.932 7f8928f7fb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 134 02/13/2025 02:38:13.933 7f8928f7fb70 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-28']) to node 1 02/13/2025 02:38:13.933 7f8928f7fb70 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-28']) 02/13/2025 02:38:13.933 7f8928f7fb70 [kafka.conn] [DEBUG]: Request 541: MetadataRequest_v1(topics=['-uve-topic-28']) 02/13/2025 02:38:13.970 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 98 02/13/2025 02:38:13.971 7f8929d22198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:13.971 7f8929d22198 [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=98, max_bytes=1048576)])]) 02/13/2025 02:38:13.971 7f8929d22198 [kafka.conn] [DEBUG]: Request 532: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=98, max_bytes=1048576)])]) 02/13/2025 02:38:14.014 7f892aa34978 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-10']) to node 1 02/13/2025 02:38:14.014 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-10']) 02/13/2025 02:38:14.015 7f892aa34978 [kafka.conn] [DEBUG]: Request 513: MetadataRequest_v1(topics=['-uve-topic-10']) 02/13/2025 02:38:14.015 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 02/13/2025 02:38:14.015 7f892aa34978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.015 7f892aa34978 [kafka.conn] [DEBUG]: Response 512 (602.3340225219727 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=22, last_stable_offset=22, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.016 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 542 02/13/2025 02:38:14.016 7f8929d22240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.016 7f8929d22240 [kafka.conn] [DEBUG]: Response 542 (602.5729179382324 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.032 7f8929cac390 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-26']) to node 1 02/13/2025 02:38:14.032 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-26']) 02/13/2025 02:38:14.033 7f8929cac390 [kafka.conn] [DEBUG]: Request 525: MetadataRequest_v1(topics=['-uve-topic-26']) 02/13/2025 02:38:14.033 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 524 02/13/2025 02:38:14.033 7f8929cac390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.033 7f8929cac390 [kafka.conn] [DEBUG]: Response 524 (602.1842956542969 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.034 7f8928f7fcc0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-29']) to node 1 02/13/2025 02:38:14.034 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-29']) 02/13/2025 02:38:14.034 7f8928f7fcc0 [kafka.conn] [DEBUG]: Request 565: MetadataRequest_v1(topics=['-uve-topic-29']) 02/13/2025 02:38:14.034 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 564 02/13/2025 02:38:14.034 7f8928f7fcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.034 7f8928f7fcc0 [kafka.conn] [DEBUG]: Response 564 (602.5996208190918 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=257, last_stable_offset=257, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.052 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 522 02/13/2025 02:38:14.052 7f8929cacb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.053 7f8929cacb70 [kafka.conn] [DEBUG]: Response 522 (604.7227382659912 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.062 7f892a51ca20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 5 02/13/2025 02:38:14.062 7f892a51ca20 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-8']) to node 1 02/13/2025 02:38:14.062 7f892a51ca20 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-8']) 02/13/2025 02:38:14.062 7f892a51ca20 [kafka.conn] [DEBUG]: Request 506: MetadataRequest_v1(topics=['-uve-topic-8']) 02/13/2025 02:38:14.108 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 02/13/2025 02:38:14.108 7f8929d22438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.108 7f8929d22438 [kafka.conn] [DEBUG]: Response 536 (601.2158393859863 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, last_stable_offset=161, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.125 7f8929cac630 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-25']) to node 1 02/13/2025 02:38:14.125 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-25']) 02/13/2025 02:38:14.125 7f8929cac630 [kafka.conn] [DEBUG]: Request 533: MetadataRequest_v1(topics=['-uve-topic-25']) 02/13/2025 02:38:14.125 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 532 02/13/2025 02:38:14.125 7f8929cac630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.125 7f8929cac630 [kafka.conn] [DEBUG]: Response 532 (602.5245189666748 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.200 7f892aa420f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54 02/13/2025 02:38:14.200 7f892aa420f0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-18']) to node 1 02/13/2025 02:38:14.200 7f892aa420f0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-18']) 02/13/2025 02:38:14.200 7f892aa420f0 [kafka.conn] [DEBUG]: Request 520: MetadataRequest_v1(topics=['-uve-topic-18']) 02/13/2025 02:38:14.201 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:14.201 7f892aa42588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.201 7f892aa42588 [kafka.conn] [DEBUG]: Response 509 (601.2303829193115 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.203 7f892a6a5eb8 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-19']) to node 1 02/13/2025 02:38:14.203 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-19']) 02/13/2025 02:38:14.203 7f892a6a5eb8 [kafka.conn] [DEBUG]: Request 519: MetadataRequest_v1(topics=['-uve-topic-19']) 02/13/2025 02:38:14.203 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 02/13/2025 02:38:14.203 7f892a6a5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.203 7f892a6a5eb8 [kafka.conn] [DEBUG]: Response 518 (601.207971572876 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.204 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:14.204 7f892aa0b630 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 02/13/2025 02:38:14.204 7f892aa0b630 [kafka.conn] [DEBUG]: Response 504 (601.449728012085 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.45', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-2', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1])])]) 02/13/2025 02:38:14.205 7f892aa0b630 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 02/13/2025 02:38:14.205 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24 02/13/2025 02:38:14.206 7f892aa42978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:14.206 7f892aa42978 [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=24, max_bytes=1048576)])]) 02/13/2025 02:38:14.206 7f892aa42978 [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-15', partitions=[(partition=0, offset=24, max_bytes=1048576)])]) 02/13/2025 02:38:14.206 7f8929cac0f0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-27']) to node 1 02/13/2025 02:38:14.206 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-27']) 02/13/2025 02:38:14.206 7f8929cac0f0 [kafka.conn] [DEBUG]: Request 544: MetadataRequest_v1(topics=['-uve-topic-27']) 02/13/2025 02:38:14.207 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 543 02/13/2025 02:38:14.207 7f8929cac0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.207 7f8929cac0f0 [kafka.conn] [DEBUG]: Response 543 (601.7510890960693 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=143, last_stable_offset=143, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.224 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2365 02/13/2025 02:38:14.224 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:14.224 7f892aa07630 [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=2365, max_bytes=1048576)])]) 02/13/2025 02:38:14.224 7f892aa07630 [kafka.conn] [DEBUG]: Request 796: 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=2365, max_bytes=1048576)])]) 02/13/2025 02:38:14.225 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 796 02/13/2025 02:38:14.225 7f892aa07630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.225 7f892aa07630 [kafka.conn] [DEBUG]: Response 796 (0.9925365447998047 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2366, last_stable_offset=2366, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t=\x00\x00\x01\x04\x00\x00\x00\x00\x02\xa8\xb34%\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/13/2025 02:38:14.226 7f892aa07630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2365 to buffered record list 02/13/2025 02:38:14.226 7f89297bb4e0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-13']) to node 1 02/13/2025 02:38:14.226 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-13']) 02/13/2025 02:38:14.226 7f89297bb4e0 [kafka.conn] [DEBUG]: Request 510: MetadataRequest_v1(topics=['-uve-topic-13']) 02/13/2025 02:38:14.226 7f892aa0bf60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/13/2025 02:38:14.227 7f892aa0bf60 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-1']) to node 1 02/13/2025 02:38:14.227 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-1']) 02/13/2025 02:38:14.227 7f892aa0bf60 [kafka.conn] [DEBUG]: Request 504: MetadataRequest_v1(topics=['-uve-topic-1']) 02/13/2025 02:38:14.227 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 02/13/2025 02:38:14.227 7f89297bb4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 02/13/2025 02:38:14.227 7f89297bb4e0 [kafka.conn] [DEBUG]: Response 509 (603.1529903411865 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=17, last_stable_offset=17, aborted_transactions=NULL, message_set=b'')])]) 02/13/2025 02:38:14.228 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10 02/13/2025 02:38:14.228 7f892a51c780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/13/2025 02:38:14.228 7f892a51c780 [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=10, max_bytes=1048576)])]) 02/13/2025 02:38:14.228 7f892a51c780 [kafka.conn] [DEBUG]: Request 509: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 02/13/2025 02:38:14.228 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 02/13/2025 02:38:14.228 7f892aa0bf60 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 02/13/2025 02:38:14.229 7f892aa0bf60 [kafka.conn] [DEBUG]: Response 504 (2.129793167114258 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.45', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-1', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 02/13/2025 02:38:14.230 7f892aa0bf60 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)