08/27/2024 08:38:49.427 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 313: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:49.428 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 313: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:49.676 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 258
08/27/2024 08:38:49.676 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.676 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 354: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=258, max_bytes=1048576)])])
08/27/2024 08:38:49.677 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:49.677 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.677 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:49.679 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
08/27/2024 08:38:49.679 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:49.680 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:49.680 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.680 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 313: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:49.680 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:49.680 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.681 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 314: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:49.724 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
08/27/2024 08:38:49.779 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 342: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:49.786 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:49.807 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:49.807 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.807 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:49.809 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:49.809 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.810 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 340: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:49.810 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:49.872 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=193, message_set=['(offset=192, message=217)', '(offset=None, message=None)'])])])
08/27/2024 08:38:49.872 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 192 to buffered record list
08/27/2024 08:38:49.873 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 104
08/27/2024 08:38:49.873 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.873 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 337: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=104, max_bytes=1048576)])])
08/27/2024 08:38:49.873 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 338: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=148, message_set=['(offset=147, message=209)', '(offset=None, message=None)'])])])
08/27/2024 08:38:49.874 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 147 to buffered record list
08/27/2024 08:38:49.885 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 55
08/27/2024 08:38:49.885 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.885 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=55, max_bytes=1048576)])])
08/27/2024 08:38:49.886 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 325: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=43, message_set=[])])])
08/27/2024 08:38:49.888 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:49.888 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.888 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:49.900 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:49.926 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 325: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:49.936 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:49.937 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.937 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:49.973 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 193
08/27/2024 08:38:49.973 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.974 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=193, max_bytes=1048576)])])
08/27/2024 08:38:49.974 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 148
08/27/2024 08:38:49.975 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.975 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 339: 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)])])
08/27/2024 08:38:49.977 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 339: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=156, message_set=['(offset=148, message=215)', '(offset=149, message=209)', '(offset=150, message=209)', '(offset=151, message=215)', '(offset=152, message=209)', '(offset=153, message=209)', '(offset=154, message=215)', '(offset=155, message=209)', '(offset=None, message=None)'])])])
08/27/2024 08:38:49.977 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 148 to buffered record list
08/27/2024 08:38:49.985 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 331: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=81, message_set=[])])])
08/27/2024 08:38:49.986 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 340: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=181, message_set=['(offset=180, message=215)', '(offset=None, message=None)'])])])
08/27/2024 08:38:49.986 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 180 to buffered record list
08/27/2024 08:38:49.993 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 411: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=321, message_set=['(offset=320, message=224)', '(offset=None, message=None)'])])])
08/27/2024 08:38:49.994 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 320 to buffered record list
08/27/2024 08:38:49.994 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:49.994 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:49.995 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 313: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:49.995 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 313: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:50.011 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=50, message_set=[])])])
08/27/2024 08:38:50.012 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 337: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=255, message_set=[])])])
08/27/2024 08:38:50.029 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:50.029 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.030 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 314: 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)])])
08/27/2024 08:38:50.030 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:50.030 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.030 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 314: 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)])])
08/27/2024 08:38:50.079 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 156
08/27/2024 08:38:50.079 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.079 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 340: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=156, max_bytes=1048576)])])
08/27/2024 08:38:50.080 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 340: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=158, message_set=['(offset=156, message=215)', '(offset=157, message=209)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.080 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 156 to buffered record list
08/27/2024 08:38:50.087 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 181
08/27/2024 08:38:50.087 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.088 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 341: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=181, max_bytes=1048576)])])
08/27/2024 08:38:50.089 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 341: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=184, message_set=['(offset=181, message=215)', '(offset=182, message=215)', '(offset=183, message=215)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.089 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 181 to buffered record list
08/27/2024 08:38:50.095 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 321
08/27/2024 08:38:50.095 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.096 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 412: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=321, max_bytes=1048576)])])
08/27/2024 08:38:50.181 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 158
08/27/2024 08:38:50.181 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.182 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 341: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=158, max_bytes=1048576)])])
08/27/2024 08:38:50.182 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 341: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=161, message_set=['(offset=158, message=209)', '(offset=159, message=185)', '(offset=160, message=191)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.183 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 158 to buffered record list
08/27/2024 08:38:50.193 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 184
08/27/2024 08:38:50.193 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.193 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 342: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=184, max_bytes=1048576)])])
08/27/2024 08:38:50.195 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 342: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=['(offset=184, message=191)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.196 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 184 to buffered record list
08/27/2024 08:38:50.278 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 354: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=259, message_set=['(offset=258, message=235)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.278 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 258 to buffered record list
08/27/2024 08:38:50.279 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:50.280 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28
08/27/2024 08:38:50.280 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.280 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])])
08/27/2024 08:38:50.281 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:50.281 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.281 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:50.281 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 313: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:50.282 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:50.283 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 161
08/27/2024 08:38:50.283 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.284 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 342: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=161, max_bytes=1048576)])])
08/27/2024 08:38:50.296 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:50.296 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.297 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 343: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:50.325 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 13
08/27/2024 08:38:50.325 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.325 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
08/27/2024 08:38:50.379 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 259
08/27/2024 08:38:50.379 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.379 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 355: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=259, max_bytes=1048576)])])
08/27/2024 08:38:50.380 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:50.380 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.380 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 343: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:50.387 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:50.387 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.387 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:50.408 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:50.410 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 340: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:50.411 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:50.411 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.411 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 346: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:50.476 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 337: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=105, message_set=['(offset=104, message=235)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.476 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 104 to buffered record list
08/27/2024 08:38:50.487 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=55, message_set=[])])])
08/27/2024 08:38:50.487 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 43
08/27/2024 08:38:50.488 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.488 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=43, max_bytes=1048576)])])
08/27/2024 08:38:50.489 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:50.503 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
08/27/2024 08:38:50.503 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.503 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 323: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:50.526 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 38
08/27/2024 08:38:50.527 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.527 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:50.538 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:50.577 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=195, message_set=['(offset=193, message=217)', '(offset=194, message=217)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.577 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 193 to buffered record list
08/27/2024 08:38:50.578 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 105
08/27/2024 08:38:50.578 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.578 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 338: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=105, max_bytes=1048576)])])
08/27/2024 08:38:50.586 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 81
08/27/2024 08:38:50.586 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.586 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 332: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=81, max_bytes=1048576)])])
08/27/2024 08:38:50.596 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:50.597 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.597 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 314: 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)])])
08/27/2024 08:38:50.597 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 313: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:50.611 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 50
08/27/2024 08:38:50.612 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.612 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=50, max_bytes=1048576)])])
08/27/2024 08:38:50.612 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 255
08/27/2024 08:38:50.612 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.613 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 338: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=255, max_bytes=1048576)])])
08/27/2024 08:38:50.631 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:50.632 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:50.678 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 195
08/27/2024 08:38:50.678 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.678 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 346: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=195, max_bytes=1048576)])])
08/27/2024 08:38:50.697 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 412: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=321, message_set=[])])])
08/27/2024 08:38:50.880 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:50.880 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.880 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:50.881 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
08/27/2024 08:38:50.882 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:50.882 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:50.882 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.883 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 314: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:50.883 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:50.883 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.883 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:50.884 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 342: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=['(offset=161, message=185)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.884 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 161 to buffered record list
08/27/2024 08:38:50.897 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 343: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:50.926 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
08/27/2024 08:38:50.980 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 355: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=260, message_set=['(offset=259, message=229)', '(offset=None, message=None)'])])])
08/27/2024 08:38:50.981 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 259 to buffered record list
08/27/2024 08:38:50.981 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 343: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:50.985 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:50.985 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:50.985 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 343: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:50.988 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:51.009 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:51.009 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.009 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:51.011 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:51.011 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.011 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 341: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:51.012 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 346: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:51.081 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 260
08/27/2024 08:38:51.081 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.082 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 356: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=260, max_bytes=1048576)])])
08/27/2024 08:38:51.088 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 55
08/27/2024 08:38:51.088 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.088 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=55, max_bytes=1048576)])])
08/27/2024 08:38:51.089 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=43, message_set=[])])])
08/27/2024 08:38:51.089 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:51.090 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.090 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:51.104 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 323: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:51.128 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:51.139 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:51.139 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.139 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:51.179 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 338: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=['(offset=105, message=229)', '(offset=None, message=None)'])])])
08/27/2024 08:38:51.179 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 105 to buffered record list
08/27/2024 08:38:51.187 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 332: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=['(offset=81, message=237)', '(offset=None, message=None)'])])])
08/27/2024 08:38:51.187 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 81 to buffered record list
08/27/2024 08:38:51.198 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:51.198 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:51.910 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.910 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 314: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:51.911 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:51.911 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.911 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: 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)])])
08/27/2024 08:38:51.912 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:51.912 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.912 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: 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)])])
08/27/2024 08:38:51.913 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:51.913 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.913 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 339: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:51.913 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
08/27/2024 08:38:51.913 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.914 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 333: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
08/27/2024 08:38:51.914 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 321
08/27/2024 08:38:51.914 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.914 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 413: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=321, max_bytes=1048576)])])
08/27/2024 08:38:51.914 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28
08/27/2024 08:38:51.915 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.915 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])])
08/27/2024 08:38:51.915 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:51.915 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.915 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:51.916 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:51.916 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.916 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 344: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:51.916 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 13
08/27/2024 08:38:51.916 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.916 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
08/27/2024 08:38:51.917 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:51.917 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.917 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 344: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:51.917 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:51.917 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.917 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:51.918 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:51.918 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.918 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 347: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:51.918 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 43
08/27/2024 08:38:51.918 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:51.919 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=43, max_bytes=1048576)])])
08/27/2024 08:38:51.920 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 328: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=50, message_set=[])])])
08/27/2024 08:38:51.920 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 338: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=255, message_set=[])])])
08/27/2024 08:38:51.921 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 346: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=['(offset=195, message=217)', '(offset=196, message=193)', '(offset=None, message=None)'])])])
08/27/2024 08:38:51.921 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 195 to buffered record list
08/27/2024 08:38:51.921 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:51.922 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:51.922 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:51.923 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 343: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:51.923 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:51.923 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 341: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:51.924 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 356: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=260, message_set=[])])])
08/27/2024 08:38:51.924 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 328: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=55, message_set=[])])])
08/27/2024 08:38:51.925 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:51.926 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 413: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=322, message_set=['(offset=321, message=224)', '(offset=None, message=None)'])])])
08/27/2024 08:38:51.926 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 321 to buffered record list
08/27/2024 08:38:52.022 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:52.022 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.022 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 347: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:52.027 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 322
08/27/2024 08:38:52.027 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.027 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 414: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=322, max_bytes=1048576)])])
08/27/2024 08:38:52.411 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
08/27/2024 08:38:52.411 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.411 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 324: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:52.412 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 38
08/27/2024 08:38:52.412 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.412 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:52.413 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:52.414 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:52.415 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.415 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: 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)])])
08/27/2024 08:38:52.520 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 314: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:52.520 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 50
08/27/2024 08:38:52.520 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.521 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 329: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=50, max_bytes=1048576)])])
08/27/2024 08:38:52.521 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 255
08/27/2024 08:38:52.521 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.521 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 339: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=255, max_bytes=1048576)])])
08/27/2024 08:38:52.522 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:52.522 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.523 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:52.523 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:52.523 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.523 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:52.523 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:52.523 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.524 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:52.524 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:52.524 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.524 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 344: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:52.524 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:52.525 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.525 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:52.525 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:52.525 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.525 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 342: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:52.526 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 260
08/27/2024 08:38:52.526 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.526 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 357: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=260, max_bytes=1048576)])])
08/27/2024 08:38:52.526 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 55
08/27/2024 08:38:52.526 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.526 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 329: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=55, max_bytes=1048576)])])
08/27/2024 08:38:52.527 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:52.527 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:52.527 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:52.528 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:52.528 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:52.529 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 339: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=[])])])
08/27/2024 08:38:52.529 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 333: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
08/27/2024 08:38:52.530 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
08/27/2024 08:38:52.530 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:52.531 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:52.531 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
08/27/2024 08:38:52.531 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:52.532 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:52.532 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 347: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:52.533 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=43, message_set=[])])])
08/27/2024 08:38:52.623 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 347: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=[])])])
08/27/2024 08:38:52.628 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 414: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=322, message_set=[])])])
08/27/2024 08:38:53.013 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 324: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:53.014 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:53.014 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.014 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:53.015 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:53.015 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:53.120 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:53.121 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.121 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 315: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:53.122 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 329: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=50, message_set=[])])])
08/27/2024 08:38:53.122 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 339: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=255, message_set=[])])])
08/27/2024 08:38:53.124 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:53.126 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:53.126 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:53.127 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:53.128 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 328: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:53.128 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 342: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:53.129 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 357: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=260, message_set=[])])])
08/27/2024 08:38:53.129 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 329: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=55, message_set=[])])])
08/27/2024 08:38:53.130 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:53.130 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:53.130 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.130 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: 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)])])
08/27/2024 08:38:53.131 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:53.131 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.131 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: 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)])])
08/27/2024 08:38:53.131 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:53.131 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.131 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 340: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:53.132 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
08/27/2024 08:38:53.132 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.132 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 334: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
08/27/2024 08:38:53.132 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28
08/27/2024 08:38:53.132 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.132 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])])
08/27/2024 08:38:53.133 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:53.133 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.133 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:53.133 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:53.133 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.133 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:53.134 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 13
08/27/2024 08:38:53.134 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.134 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
08/27/2024 08:38:53.134 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:53.134 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.135 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:53.135 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:53.135 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.135 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 323: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:53.135 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:53.135 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.136 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 348: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:53.136 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 43
08/27/2024 08:38:53.136 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.136 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=43, max_bytes=1048576)])])
08/27/2024 08:38:53.224 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:53.225 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.225 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 348: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:53.230 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 322
08/27/2024 08:38:53.230 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.231 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 415: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=322, max_bytes=1048576)])])
08/27/2024 08:38:53.614 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
08/27/2024 08:38:53.614 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.614 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 325: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:53.615 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 38
08/27/2024 08:38:53.615 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.615 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:53.616 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:53.616 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:53.616 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.617 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: 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)])])
08/27/2024 08:38:53.722 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 315: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:53.723 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 50
08/27/2024 08:38:53.723 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.724 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 330: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=50, max_bytes=1048576)])])
08/27/2024 08:38:53.724 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 255
08/27/2024 08:38:53.724 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.724 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 340: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=255, max_bytes=1048576)])])
08/27/2024 08:38:53.725 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:53.725 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.726 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:53.726 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:53.727 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.727 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:53.728 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:53.728 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.728 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:53.729 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:53.729 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.729 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:53.729 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:53.729 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.730 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 329: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:53.730 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:53.730 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.730 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 343: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:53.730 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 260
08/27/2024 08:38:53.731 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.731 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 358: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=260, max_bytes=1048576)])])
08/27/2024 08:38:53.731 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 55
08/27/2024 08:38:53.731 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.731 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 330: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=55, max_bytes=1048576)])])
08/27/2024 08:38:53.732 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:53.732 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:53.732 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:53.736 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:53.736 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:53.737 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 340: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=[])])])
08/27/2024 08:38:53.737 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 334: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
08/27/2024 08:38:53.738 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
08/27/2024 08:38:53.738 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:53.739 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:53.739 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=13, message_set=[])])])
08/27/2024 08:38:53.740 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:53.740 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 323: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:53.741 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 348: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:53.741 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 328: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=43, message_set=[])])])
08/27/2024 08:38:53.826 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 348: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=[])])])
08/27/2024 08:38:53.832 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 415: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=322, message_set=[])])])
08/27/2024 08:38:54.215 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 325: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:54.216 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 328: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:54.216 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:54.217 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.217 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:54.217 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:54.323 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:54.323 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.324 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 316: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:54.325 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 330: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=50, message_set=[])])])
08/27/2024 08:38:54.325 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 340: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=255, message_set=[])])])
08/27/2024 08:38:54.326 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:54.327 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:54.328 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:54.331 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:54.331 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 329: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:54.332 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 343: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:54.333 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 358: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=260, message_set=[])])])
08/27/2024 08:38:54.334 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 330: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=55, message_set=[])])])
08/27/2024 08:38:54.334 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:54.336 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:54.337 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.337 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: 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)])])
08/27/2024 08:38:54.338 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:54.338 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.339 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: 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)])])
08/27/2024 08:38:54.339 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:54.339 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.339 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 341: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:54.339 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
08/27/2024 08:38:54.339 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.340 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 335: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
08/27/2024 08:38:54.340 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28
08/27/2024 08:38:54.340 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.340 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 323: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])])
08/27/2024 08:38:54.340 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:54.341 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.341 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:54.341 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:54.341 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.341 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 346: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:54.341 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 13
08/27/2024 08:38:54.341 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.342 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=13, max_bytes=1048576)])])
08/27/2024 08:38:54.342 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:54.342 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.342 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 346: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:54.342 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:54.342 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.343 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 324: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:54.343 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:54.343 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.343 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 349: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:54.344 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 43
08/27/2024 08:38:54.344 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.344 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 329: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=43, max_bytes=1048576)])])
08/27/2024 08:38:54.428 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:54.429 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.429 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 349: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:54.433 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 322
08/27/2024 08:38:54.433 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.433 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 416: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=322, max_bytes=1048576)])])
08/27/2024 08:38:54.816 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
08/27/2024 08:38:54.816 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.817 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:54.817 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 38
08/27/2024 08:38:54.817 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.817 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 329: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:54.818 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 329: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=['(offset=38, message=357)', '(offset=39, message=342)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.818 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-12', partition=0) with offset 38 to buffered record list
08/27/2024 08:38:54.819 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:54.819 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:54.819 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.819 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: 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)])])
08/27/2024 08:38:54.919 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 40
08/27/2024 08:38:54.919 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.919 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 330: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:54.927 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 50
08/27/2024 08:38:54.927 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.927 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 331: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=50, max_bytes=1048576)])])
08/27/2024 08:38:54.927 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 255
08/27/2024 08:38:54.927 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.927 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 341: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=255, max_bytes=1048576)])])
08/27/2024 08:38:54.928 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 316: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:54.928 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:54.928 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.929 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:54.929 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:54.929 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.929 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:54.930 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 331: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=51, message_set=['(offset=50, message=358)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.930 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-14', partition=0) with offset 50 to buffered record list
08/27/2024 08:38:54.931 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 341: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=257, message_set=['(offset=255, message=216)', '(offset=256, message=318)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.931 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 255 to buffered record list
08/27/2024 08:38:54.931 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:54.931 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.931 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:54.935 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:54.935 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.935 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 346: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:54.935 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:54.935 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.935 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 330: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:54.936 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:54.936 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.936 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 344: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:54.936 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 260
08/27/2024 08:38:54.936 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.936 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 359: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=260, max_bytes=1048576)])])
08/27/2024 08:38:54.937 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 55
08/27/2024 08:38:54.937 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.937 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 331: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=55, max_bytes=1048576)])])
08/27/2024 08:38:54.937 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:54.937 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:54.937 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:54.939 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 359: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=262, message_set=['(offset=260, message=212)', '(offset=261, message=310)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.939 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 260 to buffered record list
08/27/2024 08:38:54.940 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:54.941 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:54.942 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 341: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=[])])])
08/27/2024 08:38:54.942 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 335: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=84, message_set=['(offset=82, message=254)', '(offset=83, message=254)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.942 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 82 to buffered record list
08/27/2024 08:38:54.943 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 323: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
08/27/2024 08:38:54.944 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:54.944 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 346: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:54.945 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=['(offset=13, message=341)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.945 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-18', partition=0) with offset 13 to buffered record list
08/27/2024 08:38:54.945 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 346: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:54.946 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 324: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:54.946 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 349: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:54.947 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 329: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=['(offset=43, message=243)', '(offset=None, message=None)'])])])
08/27/2024 08:38:54.947 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-19', partition=0) with offset 43 to buffered record list
08/27/2024 08:38:55.030 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 349: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=[])])])
08/27/2024 08:38:55.031 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 51
08/27/2024 08:38:55.031 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.031 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 332: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=51, max_bytes=1048576)])])
08/27/2024 08:38:55.032 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 257
08/27/2024 08:38:55.032 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.032 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 342: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=257, max_bytes=1048576)])])
08/27/2024 08:38:55.034 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 416: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=323, message_set=['(offset=322, message=224)', '(offset=None, message=None)'])])])
08/27/2024 08:38:55.034 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 322 to buffered record list
08/27/2024 08:38:55.040 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 262
08/27/2024 08:38:55.040 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.040 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 360: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=262, max_bytes=1048576)])])
08/27/2024 08:38:55.043 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 84
08/27/2024 08:38:55.043 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.043 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 336: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=84, max_bytes=1048576)])])
08/27/2024 08:38:55.045 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 14
08/27/2024 08:38:55.045 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.046 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 323: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
08/27/2024 08:38:55.047 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44
08/27/2024 08:38:55.047 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.048 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 330: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
08/27/2024 08:38:55.135 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 323
08/27/2024 08:38:55.135 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.135 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 417: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=323, max_bytes=1048576)])])
08/27/2024 08:38:55.418 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:55.420 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:55.420 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.421 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:55.421 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:55.521 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 330: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:55.528 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:55.529 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.529 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 317: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:55.535 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:55.535 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:55.538 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:55.539 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 346: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:55.539 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 330: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:55.540 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:55.540 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 331: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=57, message_set=['(offset=55, message=215)', '(offset=56, message=217)', '(offset=None, message=None)'])])])
08/27/2024 08:38:55.541 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 55 to buffered record list
08/27/2024 08:38:55.541 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:55.541 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.541 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: 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)])])
08/27/2024 08:38:55.542 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:55.542 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:55.542 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.542 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: 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)])])
08/27/2024 08:38:55.543 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:55.543 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.543 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 342: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:55.543 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28
08/27/2024 08:38:55.543 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.544 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 324: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])])
08/27/2024 08:38:55.544 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:55.544 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.544 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:55.545 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:55.545 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.545 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 347: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:55.546 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:55.546 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.546 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 347: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:55.546 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:55.547 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.547 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 325: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:55.547 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:55.547 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.547 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 350: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:55.631 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:55.631 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.631 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 350: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:55.633 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 332: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=51, message_set=[])])])
08/27/2024 08:38:55.633 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 342: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=257, message_set=[])])])
08/27/2024 08:38:55.641 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 360: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=262, message_set=[])])])
08/27/2024 08:38:55.641 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 57
08/27/2024 08:38:55.641 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.642 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 332: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=57, max_bytes=1048576)])])
08/27/2024 08:38:55.644 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 336: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=84, message_set=[])])])
08/27/2024 08:38:55.646 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 323: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
08/27/2024 08:38:55.648 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 330: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
08/27/2024 08:38:55.736 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 417: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=324, message_set=['(offset=323, message=224)', '(offset=None, message=None)'])])])
08/27/2024 08:38:55.736 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 323 to buffered record list
08/27/2024 08:38:55.838 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 324
08/27/2024 08:38:55.838 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:55.839 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 418: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=324, max_bytes=1048576)])])
08/27/2024 08:38:56.019 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
08/27/2024 08:38:56.019 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.020 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:56.022 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:56.022 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:56.022 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.022 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: 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)])])
08/27/2024 08:38:56.122 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 40
08/27/2024 08:38:56.122 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.122 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 331: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:56.130 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 317: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:56.135 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:56.135 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.136 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:56.136 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:56.136 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.136 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:56.138 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:56.138 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.139 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:56.139 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:56.139 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.139 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 347: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:56.140 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:56.140 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.140 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 331: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:56.140 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:56.140 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.141 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:56.142 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:56.142 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.142 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:56.143 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:56.144 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:56.145 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 342: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=[])])])
08/27/2024 08:38:56.145 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 324: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=28, message_set=[])])])
08/27/2024 08:38:56.146 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:56.146 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 347: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:56.147 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 347: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:56.148 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 325: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:56.149 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 350: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:56.232 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 350: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=[])])])
08/27/2024 08:38:56.233 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 51
08/27/2024 08:38:56.233 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.233 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 333: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=51, max_bytes=1048576)])])
08/27/2024 08:38:56.234 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 257
08/27/2024 08:38:56.234 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.234 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 343: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=257, max_bytes=1048576)])])
08/27/2024 08:38:56.242 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 262
08/27/2024 08:38:56.242 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.242 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 361: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=262, max_bytes=1048576)])])
08/27/2024 08:38:56.243 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 332: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=57, message_set=[])])])
08/27/2024 08:38:56.246 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 84
08/27/2024 08:38:56.246 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.246 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 337: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=84, max_bytes=1048576)])])
08/27/2024 08:38:56.248 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 14
08/27/2024 08:38:56.248 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.248 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 324: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
08/27/2024 08:38:56.250 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44
08/27/2024 08:38:56.250 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.250 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 331: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
08/27/2024 08:38:56.461 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 418: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=324, message_set=[])])])
08/27/2024 08:38:56.621 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=38, message_set=[])])])
08/27/2024 08:38:56.623 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:56.623 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.623 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:56.624 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:56.723 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 331: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:56.730 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:56.730 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.731 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 318: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:56.737 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:56.738 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:56.739 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:56.740 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 347: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:56.741 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 331: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:56.742 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:56.743 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:56.745 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:56.745 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.745 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: 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)])])
08/27/2024 08:38:56.745 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:56.745 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.746 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: 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)])])
08/27/2024 08:38:56.746 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:56.746 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.746 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 343: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:56.747 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 28
08/27/2024 08:38:56.747 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.747 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 325: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=28, max_bytes=1048576)])])
08/27/2024 08:38:56.747 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:56.747 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.748 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:56.748 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:56.748 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.748 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 348: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:56.749 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:56.749 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.749 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 348: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:56.749 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:56.749 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.750 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:56.750 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:56.750 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.750 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 351: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:56.833 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:56.833 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.834 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 351: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:56.835 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 333: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=51, message_set=[])])])
08/27/2024 08:38:56.836 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 343: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=257, message_set=[])])])
08/27/2024 08:38:56.843 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 361: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=262, message_set=[])])])
08/27/2024 08:38:56.844 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 57
08/27/2024 08:38:56.844 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:56.844 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 333: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=57, max_bytes=1048576)])])
08/27/2024 08:38:56.847 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 337: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=84, message_set=[])])])
08/27/2024 08:38:56.849 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 324: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=14, message_set=[])])])
08/27/2024 08:38:56.851 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 331: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
08/27/2024 08:38:57.062 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 324
08/27/2024 08:38:57.063 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.063 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 419: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=324, max_bytes=1048576)])])
08/27/2024 08:38:57.221 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 38
08/27/2024 08:38:57.221 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.222 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=38, max_bytes=1048576)])])
08/27/2024 08:38:57.224 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:57.224 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:57.224 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.225 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: 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)])])
08/27/2024 08:38:57.324 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 40
08/27/2024 08:38:57.325 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.325 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 332: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:57.331 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 318: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:57.338 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:57.338 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.338 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:57.338 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:57.338 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.339 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:57.339 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:57.340 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.340 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:57.341 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:57.341 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.341 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 348: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:57.341 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:57.342 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.342 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 332: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:57.342 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:57.342 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.342 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 346: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:57.343 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:57.344 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.344 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:57.346 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:57.347 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:57.347 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 343: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=[])])])
08/27/2024 08:38:57.349 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 325: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=29, message_set=['(offset=28, message=354)', '(offset=None, message=None)'])])])
08/27/2024 08:38:57.349 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-15', partition=0) with offset 28 to buffered record list
08/27/2024 08:38:57.350 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:57.350 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 348: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:57.351 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 348: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:57.351 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:57.352 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 351: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=296, message_set=[])])])
08/27/2024 08:38:57.435 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 351: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=[])])])
08/27/2024 08:38:57.436 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 51
08/27/2024 08:38:57.436 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.437 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 334: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=51, max_bytes=1048576)])])
08/27/2024 08:38:57.437 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 257
08/27/2024 08:38:57.437 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.438 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 344: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=257, max_bytes=1048576)])])
08/27/2024 08:38:57.445 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 262
08/27/2024 08:38:57.445 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.445 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 362: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=262, max_bytes=1048576)])])
08/27/2024 08:38:57.445 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 333: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=57, message_set=[])])])
08/27/2024 08:38:57.448 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 84
08/27/2024 08:38:57.448 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.449 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 338: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=84, max_bytes=1048576)])])
08/27/2024 08:38:57.450 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 29
08/27/2024 08:38:57.450 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.450 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=29, max_bytes=1048576)])])
08/27/2024 08:38:57.450 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 14
08/27/2024 08:38:57.450 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.451 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 325: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=14, max_bytes=1048576)])])
08/27/2024 08:38:57.452 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44
08/27/2024 08:38:57.452 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.452 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 332: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
08/27/2024 08:38:57.664 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 419: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=325, message_set=['(offset=324, message=224)', '(offset=None, message=None)'])])])
08/27/2024 08:38:57.664 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 324 to buffered record list
08/27/2024 08:38:57.765 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 325
08/27/2024 08:38:57.765 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.765 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 420: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=325, max_bytes=1048576)])])
08/27/2024 08:38:57.823 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 328: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=39, message_set=['(offset=38, message=353)', '(offset=None, message=None)'])])])
08/27/2024 08:38:57.823 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-13', partition=0) with offset 38 to buffered record list
08/27/2024 08:38:57.825 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:57.825 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.826 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:57.826 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:57.924 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 39
08/27/2024 08:38:57.924 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.924 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 329: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=39, max_bytes=1048576)])])
08/27/2024 08:38:57.928 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 332: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=41, message_set=['(offset=40, message=353)', '(offset=None, message=None)'])])])
08/27/2024 08:38:57.929 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-12', partition=0) with offset 40 to buffered record list
08/27/2024 08:38:57.936 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:57.936 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.937 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 319: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:57.940 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:57.940 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:57.941 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:57.942 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 348: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:57.943 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 332: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:57.943 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 346: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:57.944 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:57.947 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:57.947 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.947 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: 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)])])
08/27/2024 08:38:57.947 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:57.947 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.947 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: 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)])])
08/27/2024 08:38:57.948 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:57.948 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.948 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 344: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:57.950 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:57.950 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.950 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:57.951 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:57.951 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.951 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 349: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:57.951 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:57.952 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.952 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 349: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:57.952 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:57.952 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.953 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:57.953 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 296
08/27/2024 08:38:57.953 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:57.953 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 352: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=296, max_bytes=1048576)])])
08/27/2024 08:38:57.954 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 352: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=297, message_set=['(offset=296, message=301)', '(offset=None, message=None)'])])])
08/27/2024 08:38:57.954 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 296 to buffered record list
08/27/2024 08:38:58.029 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 41
08/27/2024 08:38:58.029 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.030 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 333: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=41, max_bytes=1048576)])])
08/27/2024 08:38:58.036 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:58.036 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.037 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 352: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:58.037 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 334: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=52, message_set=['(offset=51, message=354)', '(offset=None, message=None)'])])])
08/27/2024 08:38:58.037 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-14', partition=0) with offset 51 to buffered record list
08/27/2024 08:38:58.038 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=257, message_set=[])])])
08/27/2024 08:38:58.046 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 362: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=262, message_set=[])])])
08/27/2024 08:38:58.046 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 57
08/27/2024 08:38:58.046 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.046 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 334: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=57, max_bytes=1048576)])])
08/27/2024 08:38:58.049 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 338: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=84, message_set=[])])])
08/27/2024 08:38:58.050 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=29, message_set=[])])])
08/27/2024 08:38:58.051 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 325: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=['(offset=14, message=337)', '(offset=None, message=None)'])])])
08/27/2024 08:38:58.051 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-18', partition=0) with offset 14 to buffered record list
08/27/2024 08:38:58.052 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 332: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
08/27/2024 08:38:58.055 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 297
08/27/2024 08:38:58.055 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.055 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 353: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=297, max_bytes=1048576)])])
08/27/2024 08:38:58.138 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 52
08/27/2024 08:38:58.138 7fdd8cfe9348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.139 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 335: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=52, max_bytes=1048576)])])
08/27/2024 08:38:58.152 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 15
08/27/2024 08:38:58.152 7fdd94468e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.152 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 326: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=15, max_bytes=1048576)])])
08/27/2024 08:38:58.366 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 420: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=326, message_set=['(offset=325, message=224)', '(offset=None, message=None)'])])])
08/27/2024 08:38:58.367 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 325 to buffered record list
08/27/2024 08:38:58.428 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=8, message_set=[])])])
08/27/2024 08:38:58.428 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
08/27/2024 08:38:58.428 7fdd94468848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.429 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: 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)])])
08/27/2024 08:38:58.467 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 326
08/27/2024 08:38:58.467 7fdd94468148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.468 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 421: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=326, max_bytes=1048576)])])
08/27/2024 08:38:58.525 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 329: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=['(offset=39, message=338)', '(offset=None, message=None)'])])])
08/27/2024 08:38:58.526 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-13', partition=0) with offset 39 to buffered record list
08/27/2024 08:38:58.539 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 319: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:58.540 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 1
08/27/2024 08:38:58.540 7fdd94468448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.540 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:58.541 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 1
08/27/2024 08:38:58.541 7fdd94468c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.541 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=1, max_bytes=1048576)])])
08/27/2024 08:38:58.541 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2
08/27/2024 08:38:58.541 7fdd94468548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.542 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:58.542 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 162
08/27/2024 08:38:58.542 7fdd8cfe9948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.542 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 349: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=162, max_bytes=1048576)])])
08/27/2024 08:38:58.543 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 40
08/27/2024 08:38:58.543 7fdd8cfe9148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.543 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 333: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:58.544 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 125
08/27/2024 08:38:58.544 7fdd8cfe9848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.544 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 347: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=125, max_bytes=1048576)])])
08/27/2024 08:38:58.545 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 4
08/27/2024 08:38:58.545 7fdd94468648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.545 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=4, max_bytes=1048576)])])
08/27/2024 08:38:58.548 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:58.549 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:58.549 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 344: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=106, message_set=[])])])
08/27/2024 08:38:58.552 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:58.552 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 349: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=185, message_set=[])])])
08/27/2024 08:38:58.554 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 349: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=175, message_set=[])])])
08/27/2024 08:38:58.554 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=23, message_set=[])])])
08/27/2024 08:38:58.626 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 40
08/27/2024 08:38:58.626 7fdd8cfe9448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.627 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 330: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=40, max_bytes=1048576)])])
08/27/2024 08:38:58.631 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 333: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=42, message_set=['(offset=41, message=338)', '(offset=None, message=None)'])])])
08/27/2024 08:38:58.631 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-12', partition=0) with offset 41 to buffered record list
08/27/2024 08:38:58.637 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 352: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=197, message_set=[])])])
08/27/2024 08:38:58.639 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 257
08/27/2024 08:38:58.639 7fdd8cfe9748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.639 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=257, max_bytes=1048576)])])
08/27/2024 08:38:58.646 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 262
08/27/2024 08:38:58.646 7fdd8cfe9d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.646 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 363: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=262, max_bytes=1048576)])])
08/27/2024 08:38:58.647 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 334: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=57, message_set=[])])])
08/27/2024 08:38:58.649 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 84
08/27/2024 08:38:58.650 7fdd8cfe9648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.650 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 339: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=84, max_bytes=1048576)])])
08/27/2024 08:38:58.651 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 29
08/27/2024 08:38:58.651 7fdd8cfe9248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.651 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 327: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=29, max_bytes=1048576)])])
08/27/2024 08:38:58.653 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 44
08/27/2024 08:38:58.653 7fdd8cfe9a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.653 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 333: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=44, max_bytes=1048576)])])
08/27/2024 08:38:58.656 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 353: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=297, message_set=[])])])
08/27/2024 08:38:58.731 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 42
08/27/2024 08:38:58.732 7fdd94468a48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:58.732 7fdd94468a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 334: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=42, max_bytes=1048576)])])
08/27/2024 08:38:58.739 7fdd8cfe9348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 335: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=52, message_set=[])])])
08/27/2024 08:38:58.753 7fdd94468e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 326: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=15, message_set=[])])])
08/27/2024 08:38:59.028 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 8
08/27/2024 08:38:59.029 7fdd94468748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.029 7fdd94468748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 323: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=8, max_bytes=1048576)])])
08/27/2024 08:38:59.030 7fdd94468848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
08/27/2024 08:38:59.069 7fdd94468148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 421: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=326, message_set=[])])])
08/27/2024 08:38:59.140 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
08/27/2024 08:38:59.140 7fdd94468b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.140 7fdd94468b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 320: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
08/27/2024 08:38:59.142 7fdd94468448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:59.142 7fdd94468c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 320: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=1, message_set=[])])])
08/27/2024 08:38:59.143 7fdd94468548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 321: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=2, message_set=[])])])
08/27/2024 08:38:59.143 7fdd8cfe9948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 349: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=162, message_set=[])])])
08/27/2024 08:38:59.144 7fdd8cfe9148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 333: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:59.145 7fdd8cfe9848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 347: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=125, message_set=[])])])
08/27/2024 08:38:59.145 7fdd94468648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 322: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=4, message_set=[])])])
08/27/2024 08:38:59.148 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
08/27/2024 08:38:59.149 7fdd94454048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.149 7fdd94454048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: 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)])])
08/27/2024 08:38:59.149 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
08/27/2024 08:38:59.149 7fdd94468348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.149 7fdd94468348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 321: 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)])])
08/27/2024 08:38:59.150 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 106
08/27/2024 08:38:59.150 7fdd8cfe9c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.150 7fdd8cfe9c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 345: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=106, max_bytes=1048576)])])
08/27/2024 08:38:59.152 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
08/27/2024 08:38:59.152 7fdd94468d48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.153 7fdd94468d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 322: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])])
08/27/2024 08:38:59.153 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 185
08/27/2024 08:38:59.153 7fdd8cfe9b48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.153 7fdd8cfe9b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 350: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=185, max_bytes=1048576)])])
08/27/2024 08:38:59.154 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 175
08/27/2024 08:38:59.154 7fdd945c0348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.155 7fdd945c0348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 350: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=175, max_bytes=1048576)])])
08/27/2024 08:38:59.155 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 23
08/27/2024 08:38:59.155 7fdd8cfe9048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.155 7fdd8cfe9048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 328: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=23, max_bytes=1048576)])])
08/27/2024 08:38:59.228 7fdd8cfe9448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 330: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=40, message_set=[])])])
08/27/2024 08:38:59.238 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 197
08/27/2024 08:38:59.238 7fdd945c0748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.238 7fdd945c0748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 353: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=197, max_bytes=1048576)])])
08/27/2024 08:38:59.240 7fdd8cfe9748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 345: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=257, message_set=[])])])
08/27/2024 08:38:59.247 7fdd8cfe9d48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 363: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=262, message_set=[])])])
08/27/2024 08:38:59.247 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 57
08/27/2024 08:38:59.247 7fdd94468948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.248 7fdd94468948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 335: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=57, max_bytes=1048576)])])
08/27/2024 08:38:59.250 7fdd8cfe9648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 339: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=84, message_set=[])])])
08/27/2024 08:38:59.252 7fdd8cfe9248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 327: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=29, message_set=[])])])
08/27/2024 08:38:59.255 7fdd8cfe9a48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Response 333: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=44, message_set=[])])])
08/27/2024 08:38:59.257 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 297
08/27/2024 08:38:59.257 7fdd8cfe9548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
08/27/2024 08:38:59.257 7fdd8cfe9548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.28/10.0.0.28 port=9092> Request 354: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=297, max_bytes=1048576)])])