02/06/2025 02:26:44.014 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:44.034 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:44.034 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.035 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:44.035 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:44.036 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.036 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:44.056 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:44.056 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.057 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 527: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])])
02/06/2025 02:26:44.069 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:44.070 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.070 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
02/06/2025 02:26:44.071 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:44.071 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.071 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 526: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:44.071 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:44.071 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.071 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:44.072 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:44.072 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.072 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 496: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=6, max_bytes=1048576)])])
02/06/2025 02:26:44.105 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:44.105 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.105 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=16, max_bytes=1048576)])])
02/06/2025 02:26:44.106 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:44.106 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.106 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=15, max_bytes=1048576)])])
02/06/2025 02:26:44.106 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:44.106 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.107 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=40, max_bytes=1048576)])])
02/06/2025 02:26:44.125 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:44.125 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.125 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
02/06/2025 02:26:44.141 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:44.211 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 493: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:44.212 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:44.213 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 493: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:44.213 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 493: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:44.214 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 494: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:44.315 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 524: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:44.316 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 659: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=488, message_set=['(offset=487, message=224)', '(offset=None, message=None)'])])])
02/06/2025 02:26:44.316 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 487 to buffered record list
02/06/2025 02:26:44.328 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 494: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:44.329 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:44.339 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:44.390 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:44.395 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:44.403 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:44.403 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.403 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:44.417 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 488
02/06/2025 02:26:44.417 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.418 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 660: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=488, max_bytes=1048576)])])
02/06/2025 02:26:44.501 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:44.502 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.502 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:44.536 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:44.602 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:44.614 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:44.614 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.614 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 521: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:44.614 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:44.615 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.615 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=60, max_bytes=1048576)])])
02/06/2025 02:26:44.635 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:44.636 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:44.657 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:44.670 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:44.672 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 526: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:44.673 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 535: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:44.673 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:44.706 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:44.707 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:44.708 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:44.726 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:44.742 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:44.742 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.743 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:44.812 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:44.812 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.812 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 494: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:44.813 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:44.813 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.813 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:44.813 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:44.813 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.814 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 494: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:44.814 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:44.814 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.814 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 494: 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)])])
02/06/2025 02:26:44.814 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:44.814 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.815 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 495: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:44.916 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:44.916 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.916 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 525: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:44.929 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:44.929 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.929 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 495: 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)])])
02/06/2025 02:26:44.930 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:44.930 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.931 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:44.939 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:44.939 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.940 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:44.990 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:44.990 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.991 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
02/06/2025 02:26:44.995 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:44.995 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:44.995 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=54, max_bytes=1048576)])])
02/06/2025 02:26:45.004 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:45.018 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 660: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=489, message_set=['(offset=488, message=219)', '(offset=None, message=None)'])])])
02/06/2025 02:26:45.018 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 488 to buffered record list
02/06/2025 02:26:45.102 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:45.119 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 489
02/06/2025 02:26:45.119 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.119 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 661: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=489, max_bytes=1048576)])])
02/06/2025 02:26:45.136 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:45.136 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.136 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:45.202 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:45.202 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.202 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:45.215 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 521: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:45.215 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:45.236 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:45.236 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.236 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:45.237 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:45.237 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.238 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:45.258 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:45.258 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.258 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=135, max_bytes=1048576)])])
02/06/2025 02:26:45.271 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:45.271 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.272 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
02/06/2025 02:26:45.273 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:45.273 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.274 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 527: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:45.274 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:45.274 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.274 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 536: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:45.274 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:45.275 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.275 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=6, max_bytes=1048576)])])
02/06/2025 02:26:45.306 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:45.306 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.306 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=16, max_bytes=1048576)])])
02/06/2025 02:26:45.307 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:45.307 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.308 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=15, max_bytes=1048576)])])
02/06/2025 02:26:45.308 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:45.308 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.308 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:45.326 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:45.326 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.326 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
02/06/2025 02:26:45.343 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:45.413 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 494: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:45.414 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:45.415 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 494: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:45.415 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 494: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:45.416 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 495: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:45.517 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 525: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:45.530 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 495: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:45.531 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:45.540 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:45.591 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:45.596 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:45.605 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:45.605 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.605 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 533: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:45.703 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:45.703 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.703 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:45.720 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 661: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=490, message_set=['(offset=489, message=224)', '(offset=None, message=None)'])])])
02/06/2025 02:26:45.720 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 489 to buffered record list
02/06/2025 02:26:45.737 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:45.803 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:45.815 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:45.815 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.815 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 522: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:45.816 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:45.816 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.816 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=60, max_bytes=1048576)])])
02/06/2025 02:26:45.821 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 490
02/06/2025 02:26:45.821 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.821 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 662: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=490, max_bytes=1048576)])])
02/06/2025 02:26:45.837 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:45.838 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:45.859 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:45.872 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:45.875 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:45.875 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 536: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:45.876 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:45.907 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:45.909 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:45.909 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:45.927 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:45.944 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:45.944 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:45.944 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:46.013 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:46.013 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.014 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 495: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:46.014 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:46.014 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.014 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:46.015 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:46.015 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.015 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 495: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:46.015 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:46.016 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.016 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 495: 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)])])
02/06/2025 02:26:46.016 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:46.016 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.016 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 496: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:46.118 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:46.118 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.118 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 526: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:46.130 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:46.131 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.131 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 496: 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)])])
02/06/2025 02:26:46.131 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:46.131 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.132 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:46.140 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:46.141 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.141 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:46.192 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:46.192 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.192 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
02/06/2025 02:26:46.196 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:46.196 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.196 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:46.206 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:46.304 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:46.337 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:46.338 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.338 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:46.403 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:46.404 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.404 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:46.417 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 522: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:46.417 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:46.422 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 662: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=491, message_set=['(offset=490, message=228)', '(offset=None, message=None)'])])])
02/06/2025 02:26:46.422 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 490 to buffered record list
02/06/2025 02:26:46.438 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:46.438 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.438 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:46.439 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:46.439 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.439 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:46.459 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:46.459 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.460 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=135, max_bytes=1048576)])])
02/06/2025 02:26:46.475 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:46.475 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.475 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
02/06/2025 02:26:46.475 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:46.475 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.476 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:46.476 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:46.476 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.476 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 537: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:46.476 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:46.477 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.477 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=6, max_bytes=1048576)])])
02/06/2025 02:26:46.507 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:46.508 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.508 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=16, max_bytes=1048576)])])
02/06/2025 02:26:46.509 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:46.509 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.509 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=15, max_bytes=1048576)])])
02/06/2025 02:26:46.510 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:46.510 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.510 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:46.522 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 491
02/06/2025 02:26:46.522 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.523 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 663: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=491, max_bytes=1048576)])])
02/06/2025 02:26:46.527 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:46.527 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.528 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
02/06/2025 02:26:46.545 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:46.615 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 495: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:46.615 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:46.616 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 495: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:46.617 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 495: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:46.617 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:46.718 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 526: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:46.731 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:46.732 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:46.741 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:46.793 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:46.797 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:46.807 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:46.807 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.808 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 534: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:46.904 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:46.905 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:46.905 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:46.939 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:47.004 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:47.017 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:47.017 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.017 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 523: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:47.018 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:47.018 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.018 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=60, max_bytes=1048576)])])
02/06/2025 02:26:47.040 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:47.040 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:47.060 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:47.076 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:47.077 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:47.077 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 537: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:47.078 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:47.108 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:47.110 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:47.111 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:47.123 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 663: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=492, message_set=['(offset=491, message=238)', '(offset=None, message=None)'])])])
02/06/2025 02:26:47.123 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 491 to buffered record list
02/06/2025 02:26:47.128 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:47.146 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:47.146 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.146 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:47.216 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:47.216 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.216 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 496: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:47.217 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:47.217 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.217 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:47.217 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:47.217 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.217 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 496: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:47.218 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:47.218 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.218 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 496: 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)])])
02/06/2025 02:26:47.218 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:47.218 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.219 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:47.224 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 492
02/06/2025 02:26:47.226 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.226 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=492, max_bytes=1048576)])])
02/06/2025 02:26:47.319 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:47.319 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.319 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 527: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:47.332 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:47.332 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.332 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 497: 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)])])
02/06/2025 02:26:47.332 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:47.333 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.333 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:47.342 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:47.342 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.342 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 531: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:47.393 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:47.393 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.393 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
02/06/2025 02:26:47.397 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:47.397 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.398 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:47.408 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 534: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:47.506 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:47.590 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:47.590 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.591 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:47.605 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:47.605 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.605 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:47.618 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 523: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:47.619 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:47.641 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:47.642 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.642 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:47.642 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:47.642 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.642 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 531: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:47.661 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:47.662 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.662 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=135, max_bytes=1048576)])])
02/06/2025 02:26:47.677 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:47.677 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.677 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
02/06/2025 02:26:47.678 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:47.678 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.678 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:47.678 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:47.678 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.678 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 538: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:47.679 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:47.679 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.679 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=6, max_bytes=1048576)])])
02/06/2025 02:26:47.709 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:47.709 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.709 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=16, max_bytes=1048576)])])
02/06/2025 02:26:47.711 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:47.711 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.711 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=15, max_bytes=1048576)])])
02/06/2025 02:26:47.712 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:47.712 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.712 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:47.729 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:47.729 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:47.730 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
02/06/2025 02:26:47.748 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 515: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:47.819 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:47.819 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:47.820 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:47.820 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:47.820 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:47.826 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 664: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=492, message_set=[])])])
02/06/2025 02:26:47.920 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:47.932 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:47.933 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:47.942 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:47.997 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:47.998 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:48.009 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:48.009 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.010 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:48.106 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:48.106 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.106 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:48.191 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 515: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:48.206 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 515: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:48.219 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:48.219 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.219 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 524: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:48.219 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:48.220 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.220 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:48.243 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:48.243 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:48.262 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:48.277 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:48.279 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:48.279 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 538: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:48.280 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:48.310 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:48.312 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:48.313 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:48.330 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:48.349 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:48.349 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.349 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 516: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:48.419 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:48.420 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.420 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:48.420 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:48.420 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.421 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:48.421 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:48.421 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.421 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:48.421 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:48.421 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.422 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:48.422 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:48.422 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.422 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:48.428 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 492
02/06/2025 02:26:48.428 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.428 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=492, max_bytes=1048576)])])
02/06/2025 02:26:48.521 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:48.521 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.522 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 528: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:48.533 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:48.533 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.534 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:48.534 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:48.534 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.535 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:48.543 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:48.544 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.544 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:48.598 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:48.598 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.598 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
02/06/2025 02:26:48.599 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:48.599 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.599 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:48.610 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 535: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:48.707 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:48.792 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:48.792 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.792 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 516: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:48.806 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:48.806 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.806 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 516: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:48.820 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 524: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:48.821 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:48.843 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:48.844 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.844 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:48.845 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:48.845 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.845 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:48.863 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:48.864 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.864 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=135, max_bytes=1048576)])])
02/06/2025 02:26:48.879 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:48.879 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.879 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
02/06/2025 02:26:48.880 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:48.880 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.880 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:48.880 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:48.880 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.881 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 539: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:48.881 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:48.881 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.881 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=6, max_bytes=1048576)])])
02/06/2025 02:26:48.911 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:48.911 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.911 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=16, max_bytes=1048576)])])
02/06/2025 02:26:48.913 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:48.913 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.913 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=15, max_bytes=1048576)])])
02/06/2025 02:26:48.914 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:48.914 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.914 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:48.930 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:48.931 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:48.931 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
02/06/2025 02:26:48.950 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 516: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:49.021 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:49.023 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:49.023 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:49.024 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:49.024 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:49.030 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 665: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=493, message_set=['(offset=492, message=212)', '(offset=None, message=None)'])])])
02/06/2025 02:26:49.030 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 492 to buffered record list
02/06/2025 02:26:49.122 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:49.131 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 493
02/06/2025 02:26:49.131 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.131 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=493, max_bytes=1048576)])])
02/06/2025 02:26:49.134 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:49.135 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:49.144 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:49.199 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:49.199 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:49.211 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:49.211 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.211 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 536: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:49.308 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:49.308 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.308 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:49.393 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 516: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:49.407 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 516: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:49.421 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:49.421 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.421 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 525: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:49.422 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:49.422 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.422 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:49.446 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:49.446 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:49.464 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:49.479 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:49.481 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:49.481 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 539: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:49.482 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:49.512 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:49.514 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:49.515 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:49.531 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:49.550 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:49.550 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.550 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 517: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:49.622 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:49.622 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.622 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:49.623 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:49.623 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.623 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:49.624 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:49.624 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.624 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:49.624 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:49.624 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.624 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:49.625 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:49.625 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.625 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:49.723 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:49.723 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.723 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 529: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:49.732 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 666: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=494, message_set=['(offset=493, message=224)', '(offset=None, message=None)'])])])
02/06/2025 02:26:49.732 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 493 to buffered record list
02/06/2025 02:26:49.734 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:49.735 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.735 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:49.735 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:49.736 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.736 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:49.745 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:49.745 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.745 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 533: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:49.799 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:49.799 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.799 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=14, max_bytes=1048576)])])
02/06/2025 02:26:49.800 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:49.800 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.800 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:49.812 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 536: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:49.833 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 494
02/06/2025 02:26:49.833 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:49.833 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=494, max_bytes=1048576)])])
02/06/2025 02:26:49.909 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:50.006 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:50.006 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.006 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 517: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:50.007 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:50.008 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.008 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 517: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:50.022 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 525: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:50.023 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:50.046 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:50.046 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.046 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:50.047 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:50.047 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.047 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 533: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:50.065 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:50.065 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.065 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])])
02/06/2025 02:26:50.080 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:50.080 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.080 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=8, max_bytes=1048576)])])
02/06/2025 02:26:50.081 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:50.081 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.082 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 531: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:50.082 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:50.082 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.082 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 540: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:50.082 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:50.082 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.083 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=6, max_bytes=1048576)])])
02/06/2025 02:26:50.112 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:50.113 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.113 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=16, max_bytes=1048576)])])
02/06/2025 02:26:50.115 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:50.115 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.115 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 506: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=15, max_bytes=1048576)])])
02/06/2025 02:26:50.115 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:50.115 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.116 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:50.132 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:50.132 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.132 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=33, max_bytes=1048576)])])
02/06/2025 02:26:50.151 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 517: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:50.223 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:50.224 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:50.225 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:50.225 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:50.226 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:50.324 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:50.335 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:50.336 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:50.345 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:50.400 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:50.401 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:50.412 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:50.413 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.413 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 537: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:50.434 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 667: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=495, message_set=['(offset=494, message=224)', '(offset=None, message=None)'])])])
02/06/2025 02:26:50.434 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 494 to buffered record list
02/06/2025 02:26:50.509 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:50.510 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.510 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:50.535 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 495
02/06/2025 02:26:50.536 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.536 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=495, max_bytes=1048576)])])
02/06/2025 02:26:50.607 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 517: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:50.608 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 517: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:50.623 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:50.623 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.623 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 526: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:50.624 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:50.624 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.624 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 510: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:50.648 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:50.648 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:50.666 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:50.681 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:50.683 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:50.684 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 540: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:50.684 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:50.713 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:50.716 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:50.717 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:50.733 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:50.752 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:50.752 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.753 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:50.823 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:50.824 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.824 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:50.824 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:50.824 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.825 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:50.826 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:50.826 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.826 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:50.827 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:50.827 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.827 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:50.827 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:50.827 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.827 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:50.925 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:50.925 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.925 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 530: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:50.936 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:50.936 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.936 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:50.937 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:50.937 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.937 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:50.946 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:50.946 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:50.947 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 534: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:51.001 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:51.001 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.002 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=14, max_bytes=1048576)])])
02/06/2025 02:26:51.002 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:51.002 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.002 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:51.014 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 537: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:51.111 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 515: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:51.137 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 668: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=495, message_set=[])])])
02/06/2025 02:26:51.208 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:51.208 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.208 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:51.209 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:51.209 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.209 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:51.225 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 526: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:51.225 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:51.250 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:51.250 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.250 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:51.251 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:51.251 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.251 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 534: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:51.267 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:51.268 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.268 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 533: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])])
02/06/2025 02:26:51.282 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:51.282 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.282 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=8, max_bytes=1048576)])])
02/06/2025 02:26:51.284 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:51.284 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.284 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:51.285 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:51.285 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.285 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 541: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:51.286 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:51.286 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.286 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=6, max_bytes=1048576)])])
02/06/2025 02:26:51.314 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:51.314 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.314 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=16, max_bytes=1048576)])])
02/06/2025 02:26:51.317 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:51.317 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.318 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=15, max_bytes=1048576)])])
02/06/2025 02:26:51.318 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:51.318 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.318 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:51.334 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:51.334 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.334 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=33, max_bytes=1048576)])])
02/06/2025 02:26:51.354 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:51.425 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:51.426 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:51.428 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:51.428 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:51.429 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:51.526 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 530: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:51.537 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:51.538 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:51.547 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 534: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:51.603 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:51.603 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:51.615 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:51.615 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.615 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 538: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:51.711 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:51.712 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.712 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 516: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:51.738 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 495
02/06/2025 02:26:51.738 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.738 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 669: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=495, max_bytes=1048576)])])
02/06/2025 02:26:51.809 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:51.810 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:51.825 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:51.825 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.826 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=128, max_bytes=1048576)])])
02/06/2025 02:26:51.826 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:51.826 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.826 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 511: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:51.852 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:51.852 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 534: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:51.868 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:51.882 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:51.884 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:51.886 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 541: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:51.887 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:51.915 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:51.919 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:51.919 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:51.935 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:51.956 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:51.956 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:51.956 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:52.025 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:52.026 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.026 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:52.026 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:52.026 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.027 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=27, max_bytes=1048576)])])
02/06/2025 02:26:52.028 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:52.028 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.029 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:52.029 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:52.029 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.029 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:52.029 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:52.029 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.030 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:52.127 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:52.127 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.127 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 531: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:52.138 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:52.138 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.138 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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)])])
02/06/2025 02:26:52.139 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:52.139 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.139 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:52.148 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:52.148 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.148 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:52.204 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:52.204 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.205 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=14, max_bytes=1048576)])])
02/06/2025 02:26:52.205 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:52.205 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.205 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:52.216 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 538: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:52.313 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 516: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:52.339 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 669: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=496, message_set=['(offset=495, message=224)', '(offset=None, message=None)'])])])
02/06/2025 02:26:52.339 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 495 to buffered record list
02/06/2025 02:26:52.410 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:52.410 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.410 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:52.410 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:52.411 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.411 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=115, max_bytes=1048576)])])
02/06/2025 02:26:52.427 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 527: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:52.427 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 511: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:52.440 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 496
02/06/2025 02:26:52.440 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.440 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 670: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=496, max_bytes=1048576)])])
02/06/2025 02:26:52.453 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:52.453 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.453 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:52.457 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:52.457 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.457 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:52.484 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:52.484 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.484 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 534: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])])
02/06/2025 02:26:52.484 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:52.484 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.484 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=8, max_bytes=1048576)])])
02/06/2025 02:26:52.486 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:52.486 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.487 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 533: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:52.487 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:52.487 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.487 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 542: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:52.488 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:52.488 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.488 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=6, max_bytes=1048576)])])
02/06/2025 02:26:52.516 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:52.516 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.516 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=16, max_bytes=1048576)])])
02/06/2025 02:26:52.519 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:52.519 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.519 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=15, max_bytes=1048576)])])
02/06/2025 02:26:52.524 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:52.524 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.524 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:52.535 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:52.535 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.536 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=33, max_bytes=1048576)])])
02/06/2025 02:26:52.557 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 519: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:52.627 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:52.628 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:52.630 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:52.632 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=[])])])
02/06/2025 02:26:52.633 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:52.728 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:52.739 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:52.740 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:52.749 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 535: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:52.806 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
02/06/2025 02:26:52.806 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=54, message_set=[])])])
02/06/2025 02:26:52.817 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 249
02/06/2025 02:26:52.817 7fce72072848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.817 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 539: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=249, max_bytes=1048576)])])
02/06/2025 02:26:52.913 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 60
02/06/2025 02:26:52.914 7fce72072c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:52.914 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 517: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:53.011 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 519: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
02/06/2025 02:26:53.012 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 519: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=115, message_set=[])])])
02/06/2025 02:26:53.027 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 128
02/06/2025 02:26:53.027 7fce724cae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.028 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=128, max_bytes=1048576)])])
02/06/2025 02:26:53.028 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 60
02/06/2025 02:26:53.028 7fce72072648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.028 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=60, max_bytes=1048576)])])
02/06/2025 02:26:53.041 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 670: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=496, message_set=[])])])
02/06/2025 02:26:53.054 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/06/2025 02:26:53.058 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 535: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=207, message_set=[])])])
02/06/2025 02:26:53.085 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 534: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, message_set=[])])])
02/06/2025 02:26:53.085 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/06/2025 02:26:53.088 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=[])])])
02/06/2025 02:26:53.088 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 542: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
02/06/2025 02:26:53.089 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=6, message_set=[])])])
02/06/2025 02:26:53.116 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
02/06/2025 02:26:53.120 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 508: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
02/06/2025 02:26:53.125 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
02/06/2025 02:26:53.136 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 510: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
02/06/2025 02:26:53.158 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 67
02/06/2025 02:26:53.158 7fce72372248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.158 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/06/2025 02:26:53.228 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
02/06/2025 02:26:53.228 7fce72372348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.228 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:53.228 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 27
02/06/2025 02:26:53.229 7fce72072348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.229 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=27, max_bytes=1048576)])])
02/06/2025 02:26:53.233 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
02/06/2025 02:26:53.233 7fce72372448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.234 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:53.234 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/06/2025 02:26:53.234 7fce72372948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.234 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 501: 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)])])
02/06/2025 02:26:53.234 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
02/06/2025 02:26:53.234 7fce72072548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.235 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/06/2025 02:26:53.329 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 149
02/06/2025 02:26:53.329 7fce72372b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.329 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=149, max_bytes=1048576)])])
02/06/2025 02:26:53.340 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/06/2025 02:26:53.340 7fce72372848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.340 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 502: 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)])])
02/06/2025 02:26:53.341 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 44
02/06/2025 02:26:53.341 7fce72372d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.341 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
02/06/2025 02:26:53.350 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 128
02/06/2025 02:26:53.350 7fce724ca348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.350 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 536: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/06/2025 02:26:53.407 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 14
02/06/2025 02:26:53.408 7fce72372c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.408 7fce72372c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=14, max_bytes=1048576)])])
02/06/2025 02:26:53.408 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 54
02/06/2025 02:26:53.408 7fce72072448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.408 7fce72072448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=54, max_bytes=1048576)])])
02/06/2025 02:26:53.418 7fce72072848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 539: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
02/06/2025 02:26:53.515 7fce72072c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 517: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:53.612 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 138
02/06/2025 02:26:53.612 7fce72072a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.613 7fce72072a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
02/06/2025 02:26:53.613 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 115
02/06/2025 02:26:53.613 7fce72072748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.613 7fce72072748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=115, max_bytes=1048576)])])
02/06/2025 02:26:53.629 7fce724cae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 528: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])
02/06/2025 02:26:53.630 7fce72072648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 512: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=60, message_set=[])])])
02/06/2025 02:26:53.643 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 496
02/06/2025 02:26:53.643 7fce72372148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.643 7fce72372148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 671: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=496, max_bytes=1048576)])])
02/06/2025 02:26:53.655 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 31
02/06/2025 02:26:53.655 7fce72072248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.655 7fce72072248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=31, max_bytes=1048576)])])
02/06/2025 02:26:53.658 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 207
02/06/2025 02:26:53.659 7fce72072b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.659 7fce72072b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 536: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=207, max_bytes=1048576)])])
02/06/2025 02:26:53.686 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135
02/06/2025 02:26:53.686 7fce724ca748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.686 7fce724ca748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])])
02/06/2025 02:26:53.687 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 8
02/06/2025 02:26:53.687 7fce72372648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.687 7fce72372648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=8, max_bytes=1048576)])])
02/06/2025 02:26:53.689 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 195
02/06/2025 02:26:53.689 7fce72072d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.689 7fce72072d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 534: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
02/06/2025 02:26:53.689 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 199
02/06/2025 02:26:53.689 7fce72072948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.690 7fce72072948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 543: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
02/06/2025 02:26:53.690 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 6
02/06/2025 02:26:53.690 7fce72372548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.690 7fce72372548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=6, max_bytes=1048576)])])
02/06/2025 02:26:53.717 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16
02/06/2025 02:26:53.717 7fce72072148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.717 7fce72072148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=16, max_bytes=1048576)])])
02/06/2025 02:26:53.720 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
02/06/2025 02:26:53.720 7fce72372748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.721 7fce72372748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 509: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=15, max_bytes=1048576)])])
02/06/2025 02:26:53.725 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 40
02/06/2025 02:26:53.726 7fce72072048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.726 7fce72072048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
02/06/2025 02:26:53.737 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 33
02/06/2025 02:26:53.737 7fce72372e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/06/2025 02:26:53.737 7fce72372e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 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=33, max_bytes=1048576)])])
02/06/2025 02:26:53.760 7fce72372248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 520: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=67, message_set=[])])])
02/06/2025 02:26:53.829 7fce72372348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:53.830 7fce72072348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 509: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=27, message_set=[])])])
02/06/2025 02:26:53.835 7fce72372448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:53.836 7fce72372948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:53.836 7fce72072548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:53.930 7fce72372b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=149, message_set=[])])])
02/06/2025 02:26:53.941 7fce72372848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/06/2025 02:26:53.942 7fce72372d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
02/06/2025 02:26:53.951 7fce724ca348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.46/10.0.0.46 port=9092> Response 536: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=128, message_set=[])])])