03/27/2025 02:29:34.971 7f63efa6a6d8 [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-11', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 03/27/2025 02:29:34.972 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 543 03/27/2025 02:29:34.972 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:34.972 7f63eecacac8 [kafka.conn] [DEBUG]: Response 543 (605.1418781280518 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=235, last_stable_offset=235, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:34.972 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2382 03/27/2025 02:29:34.973 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:34.973 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: 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=2382, max_bytes=1048576)])]) 03/27/2025 02:29:34.973 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Request 755: 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=2382, max_bytes=1048576)])]) 03/27/2025 02:29:35.019 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:29:35.020 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.020 7f63ef5532e8 [kafka.conn] [DEBUG]: Response 507 (602.4096012115479 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.021 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:35.021 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.021 7f63ef50ac18 [kafka.conn] [DEBUG]: Response 508 (602.5295257568359 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.039 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 524 03/27/2025 02:29:35.039 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.040 7f63ef8da048 [kafka.conn] [DEBUG]: Response 524 (601.5031337738037 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=115, last_stable_offset=115, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.103 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 534 03/27/2025 02:29:35.104 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.104 7f63eeb9dac8 [kafka.conn] [DEBUG]: Response 534 (601.4969348907471 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.137 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 03/27/2025 02:29:35.137 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.137 7f63ef4ffcc0 [kafka.conn] [DEBUG]: Response 501 (601.325273513794 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'')])]) 03/27/2025 02:29:35.178 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/27/2025 02:29:35.178 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.178 7f63efa6a780 [kafka.conn] [DEBUG]: Response 506 (601.9561290740967 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.178 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 03/27/2025 02:29:35.179 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.179 7f63ef5364e0 [kafka.conn] [DEBUG]: Response 505 (602.0157337188721 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.179 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:29:35.179 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.179 7f63ef536828 [kafka.conn] [DEBUG]: Response 512 (601.8109321594238 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.180 7f63eda2c048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 10 03/27/2025 02:29:35.180 7f63eda2c048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.180 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: 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=10, max_bytes=1048576)])]) 03/27/2025 02:29:35.180 7f63eda2c048 [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=10, max_bytes=1048576)])]) 03/27/2025 02:29:35.245 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 238 03/27/2025 02:29:35.246 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.246 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: 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=238, max_bytes=1048576)])]) 03/27/2025 02:29:35.246 7f63eda24d68 [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-29', partitions=[(partition=0, offset=238, max_bytes=1048576)])]) 03/27/2025 02:29:35.300 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 03/27/2025 02:29:35.301 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.301 7f63eecac828 [kafka.conn] [DEBUG]: Response 528 (601.3178825378418 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.332 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/27/2025 02:29:35.332 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.332 7f63ef50acc0 [kafka.conn] [DEBUG]: Response 518 (601.1669635772705 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.347 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:29:35.347 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.348 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:35.348 7f63eeb11f60 [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)])]) 03/27/2025 02:29:35.348 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34 03/27/2025 02:29:35.348 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.348 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: 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=34, max_bytes=1048576)])]) 03/27/2025 02:29:35.348 7f63ef562d68 [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=34, max_bytes=1048576)])]) 03/27/2025 02:29:35.443 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:29:35.443 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.443 7f63ef553198 [kafka.conn] [DEBUG]: Response 510 (601.294755935669 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=25, last_stable_offset=25, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.444 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:29:35.444 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.444 7f63ef536ac8 [kafka.conn] [DEBUG]: Response 510 (600.8994579315186 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.446 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 539 03/27/2025 02:29:35.446 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.446 7f63eeb9dd68 [kafka.conn] [DEBUG]: Response 539 (601.7799377441406 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=189, last_stable_offset=189, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.447 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/27/2025 02:29:35.447 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.447 7f63eeca00f0 [kafka.conn] [DEBUG]: Response 519 (601.7956733703613 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.447 7f63eecac6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 134 03/27/2025 02:29:35.447 7f63eecac6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.447 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: 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=134, max_bytes=1048576)])]) 03/27/2025 02:29:35.448 7f63eecac6d8 [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-24', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 03/27/2025 02:29:35.448 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:29:35.448 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.448 7f63ef553c18 [kafka.conn] [DEBUG]: Response 513 (601.3131141662598 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.500 7f63ef5620f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 31 03/27/2025 02:29:35.500 7f63ef5620f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.501 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: 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=31, max_bytes=1048576)])]) 03/27/2025 02:29:35.501 7f63ef5620f0 [kafka.conn] [DEBUG]: Request 512: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=31, max_bytes=1048576)])]) 03/27/2025 02:29:35.501 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 501 03/27/2025 02:29:35.501 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.502 7f63efa6a8d0 [kafka.conn] [DEBUG]: Response 501 (601.1788845062256 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.535 7f63eeba9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 198 03/27/2025 02:29:35.535 7f63eeba9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.535 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: 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=198, max_bytes=1048576)])]) 03/27/2025 02:29:35.535 7f63eeba9048 [kafka.conn] [DEBUG]: Request 547: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/27/2025 02:29:35.536 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 03/27/2025 02:29:35.536 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.536 7f63eecacd68 [kafka.conn] [DEBUG]: Response 536 (600.9373664855957 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.567 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 517 03/27/2025 02:29:35.567 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.567 7f63eeb9db70 [kafka.conn] [DEBUG]: Response 517 (601.3021469116211 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=64, last_stable_offset=64, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.569 7f63ef553828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 12 03/27/2025 02:29:35.569 7f63ef553828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.569 7f63ef553828 [kafka.protocol.parser] [DEBUG]: 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=12, max_bytes=1048576)])]) 03/27/2025 02:29:35.569 7f63ef553828 [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-8', partitions=[(partition=0, offset=12, max_bytes=1048576)])]) 03/27/2025 02:29:35.570 7f63efac1f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 54 03/27/2025 02:29:35.570 7f63efac1f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.570 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: 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=54, max_bytes=1048576)])]) 03/27/2025 02:29:35.570 7f63efac1f60 [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-19', partitions=[(partition=0, offset=54, max_bytes=1048576)])]) 03/27/2025 02:29:35.572 7f63eecacac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 235 03/27/2025 02:29:35.573 7f63eecacac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.573 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: 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=235, max_bytes=1048576)])]) 03/27/2025 02:29:35.573 7f63eecacac8 [kafka.conn] [DEBUG]: Request 544: 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=235, max_bytes=1048576)])]) 03/27/2025 02:29:35.573 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/27/2025 02:29:35.573 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.574 7f63efa6a6d8 [kafka.conn] [DEBUG]: Response 506 (602.9884815216064 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.574 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 755 03/27/2025 02:29:35.574 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.574 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Response 755 (601.4418601989746 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2383, last_stable_offset=2383, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\tN\x00\x00\x01\x04\x00\x00\x00\x00\x02\xdd\x9f\x1bR\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/27/2025 02:29:35.574 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2382 to buffered record list 03/27/2025 02:29:35.621 7f63ef5532e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 03/27/2025 02:29:35.622 7f63ef5532e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.622 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: 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=16, max_bytes=1048576)])]) 03/27/2025 02:29:35.622 7f63ef5532e8 [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-4', partitions=[(partition=0, offset=16, max_bytes=1048576)])]) 03/27/2025 02:29:35.622 7f63ef50ac18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 29 03/27/2025 02:29:35.622 7f63ef50ac18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.623 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 03/27/2025 02:29:35.623 7f63ef50ac18 [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-17', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 03/27/2025 02:29:35.641 7f63ef8da048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 115 03/27/2025 02:29:35.641 7f63ef8da048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.641 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: 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=115, max_bytes=1048576)])]) 03/27/2025 02:29:35.641 7f63ef8da048 [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=115, max_bytes=1048576)])]) 03/27/2025 02:29:35.675 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2383 03/27/2025 02:29:35.675 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.676 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: 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=2383, max_bytes=1048576)])]) 03/27/2025 02:29:35.676 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Request 756: 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=2383, max_bytes=1048576)])]) 03/27/2025 02:29:35.704 7f63eeb9dac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 146 03/27/2025 02:29:35.705 7f63eeb9dac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.705 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: 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=146, max_bytes=1048576)])]) 03/27/2025 02:29:35.705 7f63eeb9dac8 [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-28', partitions=[(partition=0, offset=146, max_bytes=1048576)])]) 03/27/2025 02:29:35.738 7f63ef4ffcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 03/27/2025 02:29:35.738 7f63ef4ffcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.738 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: 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)])]) 03/27/2025 02:29:35.738 7f63ef4ffcc0 [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)])]) 03/27/2025 02:29:35.779 7f63efa6a780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 12 03/27/2025 02:29:35.779 7f63efa6a780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.779 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: 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=12, max_bytes=1048576)])]) 03/27/2025 02:29:35.779 7f63efa6a780 [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-10', partitions=[(partition=0, offset=12, max_bytes=1048576)])]) 03/27/2025 02:29:35.780 7f63ef5364e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 16 03/27/2025 02:29:35.780 7f63ef5364e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.780 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: 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=16, max_bytes=1048576)])]) 03/27/2025 02:29:35.780 7f63ef5364e0 [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=16, max_bytes=1048576)])]) 03/27/2025 02:29:35.780 7f63ef536828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 56 03/27/2025 02:29:35.780 7f63ef536828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.781 7f63ef536828 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 03/27/2025 02:29:35.781 7f63ef536828 [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-12', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 03/27/2025 02:29:35.781 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/27/2025 02:29:35.781 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.782 7f63eda2c048 [kafka.conn] [DEBUG]: Response 506 (601.703405380249 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.847 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 539 03/27/2025 02:29:35.847 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.847 7f63eda24d68 [kafka.conn] [DEBUG]: Response 539 (601.4740467071533 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=238, last_stable_offset=238, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.901 7f63eecac828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 124 03/27/2025 02:29:35.902 7f63eecac828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.902 7f63eecac828 [kafka.protocol.parser] [DEBUG]: 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=124, max_bytes=1048576)])]) 03/27/2025 02:29:35.902 7f63eecac828 [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-23', partitions=[(partition=0, offset=124, max_bytes=1048576)])]) 03/27/2025 02:29:35.933 7f63ef50acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 58 03/27/2025 02:29:35.933 7f63ef50acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:35.933 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: 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=58, max_bytes=1048576)])]) 03/27/2025 02:29:35.934 7f63ef50acc0 [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=58, max_bytes=1048576)])]) 03/27/2025 02:29:35.949 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/27/2025 02:29:35.949 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.950 7f63eeb11f60 [kafka.conn] [DEBUG]: Response 502 (601.8571853637695 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:35.950 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:35.951 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:35.951 7f63ef562d68 [kafka.conn] [DEBUG]: Response 509 (602.3683547973633 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=34, last_stable_offset=34, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.044 7f63ef553198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 25 03/27/2025 02:29:36.044 7f63ef553198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.044 7f63ef553198 [kafka.protocol.parser] [DEBUG]: 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=25, max_bytes=1048576)])]) 03/27/2025 02:29:36.045 7f63ef553198 [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=25, max_bytes=1048576)])]) 03/27/2025 02:29:36.045 7f63ef536ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 36 03/27/2025 02:29:36.045 7f63ef536ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.045 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 03/27/2025 02:29:36.045 7f63ef536ac8 [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-14', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 03/27/2025 02:29:36.047 7f63eeb9dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 189 03/27/2025 02:29:36.047 7f63eeb9dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.047 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: 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=189, max_bytes=1048576)])]) 03/27/2025 02:29:36.047 7f63eeb9dd68 [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-26', partitions=[(partition=0, offset=189, max_bytes=1048576)])]) 03/27/2025 02:29:36.047 7f63eeca00f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 100 03/27/2025 02:29:36.047 7f63eeca00f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.047 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: 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=100, max_bytes=1048576)])]) 03/27/2025 02:29:36.048 7f63eeca00f0 [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-20', partitions=[(partition=0, offset=100, max_bytes=1048576)])]) 03/27/2025 02:29:36.048 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 528 03/27/2025 02:29:36.049 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.049 7f63eecac6d8 [kafka.conn] [DEBUG]: Response 528 (601.2241840362549 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.049 7f63ef553c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 36 03/27/2025 02:29:36.049 7f63ef553c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.049 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 03/27/2025 02:29:36.050 7f63ef553c18 [kafka.conn] [DEBUG]: Request 514: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 03/27/2025 02:29:36.102 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:29:36.103 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.103 7f63ef5620f0 [kafka.conn] [DEBUG]: Response 512 (602.0221710205078 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.103 7f63efa6a8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 03/27/2025 02:29:36.103 7f63efa6a8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.103 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:36.104 7f63efa6a8d0 [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-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:36.137 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 547 03/27/2025 02:29:36.137 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.138 7f63eeba9048 [kafka.conn] [DEBUG]: Response 547 (602.6337146759033 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.139 7f63eecacd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 150 03/27/2025 02:29:36.139 7f63eecacd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.139 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 03/27/2025 02:29:36.140 7f63eecacd68 [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-21', partitions=[(partition=0, offset=150, max_bytes=1048576)])]) 03/27/2025 02:29:36.168 7f63eeb9db70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 64 03/27/2025 02:29:36.168 7f63eeb9db70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.169 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: 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=64, max_bytes=1048576)])]) 03/27/2025 02:29:36.169 7f63eeb9db70 [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-27', partitions=[(partition=0, offset=64, max_bytes=1048576)])]) 03/27/2025 02:29:36.171 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:29:36.171 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.171 7f63ef553828 [kafka.conn] [DEBUG]: Response 507 (601.6206741333008 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.172 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:29:36.172 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.172 7f63efac1f60 [kafka.conn] [DEBUG]: Response 510 (601.8457412719727 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.174 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 544 03/27/2025 02:29:36.174 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.174 7f63eecacac8 [kafka.conn] [DEBUG]: Response 544 (601.299524307251 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=235, last_stable_offset=235, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.175 7f63efa6a6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 14 03/27/2025 02:29:36.175 7f63efa6a6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.175 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: 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=14, max_bytes=1048576)])]) 03/27/2025 02:29:36.175 7f63efa6a6d8 [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-11', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 03/27/2025 02:29:36.224 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:36.224 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.224 7f63ef5532e8 [kafka.conn] [DEBUG]: Response 508 (602.1089553833008 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.225 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:36.225 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.225 7f63ef50ac18 [kafka.conn] [DEBUG]: Response 509 (601.980447769165 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.242 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 525 03/27/2025 02:29:36.242 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.243 7f63ef8da048 [kafka.conn] [DEBUG]: Response 525 (601.1664867401123 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=115, last_stable_offset=115, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.277 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 756 03/27/2025 02:29:36.277 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.277 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Response 756 (601.6035079956055 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2383, last_stable_offset=2383, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.306 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 535 03/27/2025 02:29:36.306 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.306 7f63eeb9dac8 [kafka.conn] [DEBUG]: Response 535 (601.4947891235352 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.339 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/27/2025 02:29:36.339 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.339 7f63ef4ffcc0 [kafka.conn] [DEBUG]: Response 502 (601.3133525848389 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'')])]) 03/27/2025 02:29:36.382 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:29:36.382 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.382 7f63efa6a780 [kafka.conn] [DEBUG]: Response 507 (602.6787757873535 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.382 7f63eda2c048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 10 03/27/2025 02:29:36.382 7f63eda2c048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.382 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: 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=10, max_bytes=1048576)])]) 03/27/2025 02:29:36.383 7f63eda2c048 [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=10, max_bytes=1048576)])]) 03/27/2025 02:29:36.383 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 03/27/2025 02:29:36.383 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.383 7f63ef5364e0 [kafka.conn] [DEBUG]: Response 506 (603.2195091247559 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.384 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:29:36.384 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.384 7f63ef536828 [kafka.conn] [DEBUG]: Response 513 (603.0800342559814 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.448 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 238 03/27/2025 02:29:36.449 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.449 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: 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=238, max_bytes=1048576)])]) 03/27/2025 02:29:36.449 7f63eda24d68 [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-29', partitions=[(partition=0, offset=238, max_bytes=1048576)])]) 03/27/2025 02:29:36.504 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 03/27/2025 02:29:36.504 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.504 7f63eecac828 [kafka.conn] [DEBUG]: Response 529 (601.9518375396729 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.535 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/27/2025 02:29:36.535 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.535 7f63ef50acc0 [kafka.conn] [DEBUG]: Response 519 (601.6855239868164 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.550 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:29:36.551 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.551 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:36.551 7f63eeb11f60 [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)])]) 03/27/2025 02:29:36.551 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34 03/27/2025 02:29:36.551 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.551 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: 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=34, max_bytes=1048576)])]) 03/27/2025 02:29:36.552 7f63ef562d68 [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=34, max_bytes=1048576)])]) 03/27/2025 02:29:36.646 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:29:36.647 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.647 7f63ef553198 [kafka.conn] [DEBUG]: Response 511 (602.4625301361084 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=25, last_stable_offset=25, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.648 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:29:36.648 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.648 7f63ef536ac8 [kafka.conn] [DEBUG]: Response 511 (602.7650833129883 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.649 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 03/27/2025 02:29:36.649 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.650 7f63eeb9dd68 [kafka.conn] [DEBUG]: Response 540 (602.7097702026367 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=189, last_stable_offset=189, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.650 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/27/2025 02:29:36.650 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.651 7f63eeca00f0 [kafka.conn] [DEBUG]: Response 520 (602.9441356658936 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.651 7f63eecac6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 134 03/27/2025 02:29:36.651 7f63eecac6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.651 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: 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=134, max_bytes=1048576)])]) 03/27/2025 02:29:36.652 7f63eecac6d8 [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-24', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 03/27/2025 02:29:36.652 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 514 03/27/2025 02:29:36.653 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.653 7f63ef553c18 [kafka.conn] [DEBUG]: Response 514 (603.0950546264648 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.705 7f63ef5620f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 31 03/27/2025 02:29:36.705 7f63ef5620f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.705 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: 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=31, max_bytes=1048576)])]) 03/27/2025 02:29:36.705 7f63ef5620f0 [kafka.conn] [DEBUG]: Request 513: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=31, max_bytes=1048576)])]) 03/27/2025 02:29:36.706 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 502 03/27/2025 02:29:36.706 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.706 7f63efa6a8d0 [kafka.conn] [DEBUG]: Response 502 (602.5042533874512 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.739 7f63eeba9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 198 03/27/2025 02:29:36.739 7f63eeba9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.739 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: 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=198, max_bytes=1048576)])]) 03/27/2025 02:29:36.739 7f63eeba9048 [kafka.conn] [DEBUG]: Request 548: 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=198, max_bytes=1048576)])]) 03/27/2025 02:29:36.741 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 03/27/2025 02:29:36.742 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.742 7f63eecacd68 [kafka.conn] [DEBUG]: Response 537 (601.942777633667 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.770 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 518 03/27/2025 02:29:36.770 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.770 7f63eeb9db70 [kafka.conn] [DEBUG]: Response 518 (601.3514995574951 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=64, last_stable_offset=64, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.771 7f63ef553828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 12 03/27/2025 02:29:36.771 7f63ef553828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.772 7f63ef553828 [kafka.protocol.parser] [DEBUG]: 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=12, max_bytes=1048576)])]) 03/27/2025 02:29:36.772 7f63ef553828 [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-8', partitions=[(partition=0, offset=12, max_bytes=1048576)])]) 03/27/2025 02:29:36.772 7f63efac1f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 54 03/27/2025 02:29:36.772 7f63efac1f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.772 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: 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=54, max_bytes=1048576)])]) 03/27/2025 02:29:36.773 7f63efac1f60 [kafka.conn] [DEBUG]: Request 511: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=54, max_bytes=1048576)])]) 03/27/2025 02:29:36.775 7f63eecacac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 235 03/27/2025 02:29:36.775 7f63eecacac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.775 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: 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=235, max_bytes=1048576)])]) 03/27/2025 02:29:36.775 7f63eecacac8 [kafka.conn] [DEBUG]: Request 545: 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=235, max_bytes=1048576)])]) 03/27/2025 02:29:36.776 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:29:36.776 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.776 7f63efa6a6d8 [kafka.conn] [DEBUG]: Response 507 (600.9218692779541 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:36.825 7f63ef5532e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 03/27/2025 02:29:36.826 7f63ef5532e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.826 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: 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=16, max_bytes=1048576)])]) 03/27/2025 02:29:36.826 7f63ef5532e8 [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-4', partitions=[(partition=0, offset=16, max_bytes=1048576)])]) 03/27/2025 02:29:36.826 7f63ef50ac18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 29 03/27/2025 02:29:36.827 7f63ef50ac18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.827 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 03/27/2025 02:29:36.827 7f63ef50ac18 [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-17', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 03/27/2025 02:29:36.844 7f63ef8da048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 115 03/27/2025 02:29:36.844 7f63ef8da048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.844 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: 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=115, max_bytes=1048576)])]) 03/27/2025 02:29:36.845 7f63ef8da048 [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=115, max_bytes=1048576)])]) 03/27/2025 02:29:36.879 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2383 03/27/2025 02:29:36.880 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.880 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: 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=2383, max_bytes=1048576)])]) 03/27/2025 02:29:36.880 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Request 757: 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=2383, max_bytes=1048576)])]) 03/27/2025 02:29:36.881 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 757 03/27/2025 02:29:36.881 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.881 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Response 757 (1.1987686157226562 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2384, last_stable_offset=2384, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\tO\x00\x00\x01\x04\x00\x00\x00\x00\x02\xa0*<\x1d\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/27/2025 02:29:36.882 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2383 to buffered record list 03/27/2025 02:29:36.907 7f63eeb9dac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 146 03/27/2025 02:29:36.908 7f63eeb9dac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.908 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: 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=146, max_bytes=1048576)])]) 03/27/2025 02:29:36.908 7f63eeb9dac8 [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=146, max_bytes=1048576)])]) 03/27/2025 02:29:36.940 7f63ef4ffcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 03/27/2025 02:29:36.940 7f63ef4ffcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.941 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: 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)])]) 03/27/2025 02:29:36.941 7f63ef4ffcc0 [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)])]) 03/27/2025 02:29:36.983 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2384 03/27/2025 02:29:36.983 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.983 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: 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=2384, max_bytes=1048576)])]) 03/27/2025 02:29:36.983 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Request 758: 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=2384, max_bytes=1048576)])]) 03/27/2025 02:29:36.983 7f63efa6a780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 12 03/27/2025 02:29:36.984 7f63efa6a780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.984 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: 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=12, max_bytes=1048576)])]) 03/27/2025 02:29:36.984 7f63efa6a780 [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=12, max_bytes=1048576)])]) 03/27/2025 02:29:36.985 7f63ef5364e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 16 03/27/2025 02:29:36.985 7f63ef5364e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.985 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: 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=16, max_bytes=1048576)])]) 03/27/2025 02:29:36.985 7f63ef5364e0 [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=16, max_bytes=1048576)])]) 03/27/2025 02:29:36.985 7f63ef536828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 56 03/27/2025 02:29:36.985 7f63ef536828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:36.985 7f63ef536828 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 03/27/2025 02:29:36.986 7f63ef536828 [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-12', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 03/27/2025 02:29:36.986 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:29:36.986 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:36.987 7f63eda2c048 [kafka.conn] [DEBUG]: Response 507 (603.8117408752441 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.050 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 540 03/27/2025 02:29:37.050 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.050 7f63eda24d68 [kafka.conn] [DEBUG]: Response 540 (601.2630462646484 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=238, last_stable_offset=238, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.105 7f63eecac828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 124 03/27/2025 02:29:37.105 7f63eecac828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.105 7f63eecac828 [kafka.protocol.parser] [DEBUG]: 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=124, max_bytes=1048576)])]) 03/27/2025 02:29:37.106 7f63eecac828 [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-23', partitions=[(partition=0, offset=124, max_bytes=1048576)])]) 03/27/2025 02:29:37.136 7f63ef50acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 58 03/27/2025 02:29:37.136 7f63ef50acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.137 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: 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=58, max_bytes=1048576)])]) 03/27/2025 02:29:37.137 7f63ef50acc0 [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-18', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 03/27/2025 02:29:37.154 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/27/2025 02:29:37.154 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.154 7f63eeb11f60 [kafka.conn] [DEBUG]: Response 503 (602.9202938079834 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.154 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:29:37.154 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.155 7f63ef562d68 [kafka.conn] [DEBUG]: Response 510 (602.8785705566406 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=34, last_stable_offset=34, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.248 7f63ef553198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 25 03/27/2025 02:29:37.248 7f63ef553198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.248 7f63ef553198 [kafka.protocol.parser] [DEBUG]: 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=25, max_bytes=1048576)])]) 03/27/2025 02:29:37.248 7f63ef553198 [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-7', partitions=[(partition=0, offset=25, max_bytes=1048576)])]) 03/27/2025 02:29:37.249 7f63ef536ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 36 03/27/2025 02:29:37.249 7f63ef536ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.249 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 03/27/2025 02:29:37.249 7f63ef536ac8 [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-14', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 03/27/2025 02:29:37.250 7f63eeb9dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 189 03/27/2025 02:29:37.250 7f63eeb9dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.250 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: 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=189, max_bytes=1048576)])]) 03/27/2025 02:29:37.251 7f63eeb9dd68 [kafka.conn] [DEBUG]: Request 541: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=189, max_bytes=1048576)])]) 03/27/2025 02:29:37.251 7f63eeca00f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 100 03/27/2025 02:29:37.251 7f63eeca00f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.251 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: 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=100, max_bytes=1048576)])]) 03/27/2025 02:29:37.252 7f63eeca00f0 [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-20', partitions=[(partition=0, offset=100, max_bytes=1048576)])]) 03/27/2025 02:29:37.253 7f63ef553c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 36 03/27/2025 02:29:37.253 7f63ef553c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.253 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 03/27/2025 02:29:37.254 7f63ef553c18 [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-6', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 03/27/2025 02:29:37.254 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 529 03/27/2025 02:29:37.254 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.254 7f63eecac6d8 [kafka.conn] [DEBUG]: Response 529 (602.5075912475586 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.307 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:29:37.307 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.308 7f63ef5620f0 [kafka.conn] [DEBUG]: Response 513 (602.4603843688965 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.308 7f63efa6a8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 03/27/2025 02:29:37.308 7f63efa6a8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.308 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:37.308 7f63efa6a8d0 [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=0, max_bytes=1048576)])]) 03/27/2025 02:29:37.341 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 548 03/27/2025 02:29:37.341 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.341 7f63eeba9048 [kafka.conn] [DEBUG]: Response 548 (601.9153594970703 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.343 7f63eecacd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 150 03/27/2025 02:29:37.343 7f63eecacd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.343 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 03/27/2025 02:29:37.343 7f63eecacd68 [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=150, max_bytes=1048576)])]) 03/27/2025 02:29:37.371 7f63eeb9db70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 64 03/27/2025 02:29:37.372 7f63eeb9db70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.372 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: 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=64, max_bytes=1048576)])]) 03/27/2025 02:29:37.372 7f63eeb9db70 [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-27', partitions=[(partition=0, offset=64, max_bytes=1048576)])]) 03/27/2025 02:29:37.373 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:37.373 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.373 7f63ef553828 [kafka.conn] [DEBUG]: Response 508 (601.0985374450684 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.374 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:29:37.374 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.374 7f63efac1f60 [kafka.conn] [DEBUG]: Response 511 (601.3622283935547 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.377 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 545 03/27/2025 02:29:37.377 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.377 7f63eecacac8 [kafka.conn] [DEBUG]: Response 545 (602.3099422454834 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=235, last_stable_offset=235, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.378 7f63efa6a6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 14 03/27/2025 02:29:37.378 7f63efa6a6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.378 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: 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=14, max_bytes=1048576)])]) 03/27/2025 02:29:37.378 7f63efa6a6d8 [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-11', partitions=[(partition=0, offset=14, max_bytes=1048576)])]) 03/27/2025 02:29:37.428 7f63ef5532e8 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-4']) to node 1 03/27/2025 02:29:37.428 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-4']) 03/27/2025 02:29:37.428 7f63ef5532e8 [kafka.conn] [DEBUG]: Request 510: MetadataRequest_v1(topics=['-uve-topic-4']) 03/27/2025 02:29:37.428 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:37.428 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.428 7f63ef5532e8 [kafka.conn] [DEBUG]: Response 509 (602.3778915405273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.429 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:29:37.429 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.429 7f63ef50ac18 [kafka.conn] [DEBUG]: Response 510 (602.257490158081 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.445 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 526 03/27/2025 02:29:37.445 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.446 7f63ef8da048 [kafka.conn] [DEBUG]: Response 526 (601.1583805084229 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=115, last_stable_offset=115, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.509 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 536 03/27/2025 02:29:37.509 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.509 7f63eeb9dac8 [kafka.conn] [DEBUG]: Response 536 (601.4013290405273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.542 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/27/2025 02:29:37.542 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.542 7f63ef4ffcc0 [kafka.conn] [DEBUG]: Response 503 (601.5915870666504 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'')])]) 03/27/2025 02:29:37.585 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 758 03/27/2025 02:29:37.585 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.585 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Response 758 (602.2889614105225 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2384, last_stable_offset=2384, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.586 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:37.586 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.587 7f63efa6a780 [kafka.conn] [DEBUG]: Response 508 (602.5369167327881 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.587 7f63eda2c048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 10 03/27/2025 02:29:37.587 7f63eda2c048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.587 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: 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=10, max_bytes=1048576)])]) 03/27/2025 02:29:37.588 7f63eda2c048 [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=10, max_bytes=1048576)])]) 03/27/2025 02:29:37.588 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 03/27/2025 02:29:37.588 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.588 7f63ef5364e0 [kafka.conn] [DEBUG]: Response 507 (603.4414768218994 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.589 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 514 03/27/2025 02:29:37.589 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.589 7f63ef536828 [kafka.conn] [DEBUG]: Response 514 (603.4045219421387 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.651 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 238 03/27/2025 02:29:37.651 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.651 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: 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=238, max_bytes=1048576)])]) 03/27/2025 02:29:37.652 7f63eda24d68 [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-29', partitions=[(partition=0, offset=238, max_bytes=1048576)])]) 03/27/2025 02:29:37.711 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 03/27/2025 02:29:37.711 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.711 7f63eecac828 [kafka.conn] [DEBUG]: Response 530 (605.7679653167725 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.738 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 520 03/27/2025 02:29:37.738 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.738 7f63ef50acc0 [kafka.conn] [DEBUG]: Response 520 (601.3534069061279 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.755 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:29:37.755 7f63eeb11f60 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-1']) to node 1 03/27/2025 02:29:37.755 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-1']) 03/27/2025 02:29:37.755 7f63eeb11f60 [kafka.conn] [DEBUG]: Request 504: MetadataRequest_v1(topics=['-uve-topic-1']) 03/27/2025 02:29:37.755 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34 03/27/2025 02:29:37.756 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.756 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: 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=34, max_bytes=1048576)])]) 03/27/2025 02:29:37.756 7f63ef562d68 [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=34, max_bytes=1048576)])]) 03/27/2025 02:29:37.849 7f63ef553198 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-7']) to node 1 03/27/2025 02:29:37.849 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-7']) 03/27/2025 02:29:37.849 7f63ef553198 [kafka.conn] [DEBUG]: Request 513: MetadataRequest_v1(topics=['-uve-topic-7']) 03/27/2025 02:29:37.850 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:29:37.850 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.850 7f63ef553198 [kafka.conn] [DEBUG]: Response 512 (601.5987396240234 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=25, last_stable_offset=25, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.850 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:29:37.850 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.850 7f63ef536ac8 [kafka.conn] [DEBUG]: Response 512 (601.0048389434814 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.851 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 03/27/2025 02:29:37.851 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.851 7f63eeb9dd68 [kafka.conn] [DEBUG]: Response 541 (600.7368564605713 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=189, last_stable_offset=189, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.852 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 03/27/2025 02:29:37.852 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.852 7f63eeca00f0 [kafka.conn] [DEBUG]: Response 521 (600.7325649261475 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=100, last_stable_offset=100, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.854 7f63ef553c18 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-6']) to node 1 03/27/2025 02:29:37.854 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-6']) 03/27/2025 02:29:37.854 7f63ef553c18 [kafka.conn] [DEBUG]: Request 516: MetadataRequest_v1(topics=['-uve-topic-6']) 03/27/2025 02:29:37.855 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 03/27/2025 02:29:37.855 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.855 7f63ef553c18 [kafka.conn] [DEBUG]: Response 515 (601.1650562286377 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.855 7f63eecac6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 134 03/27/2025 02:29:37.855 7f63eecac6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.855 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: 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=134, max_bytes=1048576)])]) 03/27/2025 02:29:37.855 7f63eecac6d8 [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-24', partitions=[(partition=0, offset=134, max_bytes=1048576)])]) 03/27/2025 02:29:37.908 7f63ef5620f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 31 03/27/2025 02:29:37.908 7f63ef5620f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.909 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: 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=31, max_bytes=1048576)])]) 03/27/2025 02:29:37.909 7f63ef5620f0 [kafka.conn] [DEBUG]: Request 514: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=31, max_bytes=1048576)])]) 03/27/2025 02:29:37.910 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 503 03/27/2025 02:29:37.910 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.910 7f63efa6a8d0 [kafka.conn] [DEBUG]: Response 503 (601.9425392150879 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.942 7f63eeba9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 198 03/27/2025 02:29:37.942 7f63eeba9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.942 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: 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=198, max_bytes=1048576)])]) 03/27/2025 02:29:37.942 7f63eeba9048 [kafka.conn] [DEBUG]: Request 549: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=198, max_bytes=1048576)])]) 03/27/2025 02:29:37.944 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 538 03/27/2025 02:29:37.944 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.944 7f63eecacd68 [kafka.conn] [DEBUG]: Response 538 (600.8977890014648 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.973 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 519 03/27/2025 02:29:37.973 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.973 7f63eeb9db70 [kafka.conn] [DEBUG]: Response 519 (601.2239456176758 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=64, last_stable_offset=64, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:37.973 7f63ef553828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 12 03/27/2025 02:29:37.974 7f63ef553828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.974 7f63ef553828 [kafka.protocol.parser] [DEBUG]: 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=12, max_bytes=1048576)])]) 03/27/2025 02:29:37.974 7f63ef553828 [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-8', partitions=[(partition=0, offset=12, max_bytes=1048576)])]) 03/27/2025 02:29:37.974 7f63efac1f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 54 03/27/2025 02:29:37.974 7f63efac1f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.975 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: 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=54, max_bytes=1048576)])]) 03/27/2025 02:29:37.975 7f63efac1f60 [kafka.conn] [DEBUG]: Request 512: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=54, max_bytes=1048576)])]) 03/27/2025 02:29:37.978 7f63eecacac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 235 03/27/2025 02:29:37.978 7f63eecacac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:37.978 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: 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=235, max_bytes=1048576)])]) 03/27/2025 02:29:37.978 7f63eecacac8 [kafka.conn] [DEBUG]: Request 546: 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=235, max_bytes=1048576)])]) 03/27/2025 02:29:37.979 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:37.979 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:37.979 7f63efa6a6d8 [kafka.conn] [DEBUG]: Response 508 (600.8143424987793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=14, last_stable_offset=14, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.030 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 510 03/27/2025 02:29:38.030 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.031 7f63ef5532e8 [kafka.conn] [DEBUG]: Response 510 (602.5874614715576 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-4', 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])])]) 03/27/2025 02:29:38.032 7f63ef5532e8 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.035 7f63ef50ac18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 29 03/27/2025 02:29:38.035 7f63ef50ac18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.035 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 03/27/2025 02:29:38.036 7f63ef50ac18 [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-17', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 03/27/2025 02:29:38.046 7f63ef8da048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 115 03/27/2025 02:29:38.046 7f63ef8da048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.046 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: 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=115, max_bytes=1048576)])]) 03/27/2025 02:29:38.047 7f63ef8da048 [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-3', partitions=[(partition=0, offset=115, max_bytes=1048576)])]) 03/27/2025 02:29:38.110 7f63eeb9dac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 146 03/27/2025 02:29:38.110 7f63eeb9dac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.111 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: 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=146, max_bytes=1048576)])]) 03/27/2025 02:29:38.111 7f63eeb9dac8 [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=146, max_bytes=1048576)])]) 03/27/2025 02:29:38.143 7f63ef4ffcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0 03/27/2025 02:29:38.143 7f63ef4ffcc0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-2']) to node 1 03/27/2025 02:29:38.143 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-2']) 03/27/2025 02:29:38.144 7f63ef4ffcc0 [kafka.conn] [DEBUG]: Request 504: MetadataRequest_v1(topics=['-uve-topic-2']) 03/27/2025 02:29:38.186 7f63ef9a5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2384 03/27/2025 02:29:38.186 7f63ef9a5cc0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-0']) to node 1 03/27/2025 02:29:38.186 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-0']) 03/27/2025 02:29:38.187 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Request 759: MetadataRequest_v1(topics=['-uve-topic-0']) 03/27/2025 02:29:38.187 7f63efa6a780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 12 03/27/2025 02:29:38.187 7f63efa6a780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.187 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: 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=12, max_bytes=1048576)])]) 03/27/2025 02:29:38.187 7f63efa6a780 [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=12, max_bytes=1048576)])]) 03/27/2025 02:29:38.188 7f63eda2c048 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-5']) to node 1 03/27/2025 02:29:38.188 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-5']) 03/27/2025 02:29:38.188 7f63eda2c048 [kafka.conn] [DEBUG]: Request 509: MetadataRequest_v1(topics=['-uve-topic-5']) 03/27/2025 02:29:38.189 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:38.189 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.189 7f63eda2c048 [kafka.conn] [DEBUG]: Response 508 (601.3600826263428 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.189 7f63ef5364e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 16 03/27/2025 02:29:38.189 7f63ef5364e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.189 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: 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=16, max_bytes=1048576)])]) 03/27/2025 02:29:38.190 7f63ef5364e0 [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=16, max_bytes=1048576)])]) 03/27/2025 02:29:38.190 7f63ef536828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 56 03/27/2025 02:29:38.190 7f63ef536828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.190 7f63ef536828 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 03/27/2025 02:29:38.190 7f63ef536828 [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-12', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 03/27/2025 02:29:38.253 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 541 03/27/2025 02:29:38.253 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.253 7f63eda24d68 [kafka.conn] [DEBUG]: Response 541 (601.4840602874756 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=238, last_stable_offset=238, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.312 7f63eecac828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 124 03/27/2025 02:29:38.313 7f63eecac828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.313 7f63eecac828 [kafka.protocol.parser] [DEBUG]: 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=124, max_bytes=1048576)])]) 03/27/2025 02:29:38.313 7f63eecac828 [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-23', partitions=[(partition=0, offset=124, max_bytes=1048576)])]) 03/27/2025 02:29:38.339 7f63ef50acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 58 03/27/2025 02:29:38.339 7f63ef50acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.339 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: 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=58, max_bytes=1048576)])]) 03/27/2025 02:29:38.340 7f63ef50acc0 [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-18', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 03/27/2025 02:29:38.356 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/27/2025 02:29:38.357 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.357 7f63eeb11f60 [kafka.conn] [DEBUG]: Response 504 (601.8521785736084 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', 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])])]) 03/27/2025 02:29:38.358 7f63eeb11f60 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.358 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:29:38.358 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.358 7f63ef562d68 [kafka.conn] [DEBUG]: Response 511 (602.4854183197021 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=34, last_stable_offset=34, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.451 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:29:38.451 7f63ef553198 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.451 7f63ef553198 [kafka.conn] [DEBUG]: Response 513 (601.9797325134277 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-7', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/27/2025 02:29:38.452 7f63ef553198 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.452 7f63ef536ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 36 03/27/2025 02:29:38.452 7f63ef536ac8 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-14']) to node 1 03/27/2025 02:29:38.452 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-14']) 03/27/2025 02:29:38.453 7f63ef536ac8 [kafka.conn] [DEBUG]: Request 513: MetadataRequest_v1(topics=['-uve-topic-14']) 03/27/2025 02:29:38.453 7f63eeb9dd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 189 03/27/2025 02:29:38.453 7f63eeb9dd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.453 7f63eeb9dd68 [kafka.protocol.parser] [DEBUG]: 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=189, max_bytes=1048576)])]) 03/27/2025 02:29:38.453 7f63eeb9dd68 [kafka.conn] [DEBUG]: Request 542: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=189, max_bytes=1048576)])]) 03/27/2025 02:29:38.453 7f63eeca00f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 100 03/27/2025 02:29:38.453 7f63eeca00f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.453 7f63eeca00f0 [kafka.protocol.parser] [DEBUG]: 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=100, max_bytes=1048576)])]) 03/27/2025 02:29:38.454 7f63eeca00f0 [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-20', partitions=[(partition=0, offset=100, max_bytes=1048576)])]) 03/27/2025 02:29:38.454 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 513 03/27/2025 02:29:38.454 7f63ef536ac8 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.454 7f63ef536ac8 [kafka.conn] [DEBUG]: Response 513 (2.0139217376708984 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-14', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/27/2025 02:29:38.455 7f63ef536ac8 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.456 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 03/27/2025 02:29:38.456 7f63ef553c18 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.456 7f63ef553c18 [kafka.conn] [DEBUG]: Response 516 (602.0340919494629 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-6', 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])])]) 03/27/2025 02:29:38.457 7f63ef553c18 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.457 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 530 03/27/2025 02:29:38.457 7f63eecac6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.457 7f63eecac6d8 [kafka.conn] [DEBUG]: Response 530 (602.1478176116943 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=134, last_stable_offset=134, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.510 7f63ef5620f0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-16']) to node 1 03/27/2025 02:29:38.510 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-16']) 03/27/2025 02:29:38.511 7f63ef5620f0 [kafka.conn] [DEBUG]: Request 515: MetadataRequest_v1(topics=['-uve-topic-16']) 03/27/2025 02:29:38.511 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 514 03/27/2025 02:29:38.511 7f63ef5620f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.511 7f63ef5620f0 [kafka.conn] [DEBUG]: Response 514 (602.2417545318604 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=31, last_stable_offset=31, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.512 7f63efa6a8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 03/27/2025 02:29:38.512 7f63efa6a8d0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-9']) to node 1 03/27/2025 02:29:38.512 7f63efa6a8d0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-9']) 03/27/2025 02:29:38.512 7f63efa6a8d0 [kafka.conn] [DEBUG]: Request 504: MetadataRequest_v1(topics=['-uve-topic-9']) 03/27/2025 02:29:38.543 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 549 03/27/2025 02:29:38.543 7f63eeba9048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.544 7f63eeba9048 [kafka.conn] [DEBUG]: Response 549 (601.3498306274414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=198, last_stable_offset=198, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.544 7f63eecacd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 150 03/27/2025 02:29:38.545 7f63eecacd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.545 7f63eecacd68 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 03/27/2025 02:29:38.545 7f63eecacd68 [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=150, max_bytes=1048576)])]) 03/27/2025 02:29:38.574 7f63eeb9db70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 64 03/27/2025 02:29:38.574 7f63eeb9db70 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-27']) to node 1 03/27/2025 02:29:38.574 7f63eeb9db70 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-27']) 03/27/2025 02:29:38.574 7f63eeb9db70 [kafka.conn] [DEBUG]: Request 520: MetadataRequest_v1(topics=['-uve-topic-27']) 03/27/2025 02:29:38.574 7f63ef553828 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-8']) to node 1 03/27/2025 02:29:38.575 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-8']) 03/27/2025 02:29:38.575 7f63ef553828 [kafka.conn] [DEBUG]: Request 510: MetadataRequest_v1(topics=['-uve-topic-8']) 03/27/2025 02:29:38.575 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:38.575 7f63ef553828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.575 7f63ef553828 [kafka.conn] [DEBUG]: Response 509 (601.4435291290283 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.576 7f63efac1f60 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-19']) to node 1 03/27/2025 02:29:38.576 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-19']) 03/27/2025 02:29:38.576 7f63efac1f60 [kafka.conn] [DEBUG]: Request 513: MetadataRequest_v1(topics=['-uve-topic-19']) 03/27/2025 02:29:38.576 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 512 03/27/2025 02:29:38.576 7f63efac1f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.576 7f63efac1f60 [kafka.conn] [DEBUG]: Response 512 (601.5701293945312 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.579 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 546 03/27/2025 02:29:38.579 7f63eecacac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.579 7f63eecacac8 [kafka.conn] [DEBUG]: Response 546 (600.7771492004395 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=235, last_stable_offset=235, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.579 7f63efa6a6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 14 03/27/2025 02:29:38.579 7f63efa6a6d8 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-11']) to node 1 03/27/2025 02:29:38.579 7f63efa6a6d8 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-11']) 03/27/2025 02:29:38.580 7f63efa6a6d8 [kafka.conn] [DEBUG]: Request 509: MetadataRequest_v1(topics=['-uve-topic-11']) 03/27/2025 02:29:38.635 7f63ef5532e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 03/27/2025 02:29:38.635 7f63ef5532e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.635 7f63ef5532e8 [kafka.protocol.parser] [DEBUG]: 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=16, max_bytes=1048576)])]) 03/27/2025 02:29:38.635 7f63ef5532e8 [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=16, max_bytes=1048576)])]) 03/27/2025 02:29:38.636 7f63ef50ac18 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-17']) to node 1 03/27/2025 02:29:38.636 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-17']) 03/27/2025 02:29:38.637 7f63ef50ac18 [kafka.conn] [DEBUG]: Request 512: MetadataRequest_v1(topics=['-uve-topic-17']) 03/27/2025 02:29:38.637 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 511 03/27/2025 02:29:38.637 7f63ef50ac18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.637 7f63ef50ac18 [kafka.conn] [DEBUG]: Response 511 (601.5825271606445 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.647 7f63ef8da048 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-3']) to node 1 03/27/2025 02:29:38.647 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-3']) 03/27/2025 02:29:38.648 7f63ef8da048 [kafka.conn] [DEBUG]: Request 528: MetadataRequest_v1(topics=['-uve-topic-3']) 03/27/2025 02:29:38.648 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 527 03/27/2025 02:29:38.648 7f63ef8da048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.648 7f63ef8da048 [kafka.conn] [DEBUG]: Response 527 (601.4301776885986 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=115, last_stable_offset=115, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.712 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 537 03/27/2025 02:29:38.712 7f63eeb9dac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.712 7f63eeb9dac8 [kafka.conn] [DEBUG]: Response 537 (601.4752388000488 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=146, last_stable_offset=146, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.744 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 504 03/27/2025 02:29:38.745 7f63ef4ffcc0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.745 7f63ef4ffcc0 [kafka.conn] [DEBUG]: Response 504 (601.4683246612549 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', 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])])]) 03/27/2025 02:29:38.746 7f63ef4ffcc0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.787 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 759 03/27/2025 02:29:38.788 7f63ef9a5cc0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.788 7f63ef9a5cc0 [kafka.conn] [DEBUG]: Response 759 (601.4881134033203 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', 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])])]) 03/27/2025 02:29:38.789 7f63ef9a5cc0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.789 7f63efa6a780 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-10']) to node 1 03/27/2025 02:29:38.789 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-10']) 03/27/2025 02:29:38.789 7f63efa6a780 [kafka.conn] [DEBUG]: Request 510: MetadataRequest_v1(topics=['-uve-topic-10']) 03/27/2025 02:29:38.790 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:38.790 7f63efa6a780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.790 7f63efa6a780 [kafka.conn] [DEBUG]: Response 509 (602.3895740509033 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=12, last_stable_offset=12, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.790 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:38.790 7f63eda2c048 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.791 7f63eda2c048 [kafka.conn] [DEBUG]: Response 509 (602.5848388671875 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-5', 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=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/27/2025 02:29:38.792 7f63eda2c048 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.792 7f63ef5364e0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-13']) to node 1 03/27/2025 02:29:38.792 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-13']) 03/27/2025 02:29:38.792 7f63ef5364e0 [kafka.conn] [DEBUG]: Request 509: MetadataRequest_v1(topics=['-uve-topic-13']) 03/27/2025 02:29:38.792 7f63ef536828 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-12']) to node 1 03/27/2025 02:29:38.792 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-12']) 03/27/2025 02:29:38.793 7f63ef536828 [kafka.conn] [DEBUG]: Request 516: MetadataRequest_v1(topics=['-uve-topic-12']) 03/27/2025 02:29:38.793 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 03/27/2025 02:29:38.793 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.793 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509 03/27/2025 02:29:38.793 7f63ef5364e0 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.793 7f63ef5364e0 [kafka.conn] [DEBUG]: Response 508 (603.96409034729 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=16, last_stable_offset=16, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.794 7f63ef5364e0 [kafka.conn] [DEBUG]: Response 509 (1.4500617980957031 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-13', 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])])]) 03/27/2025 02:29:38.794 7f63ef5364e0 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.795 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 515 03/27/2025 02:29:38.795 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.795 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 516 03/27/2025 02:29:38.795 7f63ef536828 [kafka.protocol.parser] [DEBUG]: Processing response MetadataResponse_v1 03/27/2025 02:29:38.795 7f63ef536828 [kafka.conn] [DEBUG]: Response 515 (605.2424907684326 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.795 7f63ef536828 [kafka.conn] [DEBUG]: Response 516 (2.9337406158447266 ms): MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.27', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-12', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])]) 03/27/2025 02:29:38.796 7f63ef536828 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0) 03/27/2025 02:29:38.854 7f63eda24d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 238 03/27/2025 02:29:38.854 7f63eda24d68 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-29']) to node 1 03/27/2025 02:29:38.854 7f63eda24d68 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-29']) 03/27/2025 02:29:38.854 7f63eda24d68 [kafka.conn] [DEBUG]: Request 542: MetadataRequest_v1(topics=['-uve-topic-29']) 03/27/2025 02:29:38.914 7f63eecac828 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-23']) to node 1 03/27/2025 02:29:38.914 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-23']) 03/27/2025 02:29:38.915 7f63eecac828 [kafka.conn] [DEBUG]: Request 532: MetadataRequest_v1(topics=['-uve-topic-23']) 03/27/2025 02:29:38.915 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 531 03/27/2025 02:29:38.915 7f63eecac828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.915 7f63eecac828 [kafka.conn] [DEBUG]: Response 531 (601.9487380981445 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.940 7f63ef50acc0 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-18']) to node 1 03/27/2025 02:29:38.940 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-18']) 03/27/2025 02:29:38.941 7f63ef50acc0 [kafka.conn] [DEBUG]: Request 522: MetadataRequest_v1(topics=['-uve-topic-18']) 03/27/2025 02:29:38.941 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 521 03/27/2025 02:29:38.941 7f63ef50acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 03/27/2025 02:29:38.941 7f63ef50acc0 [kafka.conn] [DEBUG]: Response 521 (601.5753746032715 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 03/27/2025 02:29:38.958 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/27/2025 02:29:38.958 7f63eeb11f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/27/2025 02:29:38.958 7f63eeb11f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:38.958 7f63eeb11f60 [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-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 03/27/2025 02:29:38.959 7f63ef562d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34 03/27/2025 02:29:38.959 7f63ef562d68 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-15']) to node 1 03/27/2025 02:29:38.959 7f63ef562d68 [kafka.protocol.parser] [DEBUG]: Sending request MetadataRequest_v1(topics=['-uve-topic-15']) 03/27/2025 02:29:38.959 7f63ef562d68 [kafka.conn] [DEBUG]: Request 512: MetadataRequest_v1(topics=['-uve-topic-15'])