02/17/2025 02:28:52.967 7fa1b2382348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 17
02/17/2025 02:28:52.967 7fa1b2382348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:52.967 7fa1b2382348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=17, max_bytes=1048576)])])
02/17/2025 02:28:52.968 7fa1b2345948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 47
02/17/2025 02:28:52.968 7fa1b2345948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:52.968 7fa1b2345948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=47, max_bytes=1048576)])])
02/17/2025 02:28:52.968 7fa1b2345a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 493: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
02/17/2025 02:28:53.034 7fa1b2382648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/17/2025 02:28:53.034 7fa1b2382648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.034 7fa1b2382648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 493: 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/17/2025 02:28:53.035 7fa1b2345748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
02/17/2025 02:28:53.035 7fa1b2382748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
02/17/2025 02:28:53.036 7fa1b2382748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.036 7fa1b2382748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 493: 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/17/2025 02:28:53.036 7fa1b2382448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 9
02/17/2025 02:28:53.036 7fa1b2382448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.036 7fa1b2382448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 496: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=9, max_bytes=1048576)])])
02/17/2025 02:28:53.048 7fa1b2345548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 272
02/17/2025 02:28:53.048 7fa1b2345548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.049 7fa1b2345548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 541: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=272, max_bytes=1048576)])])
02/17/2025 02:28:53.106 7fa1b2382248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
02/17/2025 02:28:53.107 7fa1b2382848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 523: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=126, message_set=[])])])
02/17/2025 02:28:53.133 7fa1b2345b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 64
02/17/2025 02:28:53.133 7fa1b2345b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.133 7fa1b2345b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=64, max_bytes=1048576)])])
02/17/2025 02:28:53.163 7fa1b2382a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=102, message_set=[])])])
02/17/2025 02:28:53.164 7fa1b2382548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=31, message_set=[])])])
02/17/2025 02:28:53.206 7fa1b2382948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 660: 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=245)', '(offset=None, message=None)'])])])
02/17/2025 02:28:53.206 7fa1b2382948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 490 to buffered record list
02/17/2025 02:28:53.211 7fa1b2382c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=['(offset=80, message=242)', '(offset=81, message=242)', '(offset=None, message=None)'])])])
02/17/2025 02:28:53.211 7fa1b2382c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 80 to buffered record list
02/17/2025 02:28:53.242 7fa1b2382048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
02/17/2025 02:28:53.248 7fa1b249f748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=150, message_set=['(offset=149, message=217)', '(offset=None, message=None)'])])])
02/17/2025 02:28:53.249 7fa1b249f748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 149 to buffered record list
02/17/2025 02:28:53.273 7fa1b2345348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 282
02/17/2025 02:28:53.273 7fa1b2345348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.274 7fa1b2345348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 542: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=282, max_bytes=1048576)])])
02/17/2025 02:28:53.274 7fa1b2345348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 542: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=284, message_set=['(offset=282, message=212)', '(offset=283, message=212)', '(offset=None, message=None)'])])])
02/17/2025 02:28:53.275 7fa1b2345348 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 282 to buffered record list
02/17/2025 02:28:53.296 7fa1b249f348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 253
02/17/2025 02:28:53.296 7fa1b249f348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.297 7fa1b249f348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 538: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=253, max_bytes=1048576)])])
02/17/2025 02:28:53.306 7fa1b2382948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 491
02/17/2025 02:28:53.307 7fa1b2382948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.307 7fa1b2382948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=491, max_bytes=1048576)])])
02/17/2025 02:28:53.312 7fa1b2382c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 82
02/17/2025 02:28:53.312 7fa1b2382c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.312 7fa1b2382c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 508: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
02/17/2025 02:28:53.331 7fa1b2345148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=34, message_set=[])])])
02/17/2025 02:28:53.333 7fa1b2345448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 529: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=171, message_set=['(offset=170, message=231)', '(offset=None, message=None)'])])])
02/17/2025 02:28:53.333 7fa1b2345448 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-21', partition=0) with offset 170 to buffered record list
02/17/2025 02:28:53.346 7fa1b2359048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 11
02/17/2025 02:28:53.346 7fa1b2359048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.346 7fa1b2359048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=11, max_bytes=1048576)])])
02/17/2025 02:28:53.347 7fa1b2382b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 128
02/17/2025 02:28:53.347 7fa1b2382b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.347 7fa1b2382b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 516: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=128, max_bytes=1048576)])])
02/17/2025 02:28:53.348 7fa1b2382148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 494: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
02/17/2025 02:28:53.350 7fa1b249f748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 150
02/17/2025 02:28:53.350 7fa1b249f748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.350 7fa1b249f748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=150, max_bytes=1048576)])])
02/17/2025 02:28:53.375 7fa1b2345348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 284
02/17/2025 02:28:53.375 7fa1b2345348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.376 7fa1b2345348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 543: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=284, max_bytes=1048576)])])
02/17/2025 02:28:53.434 7fa1b2345448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 171
02/17/2025 02:28:53.434 7fa1b2345448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.434 7fa1b2345448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 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=171, max_bytes=1048576)])])
02/17/2025 02:28:53.450 7fa1b2345848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 71
02/17/2025 02:28:53.450 7fa1b2345848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.451 7fa1b2345848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 507: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=71, max_bytes=1048576)])])
02/17/2025 02:28:53.451 7fa1b2345e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
02/17/2025 02:28:53.543 7fa1b2345c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 496: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
02/17/2025 02:28:53.549 7fa1b2345648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 33
02/17/2025 02:28:53.550 7fa1b2345648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.550 7fa1b2345648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
02/17/2025 02:28:53.550 7fa1b2345d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 67
02/17/2025 02:28:53.550 7fa1b2345d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.550 7fa1b2345d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 512: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=67, max_bytes=1048576)])])
02/17/2025 02:28:53.551 7fa1b2382d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 112
02/17/2025 02:28:53.551 7fa1b2382d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.551 7fa1b2382d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=112, max_bytes=1048576)])])
02/17/2025 02:28:53.569 7fa1b2382348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=17, message_set=[])])])
02/17/2025 02:28:53.569 7fa1b2345a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0
02/17/2025 02:28:53.570 7fa1b2345a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/17/2025 02:28:53.570 7fa1b2345a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Request 494: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
02/17/2025 02:28:53.570 7fa1b2345948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.49/10.0.0.49 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=47, message_set=[])])])