09/09/2024 03:06:33.274 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:33.275 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 895: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=637, max_bytes=1048576)])])
09/09/2024 03:06:33.656 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
09/09/2024 03:06:33.656 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:33.656 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 864: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:33.662 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 907: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:33.695 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
09/09/2024 03:06:33.695 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:33.696 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 950: 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)])])
09/09/2024 03:06:33.701 7fe4c83aa548 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-14']) to node 1
09/09/2024 03:06:33.701 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 953: MetadataRequest_v1(topics=['-uve-topic-14'])
09/09/2024 03:06:33.701 7fe4c83aa048 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-8']) to node 1
09/09/2024 03:06:33.702 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 951: MetadataRequest_v1(topics=['-uve-topic-8'])
09/09/2024 03:06:33.702 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:33.815 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 213
09/09/2024 03:06:33.816 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:33.816 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 913: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=213, max_bytes=1048576)])])
09/09/2024 03:06:34.263 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 202
09/09/2024 03:06:34.263 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.263 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 908: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:34.274 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 950: MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.55', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-17', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])])
09/09/2024 03:06:34.275 7fe4c83aa348 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)
09/09/2024 03:06:34.277 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 953: MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.55', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-12', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])])
09/09/2024 03:06:34.278 7fe4c83aa648 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)
09/09/2024 03:06:34.278 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 850: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.279 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 929: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.280 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 887: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.281 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 929: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.287 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 929: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.288 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 890: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.295 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 851: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.297 7fe4cb026848 [kafka.client] [DEBUG]: Sending metadata request MetadataRequest_v1(topics=['-uve-topic-1']) to node 1
09/09/2024 03:06:34.297 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 951: MetadataRequest_v1(topics=['-uve-topic-1'])
09/09/2024 03:06:34.298 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.299 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 888: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.299 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 887: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.303 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0
09/09/2024 03:06:34.304 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.304 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.312 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 928: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.315 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 849: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.315 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 851: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:34.316 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 944: MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.55', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-23', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])])
09/09/2024 03:06:34.317 7fe4c83aa748 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)
09/09/2024 03:06:34.317 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 916: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:34.853 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 884: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=446, message_set=['(offset=444, message=246)', '(offset=445, message=246)', '(offset=None, message=None)'])])])
09/09/2024 03:06:34.854 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 444 to buffered record list
09/09/2024 03:06:34.875 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
09/09/2024 03:06:34.876 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.876 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 951: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.878 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0
09/09/2024 03:06:34.878 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.879 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 954: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.879 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
09/09/2024 03:06:34.880 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.880 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 851: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.880 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0
09/09/2024 03:06:34.880 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.881 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 930: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.881 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
09/09/2024 03:06:34.881 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.882 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 888: 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)])])
09/09/2024 03:06:34.882 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
09/09/2024 03:06:34.882 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.882 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 930: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.888 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
09/09/2024 03:06:34.888 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.888 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 930: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.889 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
09/09/2024 03:06:34.889 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.889 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 891: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.895 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0
09/09/2024 03:06:34.896 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.896 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 852: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.899 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0
09/09/2024 03:06:34.899 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.899 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.899 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0
09/09/2024 03:06:34.900 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.900 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 889: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.900 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0
09/09/2024 03:06:34.901 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.901 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 888: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.914 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0
09/09/2024 03:06:34.914 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.914 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 929: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.916 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 0
09/09/2024 03:06:34.916 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.917 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 850: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.917 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 0
09/09/2024 03:06:34.917 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.918 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 852: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:34.918 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
09/09/2024 03:06:34.919 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.919 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 945: 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)])])
09/09/2024 03:06:34.920 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 82
09/09/2024 03:06:34.920 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.921 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 917: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
09/09/2024 03:06:34.956 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 446
09/09/2024 03:06:34.956 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:34.956 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 885: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=446, max_bytes=1048576)])])
09/09/2024 03:06:35.457 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 862: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=220, message_set=[])])])
09/09/2024 03:06:35.475 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 927: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:35.510 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 952: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:35.511 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 950: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:35.573 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 893: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=1757, message_set=[])])])
09/09/2024 03:06:36.059 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 220
09/09/2024 03:06:36.059 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:36.060 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 863: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=220, max_bytes=1048576)])])
09/09/2024 03:06:36.061 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 864: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:36.077 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0
09/09/2024 03:06:36.077 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:36.078 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 928: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:36.111 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 950: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:36.174 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1757
09/09/2024 03:06:36.174 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:36.175 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 894: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=1757, max_bytes=1048576)])])
09/09/2024 03:06:36.229 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 913: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=213, message_set=[])])])
09/09/2024 03:06:36.287 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 895: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=640, message_set=['(offset=637, message=202)', '(offset=638, message=207)', '(offset=639, message=209)'])])])
09/09/2024 03:06:36.287 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-3', partition=0) with offset 637 to buffered record list
09/09/2024 03:06:36.388 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 640
09/09/2024 03:06:36.389 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:36.389 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 896: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=640, max_bytes=1048576)])])
09/09/2024 03:06:36.662 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
09/09/2024 03:06:36.662 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:36.663 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 865: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:36.674 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 908: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:36.714 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 953: MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.55', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-14', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])])
09/09/2024 03:06:36.715 7fe4c83aa548 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)
09/09/2024 03:06:36.716 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 951: MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.55', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-8', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])])
09/09/2024 03:06:36.718 7fe4c83aa048 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)
09/09/2024 03:06:36.718 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:36.830 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 213
09/09/2024 03:06:36.830 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:36.831 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 914: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=213, max_bytes=1048576)])])
09/09/2024 03:06:37.276 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 202
09/09/2024 03:06:37.276 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.276 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 909: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:37.281 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 951: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.286 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 954: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.286 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 851: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.287 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.288 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 888: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.288 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.295 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.296 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 891: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.315 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 852: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.315 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.316 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 889: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.317 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 888: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.318 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 951: MetadataResponse_v1(brokers=[(node_id=1, host='10.0.0.55', port=9092, rack=None)], controller_id=1, topics=[(error_code=0, topic='-uve-topic-1', is_internal=False, partitions=[(error_code=0, partition=0, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=5, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=10, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=20, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=15, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=25, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=26, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=9, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=11, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=16, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=4, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=17, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=3, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=24, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=23, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=28, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=13, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=18, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=22, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=8, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=2, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=12, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=29, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=19, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=14, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=1, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=6, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=7, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=27, leader=1, replicas=[1], isr=[1]), (error_code=0, partition=21, leader=1, replicas=[1], isr=[1])])])
09/09/2024 03:06:37.319 7fe4cb026848 [kafka.cluster] [DEBUG]: Updated cluster metadata to ClusterMetadata(brokers: 1, topics: 1, groups: 0)
09/09/2024 03:06:37.320 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0
09/09/2024 03:06:37.320 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.320 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 954: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.320 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
09/09/2024 03:06:37.320 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.321 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 952: 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)])])
09/09/2024 03:06:37.321 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0
09/09/2024 03:06:37.321 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.321 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.331 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 929: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.332 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 850: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.333 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 852: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:37.333 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 945: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:37.334 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 917: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:37.362 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 885: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=446, message_set=[])])])
09/09/2024 03:06:37.363 7fe4caf72148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 605: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=1892, message_set=['(offset=1888, message=214)', '(offset=1889, message=214)', '(offset=1890, message=214)', '(offset=1891, message=214)', '(offset=None, message=None)'])])])
09/09/2024 03:06:37.364 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 1888 to buffered record list
09/09/2024 03:06:37.466 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 1892
09/09/2024 03:06:37.466 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.466 7fe4caf72148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 606: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=1892, max_bytes=1048576)])])
09/09/2024 03:06:37.881 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
09/09/2024 03:06:37.882 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.882 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 952: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.886 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0
09/09/2024 03:06:37.887 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.887 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 955: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.888 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
09/09/2024 03:06:37.888 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.888 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 852: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.888 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0
09/09/2024 03:06:37.889 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.889 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.889 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
09/09/2024 03:06:37.889 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.890 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 889: 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)])])
09/09/2024 03:06:37.890 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
09/09/2024 03:06:37.890 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.890 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.896 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
09/09/2024 03:06:37.896 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.897 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.897 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
09/09/2024 03:06:37.897 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.898 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 892: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.916 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0
09/09/2024 03:06:37.916 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.918 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 853: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.918 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0
09/09/2024 03:06:37.918 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.919 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.919 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0
09/09/2024 03:06:37.919 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.920 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 890: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.920 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0
09/09/2024 03:06:37.920 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.920 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 889: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.921 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
09/09/2024 03:06:37.921 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.921 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 952: 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)])])
09/09/2024 03:06:37.932 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0
09/09/2024 03:06:37.933 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.933 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 930: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.934 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 0
09/09/2024 03:06:37.934 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.934 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 851: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.935 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 0
09/09/2024 03:06:37.935 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.935 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 853: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:37.936 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
09/09/2024 03:06:37.936 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.936 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 946: 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)])])
09/09/2024 03:06:37.937 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 82
09/09/2024 03:06:37.937 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.937 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 918: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
09/09/2024 03:06:37.964 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 446
09/09/2024 03:06:37.965 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:37.965 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 886: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=446, max_bytes=1048576)])])
09/09/2024 03:06:38.481 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 928: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:39.067 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 865: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:39.084 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0
09/09/2024 03:06:39.084 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:39.085 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 929: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:39.242 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 914: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=213, message_set=[])])])
09/09/2024 03:06:39.399 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 896: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=642, message_set=['(offset=640, message=200)', '(offset=641, message=200)', '(offset=None, message=None)'])])])
09/09/2024 03:06:39.400 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-3', partition=0) with offset 640 to buffered record list
09/09/2024 03:06:39.501 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 642
09/09/2024 03:06:39.501 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:39.502 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 897: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=642, max_bytes=1048576)])])
09/09/2024 03:06:39.668 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 863: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=222, message_set=['(offset=220, message=226)', '(offset=221, message=226)', '(offset=None, message=None)'])])])
09/09/2024 03:06:39.668 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 220 to buffered record list
09/09/2024 03:06:39.669 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
09/09/2024 03:06:39.669 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:39.669 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 866: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:39.683 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 909: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:39.729 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 952: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:39.730 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 932: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:39.732 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 954: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:39.771 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 222
09/09/2024 03:06:39.771 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:39.771 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 864: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=222, max_bytes=1048576)])])
09/09/2024 03:06:39.784 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 894: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=1776, message_set=['(offset=1757, message=215)', '(offset=1758, message=215)', '(offset=1759, message=215)', '(offset=1760, message=215)', '(offset=1761, message=215)', '(offset=1762, message=215)', '(offset=1763, message=215)', '(offset=1764, message=215)', '(offset=1765, message=215)', '(offset=1766, message=215)', '(offset=1767, message=215)', '(offset=1768, message=215)', '(offset=1769, message=215)', '(offset=1770, message=215)', '(offset=1771, message=215)', '(offset=1772, message=215)', '(offset=1773, message=191)', '(offset=None, message=None)'])])])
09/09/2024 03:06:39.785 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 1757 to buffered record list
09/09/2024 03:06:39.847 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 213
09/09/2024 03:06:39.847 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:39.847 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 915: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=213, max_bytes=1048576)])])
09/09/2024 03:06:39.888 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1774
09/09/2024 03:06:39.888 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:39.889 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 895: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=1774, max_bytes=1048576)])])
09/09/2024 03:06:40.284 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 202
09/09/2024 03:06:40.285 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.285 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 910: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:40.290 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 952: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.295 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 955: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.296 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 852: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.297 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.298 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 889: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.299 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.305 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.306 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 892: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.329 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 853: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.330 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 932: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.331 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 890: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.331 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 889: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.332 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
09/09/2024 03:06:40.332 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.333 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 953: 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)])])
09/09/2024 03:06:40.334 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0
09/09/2024 03:06:40.334 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.335 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 933: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.335 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 952: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.336 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0
09/09/2024 03:06:40.336 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.336 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 955: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.345 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.346 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 851: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.347 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 853: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:40.348 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 946: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:40.349 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 918: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:40.890 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
09/09/2024 03:06:40.890 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.891 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 953: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.913 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0
09/09/2024 03:06:40.913 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.913 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 956: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.914 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
09/09/2024 03:06:40.914 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.914 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 853: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.914 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0
09/09/2024 03:06:40.915 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.915 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.915 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
09/09/2024 03:06:40.915 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.916 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 890: 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)])])
09/09/2024 03:06:40.916 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
09/09/2024 03:06:40.916 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.916 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.916 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
09/09/2024 03:06:40.917 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.917 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.917 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
09/09/2024 03:06:40.917 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.918 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 893: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.931 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0
09/09/2024 03:06:40.931 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.932 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 854: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.933 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0
09/09/2024 03:06:40.933 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.933 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 933: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.934 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0
09/09/2024 03:06:40.934 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.934 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 891: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.934 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0
09/09/2024 03:06:40.934 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.935 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 890: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.936 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
09/09/2024 03:06:40.936 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.936 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 953: 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)])])
09/09/2024 03:06:40.946 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0
09/09/2024 03:06:40.947 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.947 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.948 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 0
09/09/2024 03:06:40.948 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.948 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 852: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.948 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 0
09/09/2024 03:06:40.949 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.949 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 854: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:40.949 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
09/09/2024 03:06:40.950 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.950 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 947: 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)])])
09/09/2024 03:06:40.950 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 82
09/09/2024 03:06:40.950 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:40.951 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 919: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
09/09/2024 03:06:41.082 7fe4caf72148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 606: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=1895, message_set=['(offset=1892, message=214)', '(offset=1893, message=214)', '(offset=1894, message=214)', '(offset=None, message=None)'])])])
09/09/2024 03:06:41.082 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 1892 to buffered record list
09/09/2024 03:06:41.185 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 1895
09/09/2024 03:06:41.185 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:41.185 7fe4caf72148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 607: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=1895, max_bytes=1048576)])])
09/09/2024 03:06:41.494 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 929: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:41.582 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 886: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=448, message_set=['(offset=446, message=234)', '(offset=447, message=234)', '(offset=None, message=None)'])])])
09/09/2024 03:06:41.582 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 446 to buffered record list
09/09/2024 03:06:41.683 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 448
09/09/2024 03:06:41.683 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:41.684 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 887: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=448, max_bytes=1048576)])])
09/09/2024 03:06:41.697 7fe4cc959848 [kafka.producer.kafka] [DEBUG]: Sending (key=None value=b'live..') to TopicPartition(topic='HEALTH_CHECK_TOPIC', partition=4)
09/09/2024 03:06:41.698 7fe4cc959848 [kafka.producer.record_accumulator] [DEBUG]: Allocating a new 16384 byte message buffer for TopicPartition(topic='HEALTH_CHECK_TOPIC', partition=4)
09/09/2024 03:06:41.698 7fe4cc959848 [kafka.producer.kafka] [DEBUG]: Waking up the sender since TopicPartition(topic='HEALTH_CHECK_TOPIC', partition=4) is either full or getting a new batch
09/09/2024 03:06:41.698 7fe4cc959848 [kafka.producer.kafka] [DEBUG]: Flushing accumulated records in producer.
09/09/2024 03:06:41.698 7fe4cc959848 [kafka.producer.record_accumulator] [DEBUG]: Waiting on produce to TopicPartition(topic='HEALTH_CHECK_TOPIC', partition=4)
09/09/2024 03:06:41.699 7fe4cc0b5b48 [kafka.producer.sender] [DEBUG]: Nodes with data ready to send: {1}
09/09/2024 03:06:41.699 7fe4cc0b5b48 [kafka.producer.sender] [DEBUG]: Created 1 produce requests: {1: ProduceRequest_v2(required_acks=1, timeout=30000, topics=[(topic='HEALTH_CHECK_TOPIC', partitions=[(partition=4, messages=['(offset=0, message=28)'])])])}
09/09/2024 03:06:41.700 7fe4cc0b5b48 [kafka.producer.sender] [DEBUG]: Sending Produce Request: ProduceRequest_v2(required_acks=1, timeout=30000, topics=[(topic='HEALTH_CHECK_TOPIC', partitions=[(partition=4, messages=['(offset=0, message=28)'])])])
09/09/2024 03:06:41.700 7fe4cc0b5b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 30: ProduceRequest_v2(required_acks=1, timeout=30000, topics=[(topic='HEALTH_CHECK_TOPIC', partitions=[(4, <_io.BytesIO object at 0x7fe4cc085410>)])])
09/09/2024 03:06:41.701 7fe4cc0b5b48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 30: ProduceResponse_v2(topics=[(topic='HEALTH_CHECK_TOPIC', partitions=[(partition=4, error_code=0, offset=0, timestamp=-1)])], throttle_time_ms=0)
09/09/2024 03:06:41.702 7fe4cc0b5b48 [kafka.producer.sender] [DEBUG]: Parsing produce response: ProduceResponse_v2(topics=[(topic='HEALTH_CHECK_TOPIC', partitions=[(partition=4, error_code=0, offset=0, timestamp=-1)])], throttle_time_ms=0)
09/09/2024 03:06:41.702 7fe4cc0b5b48 [kafka.producer.record_accumulator] [DEBUG]: Produced messages to topic-partition TopicPartition(topic='HEALTH_CHECK_TOPIC', partition=4) with base offset 0 and error None.
09/09/2024 03:06:41.909 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 897: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=642, message_set=[])])])
09/09/2024 03:06:42.083 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 866: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:42.095 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0
09/09/2024 03:06:42.095 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:42.096 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 930: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:42.274 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 915: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=213, message_set=[])])])
09/09/2024 03:06:42.511 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 642
09/09/2024 03:06:42.511 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:42.512 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 898: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=642, max_bytes=1048576)])])
09/09/2024 03:06:42.684 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
09/09/2024 03:06:42.684 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:42.685 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 867: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:42.691 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 910: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:42.755 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 953: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:42.757 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 933: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:42.757 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 955: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:42.785 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 864: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=223, message_set=['(offset=222, message=208)', '(offset=None, message=None)'])])])
09/09/2024 03:06:42.785 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 222 to buffered record list
09/09/2024 03:06:42.875 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 213
09/09/2024 03:06:42.876 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:42.876 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 916: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=213, max_bytes=1048576)])])
09/09/2024 03:06:42.887 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 223
09/09/2024 03:06:42.887 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:42.888 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 865: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=223, max_bytes=1048576)])])
09/09/2024 03:06:42.899 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 895: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=1776, message_set=['(offset=1774, message=188)', '(offset=1775, message=215)', '(offset=None, message=None)'])])])
09/09/2024 03:06:42.900 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 1774 to buffered record list
09/09/2024 03:06:43.001 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1776
09/09/2024 03:06:43.001 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.002 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 896: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=1776, max_bytes=1048576)])])
09/09/2024 03:06:43.293 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 202
09/09/2024 03:06:43.294 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.294 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 911: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:43.300 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 953: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.326 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 956: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.327 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 853: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.328 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 932: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.328 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 890: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.329 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 932: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.329 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 932: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.330 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 893: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.357 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 854: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.358 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 933: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.358 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 891: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.359 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 890: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.360 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 953: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.360 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
09/09/2024 03:06:43.360 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.361 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 954: 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)])])
09/09/2024 03:06:43.361 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0
09/09/2024 03:06:43.362 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.362 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 934: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.362 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0
09/09/2024 03:06:43.363 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.363 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 956: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.378 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.379 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 852: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.379 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 854: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:43.380 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 947: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:43.381 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 919: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:43.901 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
09/09/2024 03:06:43.901 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.902 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 954: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.927 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0
09/09/2024 03:06:43.944 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.945 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 957: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.945 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
09/09/2024 03:06:43.946 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.946 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 854: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.946 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0
09/09/2024 03:06:43.946 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.947 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 933: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.947 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
09/09/2024 03:06:43.947 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.947 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 891: 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)])])
09/09/2024 03:06:43.948 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
09/09/2024 03:06:43.948 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.948 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 933: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.948 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
09/09/2024 03:06:43.949 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.949 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 933: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.949 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
09/09/2024 03:06:43.949 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.950 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 894: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.958 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0
09/09/2024 03:06:43.958 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.958 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 855: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.959 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0
09/09/2024 03:06:43.959 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.959 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 934: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.959 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0
09/09/2024 03:06:43.960 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.960 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 892: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.960 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0
09/09/2024 03:06:43.960 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.961 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 891: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.961 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
09/09/2024 03:06:43.961 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.961 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 954: 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)])])
09/09/2024 03:06:43.981 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0
09/09/2024 03:06:43.981 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.981 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.982 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 0
09/09/2024 03:06:43.982 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.983 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 853: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.983 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 0
09/09/2024 03:06:43.983 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.983 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 855: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:43.984 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
09/09/2024 03:06:43.984 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.984 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 948: 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)])])
09/09/2024 03:06:43.984 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 82
09/09/2024 03:06:43.984 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:43.985 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 920: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
09/09/2024 03:06:44.091 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 887: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=448, message_set=[])])])
09/09/2024 03:06:44.502 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 930: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:44.692 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 448
09/09/2024 03:06:44.692 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:44.693 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 888: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=448, max_bytes=1048576)])])
09/09/2024 03:06:44.918 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 898: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=642, message_set=[])])])
09/09/2024 03:06:45.092 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 867: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:45.103 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0
09/09/2024 03:06:45.103 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:45.104 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 931: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:45.285 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 916: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=213, message_set=[])])])
09/09/2024 03:06:45.294 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 865: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=223, message_set=[])])])
09/09/2024 03:06:45.397 7fe4caf72148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 607: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=1900, message_set=['(offset=1895, message=203)', '(offset=1896, message=214)', '(offset=1897, message=235)', '(offset=1898, message=214)', '(offset=1899, message=218)', '(offset=None, message=None)'])])])
09/09/2024 03:06:45.397 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 1895 to buffered record list
09/09/2024 03:06:45.409 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 896: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=1776, message_set=[])])])
09/09/2024 03:06:45.500 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 1900
09/09/2024 03:06:45.500 7fe4caf72148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:45.501 7fe4caf72148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 608: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=1900, max_bytes=1048576)])])
09/09/2024 03:06:45.520 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 642
09/09/2024 03:06:45.521 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:45.521 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 899: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=642, max_bytes=1048576)])])
09/09/2024 03:06:45.698 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
09/09/2024 03:06:45.699 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:45.700 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 868: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:45.701 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 911: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:45.767 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 954: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:45.768 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 934: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:45.769 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 956: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:45.887 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 213
09/09/2024 03:06:45.887 7fe4c83aad48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:45.888 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 917: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=213, max_bytes=1048576)])])
09/09/2024 03:06:45.896 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 223
09/09/2024 03:06:45.897 7fe4c83aa848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:45.897 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 866: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=223, max_bytes=1048576)])])
09/09/2024 03:06:46.011 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1776
09/09/2024 03:06:46.011 7fe4c83aa148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.013 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 897: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=1776, max_bytes=1048576)])])
09/09/2024 03:06:46.302 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 202
09/09/2024 03:06:46.302 7fe4c82ea048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.303 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 912: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:46.307 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 954: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.359 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 957: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.359 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 854: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.360 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 933: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.361 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 891: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.362 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 933: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.362 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 933: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.363 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 894: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.369 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0
09/09/2024 03:06:46.369 7fe4c83aa048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.370 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 955: 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)])])
09/09/2024 03:06:46.370 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 855: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.371 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 934: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.372 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 892: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.372 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 891: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.373 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0
09/09/2024 03:06:46.373 7fe4cb026e48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.374 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 935: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.374 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 0
09/09/2024 03:06:46.375 7fe4c83aa548 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.375 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 957: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.376 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 954: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.396 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 932: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.397 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 853: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.398 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 855: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:46.398 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 948: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:46.399 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 920: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=82, message_set=[])])])
09/09/2024 03:06:46.907 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 0
09/09/2024 03:06:46.908 7fe4c83aa348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.908 7fe4c83aa348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 955: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.959 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0
09/09/2024 03:06:46.960 7fe4c83aa648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.960 7fe4c83aa648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 958: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.960 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0
09/09/2024 03:06:46.961 7fe4caf72648 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.961 7fe4caf72648 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 855: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.961 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 0
09/09/2024 03:06:46.961 7fe4caf72048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.962 7fe4caf72048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 934: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.962 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
09/09/2024 03:06:46.962 7fe4cacffd48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.962 7fe4cacffd48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 892: 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)])])
09/09/2024 03:06:46.963 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0
09/09/2024 03:06:46.963 7fe4caf72348 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.963 7fe4caf72348 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 934: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.963 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
09/09/2024 03:06:46.964 7fe4cacffe48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.964 7fe4cacffe48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 934: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.964 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
09/09/2024 03:06:46.964 7fe4cb026948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.965 7fe4cb026948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 895: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.971 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0
09/09/2024 03:06:46.972 7fe4caf72248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.972 7fe4caf72248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 856: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.972 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 0
09/09/2024 03:06:46.972 7fe4c83aa448 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.973 7fe4c83aa448 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 935: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.974 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0
09/09/2024 03:06:46.974 7fe4cb026248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.975 7fe4cb026248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 893: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.975 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 0
09/09/2024 03:06:46.975 7fe4c83aa248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.975 7fe4c83aa248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 892: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.976 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
09/09/2024 03:06:46.977 7fe4cb026848 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.977 7fe4cb026848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 955: 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)])])
09/09/2024 03:06:46.997 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 0
09/09/2024 03:06:46.998 7fe4caf72c48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.998 7fe4caf72c48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 933: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.998 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 0
09/09/2024 03:06:46.998 7fe4c83aae48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.999 7fe4c83aae48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 854: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:46.999 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 0
09/09/2024 03:06:46.999 7fe4c82ea148 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:46.999 7fe4c82ea148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 856: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:47.000 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 82
09/09/2024 03:06:47.000 7fe4c83aa748 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:47.000 7fe4c83aa748 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 949: 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)])])
09/09/2024 03:06:47.001 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 82
09/09/2024 03:06:47.001 7fe4c83aa948 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:47.001 7fe4c83aa948 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 921: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=82, max_bytes=1048576)])])
09/09/2024 03:06:47.103 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 888: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=448, message_set=[])])])
09/09/2024 03:06:47.509 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 931: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:47.704 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 448
09/09/2024 03:06:47.705 7fe4c83aaa48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:47.706 7fe4c83aaa48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 889: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=448, max_bytes=1048576)])])
09/09/2024 03:06:47.927 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 899: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=642, message_set=[])])])
09/09/2024 03:06:48.107 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 868: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:48.110 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 0
09/09/2024 03:06:48.110 7fe4c83aab48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:48.111 7fe4c83aab48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 932: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=0, max_bytes=1048576)])])
09/09/2024 03:06:48.295 7fe4c83aad48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 917: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=213, message_set=[])])])
09/09/2024 03:06:48.309 7fe4c83aa848 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 866: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=223, message_set=[])])])
09/09/2024 03:06:48.421 7fe4c83aa148 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 897: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=1776, message_set=[])])])
09/09/2024 03:06:48.530 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 642
09/09/2024 03:06:48.531 7fe4c82ea248 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:48.532 7fe4c82ea248 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 900: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=642, max_bytes=1048576)])])
09/09/2024 03:06:48.709 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 202
09/09/2024 03:06:48.709 7fe4c83aac48 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
09/09/2024 03:06:48.710 7fe4c83aac48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Request 869: FetchRequest_v3(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=202, max_bytes=1048576)])])
09/09/2024 03:06:48.711 7fe4c82ea048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 912: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=202, message_set=[])])])
09/09/2024 03:06:48.782 7fe4c83aa048 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 955: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:48.785 7fe4cb026e48 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 935: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])
09/09/2024 03:06:48.787 7fe4c83aa548 [kafka.conn] [DEBUG]: <BrokerConnection node_id=1 host=10.0.0.55/10.0.0.55 port=9092> Response 957: FetchResponse_v3(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=0, message_set=[])])])