03/27/2025 02:41:39.057 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.058 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=25, max_bytes=1048576)])])
03/27/2025 02:41:39.058 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:39.113 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 118
03/27/2025 02:41:39.113 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.113 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=118, max_bytes=1048576)])])
03/27/2025 02:41:39.157 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:39.158 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:39.162 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168
03/27/2025 02:41:39.162 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.162 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 526: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=168, max_bytes=1048576)])])
03/27/2025 02:41:39.211 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 663: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=498, message_set=['(offset=497, message=212)', '(offset=None, message=None)'])])])
03/27/2025 02:41:39.212 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 497 to buffered record list
03/27/2025 02:41:39.222 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 19
03/27/2025 02:41:39.222 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.222 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=19, max_bytes=1048576)])])
03/27/2025 02:41:39.292 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=11, message_set=[])])])
03/27/2025 02:41:39.293 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=46, message_set=[])])])
03/27/2025 02:41:39.293 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 31
03/27/2025 02:41:39.293 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.293 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:39.294 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
03/27/2025 02:41:39.312 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 498
03/27/2025 02:41:39.312 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.313 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 664: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=498, max_bytes=1048576)])])
03/27/2025 02:41:39.322 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 524: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:39.323 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=32, message_set=[])])])
03/27/2025 02:41:39.405 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 384
03/27/2025 02:41:39.406 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.406 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 561: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=384, max_bytes=1048576)])])
03/27/2025 02:41:39.410 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:39.450 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
03/27/2025 02:41:39.508 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 515: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=78, message_set=[])])])
03/27/2025 02:41:39.509 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 516: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=77, message_set=[])])])
03/27/2025 02:41:39.509 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129
03/27/2025 02:41:39.509 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.510 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 527: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=129, max_bytes=1048576)])])
03/27/2025 02:41:39.512 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=17, message_set=[])])])
03/27/2025 02:41:39.525 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=22, message_set=[])])])
03/27/2025 02:41:39.526 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:39.538 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247
03/27/2025 02:41:39.539 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.539 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 538: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=247, max_bytes=1048576)])])
03/27/2025 02:41:39.608 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 535: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
03/27/2025 02:41:39.612 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 81
03/27/2025 02:41:39.612 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.613 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=81, max_bytes=1048576)])])
03/27/2025 02:41:39.619 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 38
03/27/2025 02:41:39.619 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.619 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
03/27/2025 02:41:39.632 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
03/27/2025 02:41:39.632 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.633 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:39.633 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
03/27/2025 02:41:39.633 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.633 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:39.635 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, message_set=[])])])
03/27/2025 02:41:39.659 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=25, message_set=[])])])
03/27/2025 02:41:39.659 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 12
03/27/2025 02:41:39.659 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.659 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:39.714 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 520: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=118, message_set=[])])])
03/27/2025 02:41:39.758 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 12
03/27/2025 02:41:39.758 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.758 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:39.759 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 130
03/27/2025 02:41:39.759 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.759 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:39.763 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 526: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, message_set=[])])])
03/27/2025 02:41:39.823 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
03/27/2025 02:41:39.893 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 11
03/27/2025 02:41:39.893 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.893 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=11, max_bytes=1048576)])])
03/27/2025 02:41:39.894 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 46
03/27/2025 02:41:39.894 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.894 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=46, max_bytes=1048576)])])
03/27/2025 02:41:39.894 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 45
03/27/2025 02:41:39.894 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.895 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
03/27/2025 02:41:39.895 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:39.914 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 664: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=498, message_set=[])])])
03/27/2025 02:41:39.923 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 130
03/27/2025 02:41:39.923 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.923 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 525: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:39.923 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 32
03/27/2025 02:41:39.924 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:39.924 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=32, max_bytes=1048576)])])
03/27/2025 02:41:40.007 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 561: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=384, message_set=[])])])
03/27/2025 02:41:40.010 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
03/27/2025 02:41:40.011 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.011 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:40.051 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 8
03/27/2025 02:41:40.051 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.051 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
03/27/2025 02:41:40.109 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78
03/27/2025 02:41:40.109 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.110 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 516: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=78, max_bytes=1048576)])])
03/27/2025 02:41:40.110 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 77
03/27/2025 02:41:40.110 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.110 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 517: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=77, max_bytes=1048576)])])
03/27/2025 02:41:40.111 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=129, message_set=[])])])
03/27/2025 02:41:40.113 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
03/27/2025 02:41:40.113 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.113 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=17, max_bytes=1048576)])])
03/27/2025 02:41:40.126 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 22
03/27/2025 02:41:40.126 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.126 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=22, max_bytes=1048576)])])
03/27/2025 02:41:40.126 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31
03/27/2025 02:41:40.127 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.127 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:40.140 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 538: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=247, message_set=[])])])
03/27/2025 02:41:40.209 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
03/27/2025 02:41:40.209 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.209 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 536: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
03/27/2025 02:41:40.213 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=81, message_set=[])])])
03/27/2025 02:41:40.220 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
03/27/2025 02:41:40.234 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:40.234 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:40.235 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10
03/27/2025 02:41:40.235 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.235 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
03/27/2025 02:41:40.259 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 25
03/27/2025 02:41:40.259 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.260 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=25, max_bytes=1048576)])])
03/27/2025 02:41:40.260 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:40.315 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 118
03/27/2025 02:41:40.315 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.315 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 521: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=118, max_bytes=1048576)])])
03/27/2025 02:41:40.360 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:40.361 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:40.364 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168
03/27/2025 02:41:40.364 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.365 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 527: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=168, max_bytes=1048576)])])
03/27/2025 02:41:40.424 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 19
03/27/2025 02:41:40.424 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.425 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=19, max_bytes=1048576)])])
03/27/2025 02:41:40.495 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=11, message_set=[])])])
03/27/2025 02:41:40.496 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=46, message_set=[])])])
03/27/2025 02:41:40.496 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 31
03/27/2025 02:41:40.496 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.496 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:40.497 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
03/27/2025 02:41:40.514 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 498
03/27/2025 02:41:40.514 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.515 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 665: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=498, max_bytes=1048576)])])
03/27/2025 02:41:40.525 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 525: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:40.526 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=32, message_set=[])])])
03/27/2025 02:41:40.608 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 384
03/27/2025 02:41:40.608 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.608 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 562: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=384, max_bytes=1048576)])])
03/27/2025 02:41:40.612 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:40.652 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
03/27/2025 02:41:40.711 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 516: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=78, message_set=[])])])
03/27/2025 02:41:40.711 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129
03/27/2025 02:41:40.712 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.712 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=129, max_bytes=1048576)])])
03/27/2025 02:41:40.712 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 517: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=77, message_set=[])])])
03/27/2025 02:41:40.714 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=17, message_set=[])])])
03/27/2025 02:41:40.727 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=22, message_set=[])])])
03/27/2025 02:41:40.728 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:40.740 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247
03/27/2025 02:41:40.741 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.741 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 539: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=247, max_bytes=1048576)])])
03/27/2025 02:41:40.810 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 536: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
03/27/2025 02:41:40.814 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 81
03/27/2025 02:41:40.814 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.814 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=81, max_bytes=1048576)])])
03/27/2025 02:41:40.821 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 38
03/27/2025 02:41:40.821 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.821 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
03/27/2025 02:41:40.834 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
03/27/2025 02:41:40.835 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.835 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:40.835 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
03/27/2025 02:41:40.835 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.836 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:40.836 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, message_set=[])])])
03/27/2025 02:41:40.861 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=25, message_set=[])])])
03/27/2025 02:41:40.862 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 12
03/27/2025 02:41:40.862 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.862 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:40.916 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 521: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=118, message_set=[])])])
03/27/2025 02:41:40.960 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 12
03/27/2025 02:41:40.960 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.961 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:40.961 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 130
03/27/2025 02:41:40.961 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:40.961 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:40.965 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, message_set=[])])])
03/27/2025 02:41:41.026 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
03/27/2025 02:41:41.096 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 11
03/27/2025 02:41:41.096 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.096 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=11, max_bytes=1048576)])])
03/27/2025 02:41:41.097 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 46
03/27/2025 02:41:41.097 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.097 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=46, max_bytes=1048576)])])
03/27/2025 02:41:41.097 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 45
03/27/2025 02:41:41.097 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.098 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
03/27/2025 02:41:41.098 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:41.115 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 665: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=498, message_set=[])])])
03/27/2025 02:41:41.125 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 130
03/27/2025 02:41:41.126 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.126 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 526: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:41.126 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 32
03/27/2025 02:41:41.126 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.126 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=32, max_bytes=1048576)])])
03/27/2025 02:41:41.209 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 562: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=384, message_set=[])])])
03/27/2025 02:41:41.213 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
03/27/2025 02:41:41.213 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.213 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:41.253 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 8
03/27/2025 02:41:41.253 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.253 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
03/27/2025 02:41:41.311 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78
03/27/2025 02:41:41.312 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.312 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 517: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=78, max_bytes=1048576)])])
03/27/2025 02:41:41.313 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 77
03/27/2025 02:41:41.313 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.313 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=77, max_bytes=1048576)])])
03/27/2025 02:41:41.314 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=129, message_set=[])])])
03/27/2025 02:41:41.315 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
03/27/2025 02:41:41.315 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.315 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=17, max_bytes=1048576)])])
03/27/2025 02:41:41.328 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 22
03/27/2025 02:41:41.328 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.329 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=22, max_bytes=1048576)])])
03/27/2025 02:41:41.329 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31
03/27/2025 02:41:41.329 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.330 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:41.342 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 539: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=247, message_set=[])])])
03/27/2025 02:41:41.411 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
03/27/2025 02:41:41.411 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.411 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 537: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
03/27/2025 02:41:41.415 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 519: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=81, message_set=[])])])
03/27/2025 02:41:41.422 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
03/27/2025 02:41:41.436 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:41.437 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10
03/27/2025 02:41:41.437 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.437 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
03/27/2025 02:41:41.437 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:41.462 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 25
03/27/2025 02:41:41.462 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.462 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=25, max_bytes=1048576)])])
03/27/2025 02:41:41.463 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:41.517 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 118
03/27/2025 02:41:41.517 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.517 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 522: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=118, max_bytes=1048576)])])
03/27/2025 02:41:41.562 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:41.563 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:41.568 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168
03/27/2025 02:41:41.568 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.568 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=168, max_bytes=1048576)])])
03/27/2025 02:41:41.627 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 19
03/27/2025 02:41:41.627 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.627 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=19, max_bytes=1048576)])])
03/27/2025 02:41:41.698 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=11, message_set=[])])])
03/27/2025 02:41:41.699 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=46, message_set=[])])])
03/27/2025 02:41:41.699 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 31
03/27/2025 02:41:41.699 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.699 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:41.700 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
03/27/2025 02:41:41.716 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 498
03/27/2025 02:41:41.716 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.716 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 666: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=498, max_bytes=1048576)])])
03/27/2025 02:41:41.727 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 526: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:41.728 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=32, message_set=[])])])
03/27/2025 02:41:41.810 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 384
03/27/2025 02:41:41.810 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.810 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 563: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=384, max_bytes=1048576)])])
03/27/2025 02:41:41.814 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:41.854 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
03/27/2025 02:41:41.913 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 517: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=78, message_set=[])])])
03/27/2025 02:41:41.914 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=77, message_set=[])])])
03/27/2025 02:41:41.914 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129
03/27/2025 02:41:41.914 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.915 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=129, max_bytes=1048576)])])
03/27/2025 02:41:41.916 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=17, message_set=[])])])
03/27/2025 02:41:41.930 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=22, message_set=[])])])
03/27/2025 02:41:41.931 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:41.943 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247
03/27/2025 02:41:41.943 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:41.943 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 540: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=247, max_bytes=1048576)])])
03/27/2025 02:41:42.012 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 537: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
03/27/2025 02:41:42.016 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 81
03/27/2025 02:41:42.016 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.016 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=81, max_bytes=1048576)])])
03/27/2025 02:41:42.022 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 38
03/27/2025 02:41:42.022 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.023 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
03/27/2025 02:41:42.037 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
03/27/2025 02:41:42.037 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.037 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:42.038 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
03/27/2025 02:41:42.038 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.038 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:42.039 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, message_set=[])])])
03/27/2025 02:41:42.063 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=25, message_set=[])])])
03/27/2025 02:41:42.064 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 12
03/27/2025 02:41:42.064 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.065 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:42.118 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 522: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=118, message_set=[])])])
03/27/2025 02:41:42.163 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 12
03/27/2025 02:41:42.163 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.163 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:42.164 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 130
03/27/2025 02:41:42.164 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.164 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:42.169 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, message_set=[])])])
03/27/2025 02:41:42.229 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
03/27/2025 02:41:42.299 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 11
03/27/2025 02:41:42.299 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.299 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=11, max_bytes=1048576)])])
03/27/2025 02:41:42.299 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 46
03/27/2025 02:41:42.299 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.300 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=46, max_bytes=1048576)])])
03/27/2025 02:41:42.300 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 45
03/27/2025 02:41:42.300 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.300 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
03/27/2025 02:41:42.301 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:42.317 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 666: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=499, message_set=['(offset=498, message=224)', '(offset=None, message=None)'])])])
03/27/2025 02:41:42.318 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 498 to buffered record list
03/27/2025 02:41:42.328 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 130
03/27/2025 02:41:42.328 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.328 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 527: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:42.328 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 32
03/27/2025 02:41:42.329 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.329 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=32, max_bytes=1048576)])])
03/27/2025 02:41:42.411 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 563: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=384, message_set=[])])])
03/27/2025 02:41:42.415 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
03/27/2025 02:41:42.415 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.416 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:42.418 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 499
03/27/2025 02:41:42.418 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.419 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 667: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=499, max_bytes=1048576)])])
03/27/2025 02:41:42.455 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 8
03/27/2025 02:41:42.455 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.455 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
03/27/2025 02:41:42.514 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78
03/27/2025 02:41:42.514 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.514 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=78, max_bytes=1048576)])])
03/27/2025 02:41:42.515 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 77
03/27/2025 02:41:42.515 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.515 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=77, max_bytes=1048576)])])
03/27/2025 02:41:42.516 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=129, message_set=[])])])
03/27/2025 02:41:42.517 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
03/27/2025 02:41:42.517 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.517 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=17, max_bytes=1048576)])])
03/27/2025 02:41:42.531 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 22
03/27/2025 02:41:42.531 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.531 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=22, max_bytes=1048576)])])
03/27/2025 02:41:42.532 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31
03/27/2025 02:41:42.532 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.532 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:42.544 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 540: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=247, message_set=[])])])
03/27/2025 02:41:42.613 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
03/27/2025 02:41:42.613 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.613 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 538: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
03/27/2025 02:41:42.617 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 520: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=81, message_set=[])])])
03/27/2025 02:41:42.623 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
03/27/2025 02:41:42.639 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:42.640 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10
03/27/2025 02:41:42.640 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.640 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
03/27/2025 02:41:42.641 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:42.664 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 25
03/27/2025 02:41:42.665 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.665 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=25, max_bytes=1048576)])])
03/27/2025 02:41:42.665 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:42.719 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 118
03/27/2025 02:41:42.719 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.719 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 523: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=118, max_bytes=1048576)])])
03/27/2025 02:41:42.765 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:42.765 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:42.770 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168
03/27/2025 02:41:42.770 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.770 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=168, max_bytes=1048576)])])
03/27/2025 02:41:42.829 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 19
03/27/2025 02:41:42.829 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.830 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=19, max_bytes=1048576)])])
03/27/2025 02:41:42.900 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=11, message_set=[])])])
03/27/2025 02:41:42.901 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=46, message_set=[])])])
03/27/2025 02:41:42.901 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
03/27/2025 02:41:42.902 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 31
03/27/2025 02:41:42.902 7f3a2e53ce48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:42.902 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:42.930 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:42.930 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=32, message_set=[])])])
03/27/2025 02:41:43.012 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 384
03/27/2025 02:41:43.012 7f3a2c2e2548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.012 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 564: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=384, max_bytes=1048576)])])
03/27/2025 02:41:43.016 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:43.019 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 667: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=499, message_set=[])])])
03/27/2025 02:41:43.056 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
03/27/2025 02:41:43.116 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=78, message_set=[])])])
03/27/2025 02:41:43.116 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129
03/27/2025 02:41:43.117 7f3a2e53c948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.117 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=129, max_bytes=1048576)])])
03/27/2025 02:41:43.117 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 519: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=77, message_set=[])])])
03/27/2025 02:41:43.118 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=17, message_set=[])])])
03/27/2025 02:41:43.133 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=22, message_set=[])])])
03/27/2025 02:41:43.134 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:43.145 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247
03/27/2025 02:41:43.145 7f3a2c2e2a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.145 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 541: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=247, max_bytes=1048576)])])
03/27/2025 02:41:43.214 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 538: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
03/27/2025 02:41:43.218 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 81
03/27/2025 02:41:43.218 7f3a2c2e2348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.218 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 521: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=81, max_bytes=1048576)])])
03/27/2025 02:41:43.224 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 38
03/27/2025 02:41:43.224 7f3a2c2e2b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.224 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
03/27/2025 02:41:43.240 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
03/27/2025 02:41:43.240 7f3a2e53c148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.240 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:43.241 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
03/27/2025 02:41:43.241 7f3a2e53cd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.241 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:43.242 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, message_set=[])])])
03/27/2025 02:41:43.266 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=25, message_set=[])])])
03/27/2025 02:41:43.266 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 12
03/27/2025 02:41:43.267 7f3a2c2e2448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.267 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:43.320 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 523: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=118, message_set=[])])])
03/27/2025 02:41:43.365 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 12
03/27/2025 02:41:43.365 7f3a2e53c748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.366 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
03/27/2025 02:41:43.366 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 130
03/27/2025 02:41:43.366 7f3a2e930348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.366 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 531: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:43.371 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, message_set=[])])])
03/27/2025 02:41:43.431 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
03/27/2025 02:41:43.501 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 11
03/27/2025 02:41:43.501 7f3a2e53c648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.501 7f3a2e53c648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=11, max_bytes=1048576)])])
03/27/2025 02:41:43.502 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 46
03/27/2025 02:41:43.502 7f3a2c2e2648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.502 7f3a2c2e2648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=46, max_bytes=1048576)])])
03/27/2025 02:41:43.502 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 45
03/27/2025 02:41:43.502 7f3a2e53ca48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.503 7f3a2e53ca48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
03/27/2025 02:41:43.503 7f3a2e53ce48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
03/27/2025 02:41:43.530 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 130
03/27/2025 02:41:43.531 7f3a2e930748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.531 7f3a2e930748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=130, max_bytes=1048576)])])
03/27/2025 02:41:43.531 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 32
03/27/2025 02:41:43.532 7f3a2e533048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.532 7f3a2e533048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=32, max_bytes=1048576)])])
03/27/2025 02:41:43.613 7f3a2c2e2548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 564: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=384, message_set=[])])])
03/27/2025 02:41:43.618 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
03/27/2025 02:41:43.618 7f3a2e53c848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.618 7f3a2e53c848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
03/27/2025 02:41:43.620 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 499
03/27/2025 02:41:43.620 7f3a2e53c348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.620 7f3a2e53c348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 668: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=499, max_bytes=1048576)])])
03/27/2025 02:41:43.657 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 8
03/27/2025 02:41:43.657 7f3a2e53c448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.658 7f3a2e53c448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
03/27/2025 02:41:43.716 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 78
03/27/2025 02:41:43.717 7f3a2c2e2948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.717 7f3a2c2e2948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=78, max_bytes=1048576)])])
03/27/2025 02:41:43.717 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 77
03/27/2025 02:41:43.718 7f3a2c2e2d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.718 7f3a2c2e2d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=77, max_bytes=1048576)])])
03/27/2025 02:41:43.718 7f3a2e53c948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=129, message_set=[])])])
03/27/2025 02:41:43.719 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 17
03/27/2025 02:41:43.719 7f3a2e53c548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.719 7f3a2e53c548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=17, max_bytes=1048576)])])
03/27/2025 02:41:43.734 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 22
03/27/2025 02:41:43.734 7f3a2c2e2148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.734 7f3a2c2e2148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=22, max_bytes=1048576)])])
03/27/2025 02:41:43.735 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 31
03/27/2025 02:41:43.735 7f3a2c2e2048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.735 7f3a2c2e2048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
03/27/2025 02:41:43.746 7f3a2c2e2a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 541: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=247, message_set=[])])])
03/27/2025 02:41:43.815 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
03/27/2025 02:41:43.815 7f3a2c2e2c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.816 7f3a2c2e2c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 539: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
03/27/2025 02:41:43.819 7f3a2c2e2348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 521: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=81, message_set=[])])])
03/27/2025 02:41:43.825 7f3a2c2e2b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
03/27/2025 02:41:43.841 7f3a2e53c148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:43.842 7f3a2e53cd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
03/27/2025 02:41:43.842 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10
03/27/2025 02:41:43.842 7f3a2e53cb48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.843 7f3a2e53cb48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
03/27/2025 02:41:43.867 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 25
03/27/2025 02:41:43.867 7f3a2e53cc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.867 7f3a2e53cc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=25, max_bytes=1048576)])])
03/27/2025 02:41:43.868 7f3a2c2e2448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:43.921 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 118
03/27/2025 02:41:43.921 7f3a2c2e2748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.921 7f3a2c2e2748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 524: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=118, max_bytes=1048576)])])
03/27/2025 02:41:43.967 7f3a2e53c748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
03/27/2025 02:41:43.968 7f3a2e930348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
03/27/2025 02:41:43.971 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168
03/27/2025 02:41:43.971 7f3a2c2e2848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:43.972 7f3a2c2e2848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=168, max_bytes=1048576)])])
03/27/2025 02:41:44.032 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 19
03/27/2025 02:41:44.032 7f3a2c2e2248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/27/2025 02:41:44.033 7f3a2c2e2248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.43/10.0.0.43 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=19, max_bytes=1048576)])])