11/07/2024 02:39:13.958 7fef7020db48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=140, max_bytes=1048576)])])
11/07/2024 02:39:13.960 7fef72633c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 12
11/07/2024 02:39:13.961 7fef72633c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:13.961 7fef72633c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
11/07/2024 02:39:13.965 7fef72633948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10
11/07/2024 02:39:13.965 7fef72633948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:13.965 7fef72633948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
11/07/2024 02:39:13.965 7fef72786e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 13
11/07/2024 02:39:13.965 7fef72786e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:13.966 7fef72786e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=13, max_bytes=1048576)])])
11/07/2024 02:39:13.985 7fef72633a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=[])])])
11/07/2024 02:39:14.020 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 472
11/07/2024 02:39:14.020 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.021 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 658: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=472, max_bytes=1048576)])])
11/07/2024 02:39:14.049 7fef72633d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=34, message_set=[])])])
11/07/2024 02:39:14.050 7fef72633848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=35, message_set=[])])])
11/07/2024 02:39:14.050 7fef7020d248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13
11/07/2024 02:39:14.050 7fef7020d248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.050 7fef7020d248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 497: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
11/07/2024 02:39:14.055 7fef7020d648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 199
11/07/2024 02:39:14.055 7fef7020d648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.055 7fef7020d648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 532: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
11/07/2024 02:39:14.085 7fef72786748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 101
11/07/2024 02:39:14.086 7fef72786748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.086 7fef72786748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 513: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=101, max_bytes=1048576)])])
11/07/2024 02:39:14.217 7fef7020d948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 521: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=145, message_set=[])])])
11/07/2024 02:39:14.217 7fef7020d448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45
11/07/2024 02:39:14.217 7fef7020d448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.218 7fef7020d448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 502: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
11/07/2024 02:39:14.218 7fef72633e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 28
11/07/2024 02:39:14.218 7fef72633e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.219 7fef72633e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=28, max_bytes=1048576)])])
11/07/2024 02:39:14.219 7fef7020d748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 138
11/07/2024 02:39:14.219 7fef7020d748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.220 7fef7020d748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 518: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
11/07/2024 02:39:14.221 7fef72633648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 492: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
11/07/2024 02:39:14.221 7fef72633348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
11/07/2024 02:39:14.243 7fef7020d348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48
11/07/2024 02:39:14.243 7fef7020d348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.244 7fef7020d348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=48, max_bytes=1048576)])])
11/07/2024 02:39:14.246 7fef7020dc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 534: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=165, message_set=[])])])
11/07/2024 02:39:14.314 7fef72633148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 16
11/07/2024 02:39:14.314 7fef72633148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.314 7fef72633148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=16, max_bytes=1048576)])])
11/07/2024 02:39:14.315 7fef7020d548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=26, message_set=[])])])
11/07/2024 02:39:14.315 7fef7020d048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 33
11/07/2024 02:39:14.315 7fef7020d048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.316 7fef7020d048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 505: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=33, max_bytes=1048576)])])
11/07/2024 02:39:14.316 7fef72633448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 492: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
11/07/2024 02:39:14.357 7fef72633b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 492: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
11/07/2024 02:39:14.358 7fef7020da48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121
11/07/2024 02:39:14.359 7fef7020da48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.359 7fef7020da48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=121, max_bytes=1048576)])])
11/07/2024 02:39:14.385 7fef7020d148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
11/07/2024 02:39:14.449 7fef7020dd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 174
11/07/2024 02:39:14.449 7fef7020dd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.450 7fef7020dd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=174, max_bytes=1048576)])])
11/07/2024 02:39:14.450 7fef7020d848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 249
11/07/2024 02:39:14.450 7fef7020d848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.450 7fef7020d848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=249, max_bytes=1048576)])])
11/07/2024 02:39:14.459 7fef72633548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 521: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
11/07/2024 02:39:14.559 7fef72786348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 148
11/07/2024 02:39:14.559 7fef72786348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.559 7fef72786348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 524: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=148, max_bytes=1048576)])])
11/07/2024 02:39:14.560 7fef7020db48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 531: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=140, message_set=[])])])
11/07/2024 02:39:14.562 7fef72633c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
11/07/2024 02:39:14.566 7fef72633948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, message_set=[])])])
11/07/2024 02:39:14.567 7fef72786e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
11/07/2024 02:39:14.586 7fef72633a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 19
11/07/2024 02:39:14.586 7fef72633a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.587 7fef72633a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=19, max_bytes=1048576)])])
11/07/2024 02:39:14.622 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 658: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=473, message_set=['(offset=472, message=224)', '(offset=None, message=None)'])])])
11/07/2024 02:39:14.622 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 472 to buffered record list
11/07/2024 02:39:14.649 7fef72633d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34
11/07/2024 02:39:14.650 7fef72633d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.650 7fef72633d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=34, max_bytes=1048576)])])
11/07/2024 02:39:14.650 7fef72633848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 35
11/07/2024 02:39:14.650 7fef72633848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.650 7fef72633848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=35, max_bytes=1048576)])])
11/07/2024 02:39:14.651 7fef7020d248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
11/07/2024 02:39:14.656 7fef7020d648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
11/07/2024 02:39:14.687 7fef72786748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 513: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=101, message_set=[])])])
11/07/2024 02:39:14.723 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 473
11/07/2024 02:39:14.723 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.723 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 659: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=473, max_bytes=1048576)])])
11/07/2024 02:39:14.817 7fef7020d948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 145
11/07/2024 02:39:14.818 7fef7020d948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.818 7fef7020d948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 522: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=145, max_bytes=1048576)])])
11/07/2024 02:39:14.821 7fef7020d448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
11/07/2024 02:39:14.821 7fef72633e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
11/07/2024 02:39:14.821 7fef72633648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
11/07/2024 02:39:14.822 7fef72633648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.822 7fef72633648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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)])])
11/07/2024 02:39:14.822 7fef72633348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
11/07/2024 02:39:14.822 7fef72633348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.822 7fef72633348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 499: 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)])])
11/07/2024 02:39:14.823 7fef7020d748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 518: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
11/07/2024 02:39:14.845 7fef7020d348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=48, message_set=[])])])
11/07/2024 02:39:14.846 7fef7020dc48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 165
11/07/2024 02:39:14.846 7fef7020dc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.847 7fef7020dc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=165, max_bytes=1048576)])])
11/07/2024 02:39:14.915 7fef72633148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 497: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
11/07/2024 02:39:14.916 7fef7020d548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 26
11/07/2024 02:39:14.916 7fef7020d548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.916 7fef7020d548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=26, max_bytes=1048576)])])
11/07/2024 02:39:14.917 7fef7020d048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 505: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
11/07/2024 02:39:14.917 7fef72633448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
11/07/2024 02:39:14.917 7fef72633448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.917 7fef72633448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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)])])
11/07/2024 02:39:14.957 7fef72633b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
11/07/2024 02:39:14.958 7fef72633b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.958 7fef72633b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 493: 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)])])
11/07/2024 02:39:14.960 7fef7020da48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 520: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=121, message_set=[])])])
11/07/2024 02:39:14.985 7fef7020d148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 82
11/07/2024 02:39:14.985 7fef7020d148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:14.986 7fef7020d148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
11/07/2024 02:39:15.051 7fef7020dd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=174, message_set=[])])])
11/07/2024 02:39:15.052 7fef7020d848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 536: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
11/07/2024 02:39:15.060 7fef72633548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 130
11/07/2024 02:39:15.060 7fef72633548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.061 7fef72633548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=130, max_bytes=1048576)])])
11/07/2024 02:39:15.160 7fef72786348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 524: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=148, message_set=[])])])
11/07/2024 02:39:15.161 7fef7020db48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 140
11/07/2024 02:39:15.161 7fef7020db48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.161 7fef7020db48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=140, max_bytes=1048576)])])
11/07/2024 02:39:15.163 7fef72633c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 12
11/07/2024 02:39:15.163 7fef72633c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.163 7fef72633c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
11/07/2024 02:39:15.167 7fef72633948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10
11/07/2024 02:39:15.167 7fef72633948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.167 7fef72633948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
11/07/2024 02:39:15.167 7fef72786e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 13
11/07/2024 02:39:15.167 7fef72786e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.168 7fef72786e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=13, max_bytes=1048576)])])
11/07/2024 02:39:15.188 7fef72633a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
11/07/2024 02:39:15.251 7fef72633d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=34, message_set=[])])])
11/07/2024 02:39:15.252 7fef7020d248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13
11/07/2024 02:39:15.252 7fef7020d248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.252 7fef7020d248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 498: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
11/07/2024 02:39:15.253 7fef72633848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=35, message_set=[])])])
11/07/2024 02:39:15.256 7fef7020d648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 199
11/07/2024 02:39:15.256 7fef7020d648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.257 7fef7020d648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 533: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
11/07/2024 02:39:15.288 7fef72786748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 101
11/07/2024 02:39:15.288 7fef72786748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.288 7fef72786748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 514: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=101, max_bytes=1048576)])])
11/07/2024 02:39:15.324 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 659: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=473, message_set=[])])])
11/07/2024 02:39:15.419 7fef7020d948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 522: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=145, message_set=[])])])
11/07/2024 02:39:15.421 7fef7020d448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45
11/07/2024 02:39:15.421 7fef7020d448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.421 7fef7020d448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 503: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
11/07/2024 02:39:15.422 7fef72633e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 28
11/07/2024 02:39:15.422 7fef72633e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.422 7fef72633e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=28, max_bytes=1048576)])])
11/07/2024 02:39:15.423 7fef72633648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=[])])])
11/07/2024 02:39:15.424 7fef7020d748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 138
11/07/2024 02:39:15.424 7fef7020d748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.424 7fef7020d748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 519: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
11/07/2024 02:39:15.424 7fef72633348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
11/07/2024 02:39:15.445 7fef7020d348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48
11/07/2024 02:39:15.445 7fef7020d348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.446 7fef7020d348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=48, max_bytes=1048576)])])
11/07/2024 02:39:15.447 7fef7020dc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 535: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=165, message_set=[])])])
11/07/2024 02:39:15.516 7fef72633148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 16
11/07/2024 02:39:15.516 7fef72633148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.516 7fef72633148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=16, max_bytes=1048576)])])
11/07/2024 02:39:15.517 7fef7020d548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=26, message_set=[])])])
11/07/2024 02:39:15.517 7fef7020d048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 33
11/07/2024 02:39:15.517 7fef7020d048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.518 7fef7020d048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=33, max_bytes=1048576)])])
11/07/2024 02:39:15.518 7fef72633448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 493: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
11/07/2024 02:39:15.560 7fef72633b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=[])])])
11/07/2024 02:39:15.561 7fef7020da48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121
11/07/2024 02:39:15.561 7fef7020da48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.561 7fef7020da48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 521: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=121, max_bytes=1048576)])])
11/07/2024 02:39:15.587 7fef7020d148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
11/07/2024 02:39:15.661 7fef7020dd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 174
11/07/2024 02:39:15.661 7fef7020dd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.662 7fef7020dd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=174, max_bytes=1048576)])])
11/07/2024 02:39:15.662 7fef7020d848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 249
11/07/2024 02:39:15.662 7fef7020d848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.662 7fef7020d848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=249, max_bytes=1048576)])])
11/07/2024 02:39:15.663 7fef72633548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 522: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])
11/07/2024 02:39:15.761 7fef72786348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 148
11/07/2024 02:39:15.761 7fef72786348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.761 7fef72786348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=148, max_bytes=1048576)])])
11/07/2024 02:39:15.762 7fef7020db48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 532: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=140, message_set=[])])])
11/07/2024 02:39:15.764 7fef72633c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=12, message_set=[])])])
11/07/2024 02:39:15.768 7fef72633948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=10, message_set=[])])])
11/07/2024 02:39:15.769 7fef72786e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 499: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
11/07/2024 02:39:15.788 7fef72633a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 19
11/07/2024 02:39:15.789 7fef72633a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.789 7fef72633a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=19, max_bytes=1048576)])])
11/07/2024 02:39:15.852 7fef72633d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34
11/07/2024 02:39:15.852 7fef72633d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.852 7fef72633d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 501: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=34, max_bytes=1048576)])])
11/07/2024 02:39:15.853 7fef72633848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 35
11/07/2024 02:39:15.853 7fef72633848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.853 7fef72633848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=35, max_bytes=1048576)])])
11/07/2024 02:39:15.854 7fef7020d248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
11/07/2024 02:39:15.857 7fef7020d648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 533: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=199, message_set=[])])])
11/07/2024 02:39:15.889 7fef72786748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 514: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=101, message_set=[])])])
11/07/2024 02:39:15.925 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 473
11/07/2024 02:39:15.925 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:15.925 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=473, max_bytes=1048576)])])
11/07/2024 02:39:15.926 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 660: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=476, message_set=['(offset=473, message=224)', '(offset=474, message=228)', '(offset=475, message=219)', '(offset=None, message=None)'])])])
11/07/2024 02:39:15.926 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 473 to buffered record list
11/07/2024 02:39:16.020 7fef7020d948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 145
11/07/2024 02:39:16.020 7fef7020d948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.020 7fef7020d948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 523: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=145, max_bytes=1048576)])])
11/07/2024 02:39:16.023 7fef7020d448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 503: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=45, message_set=[])])])
11/07/2024 02:39:16.024 7fef72633e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 502: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
11/07/2024 02:39:16.024 7fef72633648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
11/07/2024 02:39:16.024 7fef72633648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.024 7fef72633648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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)])])
11/07/2024 02:39:16.025 7fef72633348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 15
11/07/2024 02:39:16.025 7fef72633348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.025 7fef72633348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 500: 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)])])
11/07/2024 02:39:16.026 7fef7020d748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 519: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=138, message_set=[])])])
11/07/2024 02:39:16.027 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 476
11/07/2024 02:39:16.027 7fef72633748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.028 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=476, max_bytes=1048576)])])
11/07/2024 02:39:16.047 7fef7020d348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 507: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=48, message_set=[])])])
11/07/2024 02:39:16.048 7fef7020dc48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 165
11/07/2024 02:39:16.048 7fef7020dc48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.048 7fef7020dc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 536: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=165, max_bytes=1048576)])])
11/07/2024 02:39:16.117 7fef72633148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 498: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=16, message_set=[])])])
11/07/2024 02:39:16.118 7fef7020d548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 26
11/07/2024 02:39:16.118 7fef7020d548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.118 7fef7020d548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=26, max_bytes=1048576)])])
11/07/2024 02:39:16.119 7fef7020d048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 506: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=33, message_set=[])])])
11/07/2024 02:39:16.119 7fef72633448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
11/07/2024 02:39:16.119 7fef72633448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.120 7fef72633448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 494: 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)])])
11/07/2024 02:39:16.163 7fef72633b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
11/07/2024 02:39:16.163 7fef72633b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.163 7fef72633b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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)])])
11/07/2024 02:39:16.164 7fef7020da48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 521: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=121, message_set=[])])])
11/07/2024 02:39:16.187 7fef7020d148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 82
11/07/2024 02:39:16.188 7fef7020d148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.188 7fef7020d148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
11/07/2024 02:39:16.263 7fef7020dd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 534: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=174, message_set=[])])])
11/07/2024 02:39:16.264 7fef7020d848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 537: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=249, message_set=[])])])
11/07/2024 02:39:16.264 7fef72633548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 130
11/07/2024 02:39:16.265 7fef72633548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.265 7fef72633548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=130, max_bytes=1048576)])])
11/07/2024 02:39:16.362 7fef72786348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 525: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=148, message_set=[])])])
11/07/2024 02:39:16.363 7fef7020db48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 140
11/07/2024 02:39:16.363 7fef7020db48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.363 7fef7020db48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=140, max_bytes=1048576)])])
11/07/2024 02:39:16.364 7fef72633c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 12
11/07/2024 02:39:16.364 7fef72633c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.364 7fef72633c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 500: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=12, max_bytes=1048576)])])
11/07/2024 02:39:16.369 7fef72633948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 10
11/07/2024 02:39:16.369 7fef72633948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.369 7fef72633948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=10, max_bytes=1048576)])])
11/07/2024 02:39:16.369 7fef72786e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 13
11/07/2024 02:39:16.370 7fef72786e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.370 7fef72786e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=13, max_bytes=1048576)])])
11/07/2024 02:39:16.391 7fef72633a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=19, message_set=[])])])
11/07/2024 02:39:16.453 7fef72633d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=34, message_set=[])])])
11/07/2024 02:39:16.454 7fef72633848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 504: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=35, message_set=[])])])
11/07/2024 02:39:16.454 7fef7020d248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13
11/07/2024 02:39:16.455 7fef7020d248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.455 7fef7020d248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 499: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
11/07/2024 02:39:16.458 7fef7020d648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 199
11/07/2024 02:39:16.459 7fef7020d648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.459 7fef7020d648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 534: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=199, max_bytes=1048576)])])
11/07/2024 02:39:16.490 7fef72786748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 101
11/07/2024 02:39:16.491 7fef72786748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.491 7fef72786748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 515: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=101, max_bytes=1048576)])])
11/07/2024 02:39:16.621 7fef7020d948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 523: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=145, message_set=[])])])
11/07/2024 02:39:16.623 7fef7020d448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45
11/07/2024 02:39:16.623 7fef7020d448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.624 7fef7020d448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 504: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=45, max_bytes=1048576)])])
11/07/2024 02:39:16.624 7fef72633e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 28
11/07/2024 02:39:16.624 7fef72633e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.624 7fef72633e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=28, max_bytes=1048576)])])
11/07/2024 02:39:16.625 7fef72633648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=[])])])
11/07/2024 02:39:16.626 7fef72633348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 500: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
11/07/2024 02:39:16.626 7fef7020d748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 138
11/07/2024 02:39:16.626 7fef7020d748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.627 7fef7020d748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 520: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=138, max_bytes=1048576)])])
11/07/2024 02:39:16.629 7fef72633748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 661: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=476, message_set=[])])])
11/07/2024 02:39:16.647 7fef7020d348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48
11/07/2024 02:39:16.647 7fef7020d348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.648 7fef7020d348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=48, max_bytes=1048576)])])
11/07/2024 02:39:16.649 7fef7020dc48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 536: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=165, message_set=[])])])
11/07/2024 02:39:16.718 7fef72633148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 16
11/07/2024 02:39:16.718 7fef72633148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.719 7fef72633148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=16, max_bytes=1048576)])])
11/07/2024 02:39:16.719 7fef7020d548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 501: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=26, message_set=[])])])
11/07/2024 02:39:16.720 7fef7020d048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 33
11/07/2024 02:39:16.720 7fef7020d048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.720 7fef7020d048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=33, max_bytes=1048576)])])
11/07/2024 02:39:16.721 7fef72633448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=[])])])
11/07/2024 02:39:16.764 7fef72633b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=[])])])
11/07/2024 02:39:16.765 7fef7020da48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 121
11/07/2024 02:39:16.765 7fef7020da48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.766 7fef7020da48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 522: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=121, max_bytes=1048576)])])
11/07/2024 02:39:16.789 7fef7020d148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 515: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
11/07/2024 02:39:16.864 7fef7020dd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 174
11/07/2024 02:39:16.864 7fef7020dd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.864 7fef7020dd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Request 535: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=174, max_bytes=1048576)])])
11/07/2024 02:39:16.865 7fef7020d848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 249
11/07/2024 02:39:16.865 7fef7020d848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/07/2024 02:39:16.865 7fef7020d848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 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=249, max_bytes=1048576)])])
11/07/2024 02:39:16.866 7fef72633548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.40/10.0.0.40 port=9092> Response 523: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=130, message_set=[])])])