12/26/2024 02:14:45.018 7f3b58372390 [kafka.conn] [DEBUG]: Response 312 (601.9847393035889 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=160, last_stable_offset=160, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.018 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 12/26/2024 02:14:45.019 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.019 7f3b609b7cc0 [kafka.conn] [DEBUG]: Response 289 (602.2868156433105 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.063 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 171 12/26/2024 02:14:45.064 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.064 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:45.064 7f3b583720f0 [kafka.conn] [DEBUG]: Request 302: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:45.065 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 12/26/2024 02:14:45.065 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.065 7f3b609bccc0 [kafka.conn] [DEBUG]: Response 289 (601.9537448883057 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=48, last_stable_offset=48, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.067 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 12/26/2024 02:14:45.067 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.068 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:45.068 7f3b609bcb70 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:45.068 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 38 12/26/2024 02:14:45.069 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.069 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:45.069 7f3b609bc978 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:45.069 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 89 12/26/2024 02:14:45.069 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.070 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:45.070 7f3b5836eb70 [kafka.conn] [DEBUG]: Request 305: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:45.131 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 452 12/26/2024 02:14:45.131 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.131 7f3b60899390 [kafka.conn] [DEBUG]: Response 452 (601.5121936798096 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4060, last_stable_offset=4060, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.170 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 12/26/2024 02:14:45.170 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.170 7f3b5836e8d0 [kafka.conn] [DEBUG]: Response 303 (601.9363403320312 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, last_stable_offset=135, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.243 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 324 12/26/2024 02:14:45.244 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.244 7f3b37f446d8 [kafka.conn] [DEBUG]: Response 324 (601.2716293334961 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=276, last_stable_offset=276, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.264 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/26/2024 02:14:45.265 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.265 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.265 7f3b609b4588 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.270 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 12/26/2024 02:14:45.270 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.270 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:45.271 7f3b609bc048 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:45.271 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5 12/26/2024 02:14:45.271 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.271 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:45.272 7f3b60947240 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:45.363 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 12/26/2024 02:14:45.363 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.364 7f3b60899d68 [kafka.conn] [DEBUG]: Response 277 (601.963996887207 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.364 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/26/2024 02:14:45.364 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.364 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.365 7f3b6089d978 [kafka.conn] [DEBUG]: Request 277: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.365 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 12/26/2024 02:14:45.365 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.365 7f3b609b7048 [kafka.conn] [DEBUG]: Response 277 (602.8251647949219 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.450 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 12/26/2024 02:14:45.450 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.450 7f3b609a9828 [kafka.conn] [DEBUG]: Response 278 (602.3032665252686 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.451 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:45.451 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.452 7f3b6089df60 [kafka.conn] [DEBUG]: Response 279 (603.0693054199219 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.453 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 12/26/2024 02:14:45.453 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.453 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:45.453 7f3b60947390 [kafka.conn] [DEBUG]: Request 284: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:45.454 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 12/26/2024 02:14:45.454 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.454 7f3b609bc588 [kafka.conn] [DEBUG]: Response 295 (603.6627292633057 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=55, last_stable_offset=55, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.525 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 297 12/26/2024 02:14:45.525 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.525 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:45.526 7f3b58419cc0 [kafka.conn] [DEBUG]: Request 325: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:45.528 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 12/26/2024 02:14:45.529 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.529 7f3b60905f60 [kafka.conn] [DEBUG]: Response 303 (601.1466979980469 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=132, last_stable_offset=132, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.532 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 12/26/2024 02:14:45.532 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.532 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:45.532 7f3b608da0f0 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:45.533 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:45.533 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.533 7f3b6089d828 [kafka.conn] [DEBUG]: Response 280 (600.8353233337402 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.534 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 38 12/26/2024 02:14:45.534 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.534 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:45.534 7f3b609b78d0 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:45.548 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 248 12/26/2024 02:14:45.549 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.549 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:45.549 7f3b37fcd780 [kafka.conn] [DEBUG]: Request 308: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:45.550 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 12/26/2024 02:14:45.550 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.550 7f3b6089dcc0 [kafka.conn] [DEBUG]: Response 292 (601.3126373291016 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.569 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 12/26/2024 02:14:45.569 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.569 7f3b609b7588 [kafka.conn] [DEBUG]: Response 286 (602.224588394165 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.598 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 166 12/26/2024 02:14:45.598 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.598 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:45.599 7f3b58419d68 [kafka.conn] [DEBUG]: Request 308: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:45.616 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 310 12/26/2024 02:14:45.616 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.617 7f3b5836ee10 [kafka.conn] [DEBUG]: Response 310 (601.6457080841064 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.618 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 12/26/2024 02:14:45.619 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.619 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:45.619 7f3b58372390 [kafka.conn] [DEBUG]: Request 313: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:45.620 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 38 12/26/2024 02:14:45.620 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.620 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:45.620 7f3b609b7cc0 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:45.665 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 302 12/26/2024 02:14:45.665 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.665 7f3b583720f0 [kafka.conn] [DEBUG]: Response 302 (601.6254425048828 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.666 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 12/26/2024 02:14:45.666 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.666 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:45.667 7f3b609bccc0 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:45.670 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 12/26/2024 02:14:45.670 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.670 7f3b609bcb70 [kafka.conn] [DEBUG]: Response 287 (602.1885871887207 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.671 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 12/26/2024 02:14:45.671 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.671 7f3b609bc978 [kafka.conn] [DEBUG]: Response 287 (602.4894714355469 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.672 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 305 12/26/2024 02:14:45.672 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.672 7f3b5836eb70 [kafka.conn] [DEBUG]: Response 305 (602.5941371917725 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=89, last_stable_offset=89, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.739 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4060 12/26/2024 02:14:45.740 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.740 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4060, max_bytes=1048576)])]) 12/26/2024 02:14:45.740 7f3b60899390 [kafka.conn] [DEBUG]: Request 453: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4060, max_bytes=1048576)])]) 12/26/2024 02:14:45.772 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135 12/26/2024 02:14:45.773 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.773 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:45.773 7f3b5836e8d0 [kafka.conn] [DEBUG]: Request 304: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:45.844 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 276 12/26/2024 02:14:45.845 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.845 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:45.845 7f3b37f446d8 [kafka.conn] [DEBUG]: Request 325: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:45.866 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 12/26/2024 02:14:45.866 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.867 7f3b609b4588 [kafka.conn] [DEBUG]: Response 278 (601.5000343322754 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.873 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:45.873 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.873 7f3b609bc048 [kafka.conn] [DEBUG]: Response 281 (602.6144027709961 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.874 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:45.874 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.874 7f3b60947240 [kafka.conn] [DEBUG]: Response 279 (602.2887229919434 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:45.964 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/26/2024 02:14:45.964 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.965 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.965 7f3b60899d68 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.966 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/26/2024 02:14:45.966 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:45.966 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.966 7f3b609b7048 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:45.966 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 12/26/2024 02:14:45.966 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:45.967 7f3b6089d978 [kafka.conn] [DEBUG]: Response 277 (602.1838188171387 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.051 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 12/26/2024 02:14:46.051 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.051 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:46.051 7f3b609a9828 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:46.053 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 12/26/2024 02:14:46.053 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.053 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:46.053 7f3b6089df60 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:46.054 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 55 12/26/2024 02:14:46.054 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.054 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:46.055 7f3b609bc588 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:46.055 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 12/26/2024 02:14:46.055 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.055 7f3b60947390 [kafka.conn] [DEBUG]: Response 284 (602.2276878356934 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.126 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 325 12/26/2024 02:14:46.127 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.127 7f3b58419cc0 [kafka.conn] [DEBUG]: Response 325 (601.2876033782959 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=297, last_stable_offset=297, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.129 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 12/26/2024 02:14:46.129 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.129 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:46.130 7f3b60905f60 [kafka.conn] [DEBUG]: Request 304: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:46.133 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 12/26/2024 02:14:46.133 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.133 7f3b608da0f0 [kafka.conn] [DEBUG]: Response 278 (601.0868549346924 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.134 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 4 12/26/2024 02:14:46.134 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.134 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:46.134 7f3b6089d828 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:46.135 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 12/26/2024 02:14:46.135 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.136 7f3b609b78d0 [kafka.conn] [DEBUG]: Response 288 (601.3402938842773 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.150 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 308 12/26/2024 02:14:46.150 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.150 7f3b37fcd780 [kafka.conn] [DEBUG]: Response 308 (601.3362407684326 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=248, last_stable_offset=248, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.151 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 12/26/2024 02:14:46.151 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.151 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:46.151 7f3b6089dcc0 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:46.170 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 35 12/26/2024 02:14:46.170 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.170 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:46.170 7f3b609b7588 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:46.200 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 308 12/26/2024 02:14:46.200 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.200 7f3b58419d68 [kafka.conn] [DEBUG]: Response 308 (601.778507232666 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.218 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 188 12/26/2024 02:14:46.218 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.219 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:46.219 7f3b5836ee10 [kafka.conn] [DEBUG]: Request 311: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:46.224 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 313 12/26/2024 02:14:46.224 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.224 7f3b58372390 [kafka.conn] [DEBUG]: Response 313 (604.9010753631592 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=160, last_stable_offset=160, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.225 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 12/26/2024 02:14:46.225 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.225 7f3b609b7cc0 [kafka.conn] [DEBUG]: Response 290 (604.8650741577148 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.266 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 171 12/26/2024 02:14:46.266 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.267 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:46.267 7f3b583720f0 [kafka.conn] [DEBUG]: Request 303: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:46.268 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 12/26/2024 02:14:46.268 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.268 7f3b609bccc0 [kafka.conn] [DEBUG]: Response 290 (601.2992858886719 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=48, last_stable_offset=48, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.270 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 12/26/2024 02:14:46.271 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.271 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:46.271 7f3b609bcb70 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:46.272 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 38 12/26/2024 02:14:46.272 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.272 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:46.273 7f3b609bc978 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:46.273 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 89 12/26/2024 02:14:46.274 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.274 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:46.274 7f3b5836eb70 [kafka.conn] [DEBUG]: Request 306: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:46.341 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 453 12/26/2024 02:14:46.341 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.341 7f3b60899390 [kafka.conn] [DEBUG]: Response 453 (601.311445236206 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4061, last_stable_offset=4061, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xdc\x00\x00\x01\x04\x00\x00\x00\x00\x028r*\x92\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 12/26/2024 02:14:46.341 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4060 to buffered record list 12/26/2024 02:14:46.374 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 12/26/2024 02:14:46.374 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.374 7f3b5836e8d0 [kafka.conn] [DEBUG]: Response 304 (601.3147830963135 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, last_stable_offset=135, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.442 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4061 12/26/2024 02:14:46.442 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.442 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4061, max_bytes=1048576)])]) 12/26/2024 02:14:46.443 7f3b60899390 [kafka.conn] [DEBUG]: Request 454: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4061, max_bytes=1048576)])]) 12/26/2024 02:14:46.446 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 325 12/26/2024 02:14:46.446 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.446 7f3b37f446d8 [kafka.conn] [DEBUG]: Response 325 (601.081371307373 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=276, last_stable_offset=276, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.467 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/26/2024 02:14:46.467 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.468 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:46.468 7f3b609b4588 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:46.474 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 12/26/2024 02:14:46.474 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.474 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:46.474 7f3b609bc048 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:46.475 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5 12/26/2024 02:14:46.475 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.475 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:46.475 7f3b60947240 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:46.566 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 12/26/2024 02:14:46.566 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.566 7f3b60899d68 [kafka.conn] [DEBUG]: Response 278 (601.5253067016602 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.567 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 12/26/2024 02:14:46.567 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.567 7f3b609b7048 [kafka.conn] [DEBUG]: Response 278 (601.2451648712158 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.567 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/26/2024 02:14:46.568 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.568 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:46.568 7f3b6089d978 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:46.652 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:46.652 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.652 7f3b609a9828 [kafka.conn] [DEBUG]: Response 279 (601.2344360351562 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.654 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:46.654 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.654 7f3b6089df60 [kafka.conn] [DEBUG]: Response 280 (600.916862487793 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.655 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 12/26/2024 02:14:46.655 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.656 7f3b609bc588 [kafka.conn] [DEBUG]: Response 296 (600.9347438812256 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=55, last_stable_offset=55, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.656 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 12/26/2024 02:14:46.656 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.656 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:46.657 7f3b60947390 [kafka.conn] [DEBUG]: Request 285: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:46.727 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 297 12/26/2024 02:14:46.728 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.728 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:46.728 7f3b58419cc0 [kafka.conn] [DEBUG]: Request 326: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:46.731 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 12/26/2024 02:14:46.731 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.731 7f3b60905f60 [kafka.conn] [DEBUG]: Response 304 (601.0279655456543 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=132, last_stable_offset=132, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.734 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 12/26/2024 02:14:46.734 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.734 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:46.734 7f3b608da0f0 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:46.735 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:46.735 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.735 7f3b6089d828 [kafka.conn] [DEBUG]: Response 281 (601.2167930603027 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.736 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 38 12/26/2024 02:14:46.736 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.736 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:46.737 7f3b609b78d0 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:46.752 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 248 12/26/2024 02:14:46.752 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.752 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:46.752 7f3b37fcd780 [kafka.conn] [DEBUG]: Request 309: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:46.753 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 12/26/2024 02:14:46.753 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.753 7f3b6089dcc0 [kafka.conn] [DEBUG]: Response 293 (602.3268699645996 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.772 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 12/26/2024 02:14:46.772 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.772 7f3b609b7588 [kafka.conn] [DEBUG]: Response 287 (602.0100116729736 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.801 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 166 12/26/2024 02:14:46.801 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.801 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:46.802 7f3b58419d68 [kafka.conn] [DEBUG]: Request 309: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:46.820 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 311 12/26/2024 02:14:46.820 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.820 7f3b5836ee10 [kafka.conn] [DEBUG]: Response 311 (601.2537479400635 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.825 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 12/26/2024 02:14:46.825 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.825 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:46.825 7f3b58372390 [kafka.conn] [DEBUG]: Request 314: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:46.825 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 38 12/26/2024 02:14:46.826 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.826 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:46.826 7f3b609b7cc0 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:46.868 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 12/26/2024 02:14:46.868 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.868 7f3b583720f0 [kafka.conn] [DEBUG]: Response 303 (601.5071868896484 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.869 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 12/26/2024 02:14:46.869 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.869 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:46.869 7f3b609bccc0 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:46.872 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 12/26/2024 02:14:46.872 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.872 7f3b609bcb70 [kafka.conn] [DEBUG]: Response 288 (601.0382175445557 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.873 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 12/26/2024 02:14:46.873 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.874 7f3b609bc978 [kafka.conn] [DEBUG]: Response 288 (601.0544300079346 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.875 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 12/26/2024 02:14:46.875 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:46.875 7f3b5836eb70 [kafka.conn] [DEBUG]: Response 306 (601.3555526733398 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=89, last_stable_offset=89, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:46.976 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135 12/26/2024 02:14:46.976 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:46.976 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:46.976 7f3b5836e8d0 [kafka.conn] [DEBUG]: Request 305: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:47.048 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454 12/26/2024 02:14:47.048 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.048 7f3b60899390 [kafka.conn] [DEBUG]: Response 454 (605.4568290710449 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4062, last_stable_offset=4062, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xdd\x00\x00\x01\x02\x00\x00\x00\x00\x02Y\xc4\xce(\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9e\x03\x00\x00\x00\xe0\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 12/26/2024 02:14:47.048 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4061 to buffered record list 12/26/2024 02:14:47.049 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 276 12/26/2024 02:14:47.049 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.049 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:47.049 7f3b37f446d8 [kafka.conn] [DEBUG]: Request 326: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:47.069 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:47.069 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.069 7f3b609b4588 [kafka.conn] [DEBUG]: Response 279 (601.3748645782471 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.076 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:47.076 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.077 7f3b609bc048 [kafka.conn] [DEBUG]: Response 282 (602.3836135864258 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.077 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:47.077 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.077 7f3b60947240 [kafka.conn] [DEBUG]: Response 280 (602.3759841918945 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.149 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4062 12/26/2024 02:14:47.149 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.149 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4062, max_bytes=1048576)])]) 12/26/2024 02:14:47.150 7f3b60899390 [kafka.conn] [DEBUG]: Request 455: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4062, max_bytes=1048576)])]) 12/26/2024 02:14:47.151 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 12/26/2024 02:14:47.151 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.151 7f3b60899390 [kafka.conn] [DEBUG]: Response 455 (1.1570453643798828 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4063, last_stable_offset=4063, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xde\x00\x00\x01\x04\x00\x00\x00\x00\x02#E\x96\xe1\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 12/26/2024 02:14:47.151 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4062 to buffered record list 12/26/2024 02:14:47.167 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/26/2024 02:14:47.167 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.167 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.168 7f3b60899d68 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.168 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/26/2024 02:14:47.168 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.168 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.169 7f3b609b7048 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.170 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 12/26/2024 02:14:47.170 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.170 7f3b6089d978 [kafka.conn] [DEBUG]: Response 278 (602.1018028259277 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.252 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4063 12/26/2024 02:14:47.252 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.252 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4063, max_bytes=1048576)])]) 12/26/2024 02:14:47.253 7f3b60899390 [kafka.conn] [DEBUG]: Request 456: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4063, max_bytes=1048576)])]) 12/26/2024 02:14:47.254 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 12/26/2024 02:14:47.254 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.254 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:47.254 7f3b609a9828 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:47.255 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 12/26/2024 02:14:47.255 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.255 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:47.255 7f3b6089df60 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:47.256 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 55 12/26/2024 02:14:47.256 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.256 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:47.256 7f3b609bc588 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:47.257 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 12/26/2024 02:14:47.257 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.257 7f3b60947390 [kafka.conn] [DEBUG]: Response 285 (600.7945537567139 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.329 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 326 12/26/2024 02:14:47.329 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.329 7f3b58419cc0 [kafka.conn] [DEBUG]: Response 326 (601.1943817138672 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=297, last_stable_offset=297, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.331 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 12/26/2024 02:14:47.331 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.332 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:47.332 7f3b60905f60 [kafka.conn] [DEBUG]: Request 305: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:47.335 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:47.335 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.336 7f3b608da0f0 [kafka.conn] [DEBUG]: Response 279 (601.2673377990723 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.336 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 4 12/26/2024 02:14:47.336 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.336 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:47.337 7f3b6089d828 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:47.337 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 12/26/2024 02:14:47.337 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.338 7f3b609b78d0 [kafka.conn] [DEBUG]: Response 289 (601.0589599609375 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.353 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 309 12/26/2024 02:14:47.354 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.354 7f3b37fcd780 [kafka.conn] [DEBUG]: Response 309 (601.3808250427246 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=248, last_stable_offset=248, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.354 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 12/26/2024 02:14:47.354 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.354 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:47.355 7f3b6089dcc0 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:47.373 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 35 12/26/2024 02:14:47.373 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.373 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:47.374 7f3b609b7588 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:47.403 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 309 12/26/2024 02:14:47.403 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.403 7f3b58419d68 [kafka.conn] [DEBUG]: Response 309 (601.3092994689941 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.421 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 188 12/26/2024 02:14:47.421 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.421 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:47.421 7f3b5836ee10 [kafka.conn] [DEBUG]: Request 312: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:47.426 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 314 12/26/2024 02:14:47.427 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.427 7f3b58372390 [kafka.conn] [DEBUG]: Response 314 (601.6545295715332 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=160, last_stable_offset=160, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.427 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 12/26/2024 02:14:47.427 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.427 7f3b609b7cc0 [kafka.conn] [DEBUG]: Response 291 (601.6623973846436 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.469 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 171 12/26/2024 02:14:47.469 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.469 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:47.470 7f3b583720f0 [kafka.conn] [DEBUG]: Request 304: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:47.470 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 12/26/2024 02:14:47.470 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.471 7f3b609bccc0 [kafka.conn] [DEBUG]: Response 291 (601.6147136688232 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=48, last_stable_offset=48, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.473 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 12/26/2024 02:14:47.473 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.473 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:47.474 7f3b609bcb70 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:47.474 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 38 12/26/2024 02:14:47.474 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.474 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:47.475 7f3b609bc978 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:47.477 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 89 12/26/2024 02:14:47.477 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.477 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:47.477 7f3b5836eb70 [kafka.conn] [DEBUG]: Request 307: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:47.577 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 305 12/26/2024 02:14:47.578 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.578 7f3b5836e8d0 [kafka.conn] [DEBUG]: Response 305 (601.5679836273193 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, last_stable_offset=135, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.651 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 326 12/26/2024 02:14:47.651 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.651 7f3b37f446d8 [kafka.conn] [DEBUG]: Response 326 (602.0739078521729 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=276, last_stable_offset=276, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.671 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/26/2024 02:14:47.671 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.671 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.672 7f3b609b4588 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.677 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 12/26/2024 02:14:47.677 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.677 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:47.678 7f3b609bc048 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:47.678 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5 12/26/2024 02:14:47.678 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.678 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:47.679 7f3b60947240 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:47.771 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:47.772 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.772 7f3b60899d68 [kafka.conn] [DEBUG]: Response 279 (604.2129993438721 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.775 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/26/2024 02:14:47.776 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.777 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.779 7f3b6089d978 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:47.782 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:47.783 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.784 7f3b609b7048 [kafka.conn] [DEBUG]: Response 279 (614.9592399597168 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.855 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 12/26/2024 02:14:47.856 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.856 7f3b60899390 [kafka.conn] [DEBUG]: Response 456 (603.6503314971924 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4063, last_stable_offset=4063, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.860 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 12/26/2024 02:14:47.861 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.862 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:47.864 7f3b60947390 [kafka.conn] [DEBUG]: Request 286: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:47.866 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:47.866 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.868 7f3b609a9828 [kafka.conn] [DEBUG]: Response 280 (613.2261753082275 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.871 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:47.871 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.872 7f3b6089df60 [kafka.conn] [DEBUG]: Response 281 (617.1798706054688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.875 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 12/26/2024 02:14:47.876 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.877 7f3b609bc588 [kafka.conn] [DEBUG]: Response 297 (620.4187870025635 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=55, last_stable_offset=55, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.930 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 297 12/26/2024 02:14:47.931 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.932 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:47.934 7f3b58419cc0 [kafka.conn] [DEBUG]: Request 327: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:47.935 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 305 12/26/2024 02:14:47.935 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.935 7f3b60905f60 [kafka.conn] [DEBUG]: Response 305 (603.553056716919 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=132, last_stable_offset=132, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.936 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 12/26/2024 02:14:47.936 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.936 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:47.937 7f3b608da0f0 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:47.937 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:47.937 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.938 7f3b6089d828 [kafka.conn] [DEBUG]: Response 282 (601.0894775390625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.938 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 38 12/26/2024 02:14:47.938 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.938 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:47.939 7f3b609b78d0 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:47.954 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 248 12/26/2024 02:14:47.954 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:47.955 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:47.955 7f3b37fcd780 [kafka.conn] [DEBUG]: Request 310: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:47.956 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 12/26/2024 02:14:47.956 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.956 7f3b6089dcc0 [kafka.conn] [DEBUG]: Response 294 (601.5915870666504 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:47.974 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 12/26/2024 02:14:47.974 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:47.975 7f3b609b7588 [kafka.conn] [DEBUG]: Response 288 (601.1018753051758 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.004 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 166 12/26/2024 02:14:48.004 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.004 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:48.004 7f3b58419d68 [kafka.conn] [DEBUG]: Request 310: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:48.022 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 312 12/26/2024 02:14:48.023 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.023 7f3b5836ee10 [kafka.conn] [DEBUG]: Response 312 (601.4211177825928 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.027 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 12/26/2024 02:14:48.027 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.027 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:48.028 7f3b58372390 [kafka.conn] [DEBUG]: Request 315: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:48.028 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 38 12/26/2024 02:14:48.028 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.028 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:48.028 7f3b609b7cc0 [kafka.conn] [DEBUG]: Request 292: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:48.071 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 12/26/2024 02:14:48.071 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.071 7f3b583720f0 [kafka.conn] [DEBUG]: Response 304 (601.5048027038574 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.071 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 12/26/2024 02:14:48.072 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.072 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:48.072 7f3b609bccc0 [kafka.conn] [DEBUG]: Request 292: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:48.074 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 12/26/2024 02:14:48.075 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.075 7f3b609bcb70 [kafka.conn] [DEBUG]: Response 289 (601.1538505554199 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.075 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 12/26/2024 02:14:48.075 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.075 7f3b609bc978 [kafka.conn] [DEBUG]: Response 289 (600.8262634277344 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.078 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 12/26/2024 02:14:48.078 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.079 7f3b5836eb70 [kafka.conn] [DEBUG]: Response 307 (601.6359329223633 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=89, last_stable_offset=89, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.179 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135 12/26/2024 02:14:48.179 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.179 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:48.180 7f3b5836e8d0 [kafka.conn] [DEBUG]: Request 306: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:48.252 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 276 12/26/2024 02:14:48.253 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.253 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:48.253 7f3b37f446d8 [kafka.conn] [DEBUG]: Request 327: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:48.282 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:48.282 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.282 7f3b609b4588 [kafka.conn] [DEBUG]: Response 280 (610.482931137085 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.287 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 12/26/2024 02:14:48.287 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.287 7f3b609bc048 [kafka.conn] [DEBUG]: Response 283 (609.2426776885986 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.287 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:48.288 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.288 7f3b60947240 [kafka.conn] [DEBUG]: Response 281 (609.097957611084 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.380 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/26/2024 02:14:48.380 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.380 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.381 7f3b60899d68 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.386 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/26/2024 02:14:48.387 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.387 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.387 7f3b609b7048 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.388 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 12/26/2024 02:14:48.388 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.388 7f3b6089d978 [kafka.conn] [DEBUG]: Response 279 (609.8556518554688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.459 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4063 12/26/2024 02:14:48.459 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.459 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4063, max_bytes=1048576)])]) 12/26/2024 02:14:48.459 7f3b60899390 [kafka.conn] [DEBUG]: Request 457: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4063, max_bytes=1048576)])]) 12/26/2024 02:14:48.470 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 12/26/2024 02:14:48.470 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.470 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:48.471 7f3b609a9828 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:48.475 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 12/26/2024 02:14:48.476 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.476 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:48.476 7f3b6089df60 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:48.479 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 55 12/26/2024 02:14:48.480 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.480 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:48.480 7f3b609bc588 [kafka.conn] [DEBUG]: Request 298: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:48.481 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 12/26/2024 02:14:48.481 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.481 7f3b60947390 [kafka.conn] [DEBUG]: Response 286 (618.1533336639404 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.536 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 327 12/26/2024 02:14:48.536 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.536 7f3b58419cc0 [kafka.conn] [DEBUG]: Response 327 (602.6561260223389 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=297, last_stable_offset=297, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.536 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 12/26/2024 02:14:48.536 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.537 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:48.537 7f3b60905f60 [kafka.conn] [DEBUG]: Request 306: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:48.538 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:48.538 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.538 7f3b608da0f0 [kafka.conn] [DEBUG]: Response 280 (601.3307571411133 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.538 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 4 12/26/2024 02:14:48.538 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.538 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:48.539 7f3b6089d828 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:48.541 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 12/26/2024 02:14:48.541 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.541 7f3b609b78d0 [kafka.conn] [DEBUG]: Response 290 (602.4429798126221 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.556 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 310 12/26/2024 02:14:48.556 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.556 7f3b37fcd780 [kafka.conn] [DEBUG]: Response 310 (601.5000343322754 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=248, last_stable_offset=248, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.557 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 12/26/2024 02:14:48.557 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.557 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:48.557 7f3b6089dcc0 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:48.575 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 35 12/26/2024 02:14:48.575 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.576 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:48.576 7f3b609b7588 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:48.606 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 310 12/26/2024 02:14:48.606 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.606 7f3b58419d68 [kafka.conn] [DEBUG]: Response 310 (601.7289161682129 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.624 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 188 12/26/2024 02:14:48.624 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.624 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:48.624 7f3b5836ee10 [kafka.conn] [DEBUG]: Request 313: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:48.630 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 315 12/26/2024 02:14:48.630 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.630 7f3b58372390 [kafka.conn] [DEBUG]: Response 315 (602.5893688201904 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=160, last_stable_offset=160, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.631 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 12/26/2024 02:14:48.631 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.631 7f3b609b7cc0 [kafka.conn] [DEBUG]: Response 292 (602.6597023010254 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.672 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 171 12/26/2024 02:14:48.672 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.672 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:48.673 7f3b583720f0 [kafka.conn] [DEBUG]: Request 305: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:48.673 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 12/26/2024 02:14:48.673 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.674 7f3b609bccc0 [kafka.conn] [DEBUG]: Response 292 (601.6275882720947 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=48, last_stable_offset=48, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.675 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 12/26/2024 02:14:48.675 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.675 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:48.676 7f3b609bcb70 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:48.676 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 38 12/26/2024 02:14:48.676 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.676 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:48.676 7f3b609bc978 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:48.679 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 89 12/26/2024 02:14:48.679 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.679 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:48.679 7f3b5836eb70 [kafka.conn] [DEBUG]: Request 308: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:48.781 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 12/26/2024 02:14:48.781 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.781 7f3b5836e8d0 [kafka.conn] [DEBUG]: Response 306 (601.4080047607422 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, last_stable_offset=135, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.854 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 327 12/26/2024 02:14:48.854 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.854 7f3b37f446d8 [kafka.conn] [DEBUG]: Response 327 (601.5064716339111 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=276, last_stable_offset=276, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.883 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/26/2024 02:14:48.883 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.883 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.883 7f3b609b4588 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.887 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 12/26/2024 02:14:48.888 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.888 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:48.888 7f3b609bc048 [kafka.conn] [DEBUG]: Request 284: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:48.888 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5 12/26/2024 02:14:48.888 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.888 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:48.889 7f3b60947240 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:48.982 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:48.982 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.983 7f3b60899d68 [kafka.conn] [DEBUG]: Response 280 (602.0886898040771 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.988 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:48.988 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:48.988 7f3b609b7048 [kafka.conn] [DEBUG]: Response 280 (601.2270450592041 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:48.989 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/26/2024 02:14:48.989 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:48.989 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:48.989 7f3b6089d978 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:49.060 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 12/26/2024 02:14:49.061 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.061 7f3b60899390 [kafka.conn] [DEBUG]: Response 457 (601.3903617858887 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4064, last_stable_offset=4064, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xdf\x00\x00\x01\x04\x00\x00\x00\x00\x02\xee\xf33\x8c\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 12/26/2024 02:14:49.061 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4063 to buffered record list 12/26/2024 02:14:49.072 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:49.072 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.072 7f3b609a9828 [kafka.conn] [DEBUG]: Response 281 (601.3305187225342 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.077 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:49.077 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.077 7f3b6089df60 [kafka.conn] [DEBUG]: Response 282 (601.2594699859619 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.081 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 298 12/26/2024 02:14:49.081 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.081 7f3b609bc588 [kafka.conn] [DEBUG]: Response 298 (601.0887622833252 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=55, last_stable_offset=55, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.082 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 12/26/2024 02:14:49.082 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.082 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:49.083 7f3b60947390 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:49.137 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 297 12/26/2024 02:14:49.137 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.137 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:49.137 7f3b58419cc0 [kafka.conn] [DEBUG]: Request 328: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:49.138 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 12/26/2024 02:14:49.138 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.138 7f3b60905f60 [kafka.conn] [DEBUG]: Response 306 (601.4039516448975 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=132, last_stable_offset=132, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.139 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 12/26/2024 02:14:49.139 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.139 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:49.139 7f3b608da0f0 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:49.141 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 12/26/2024 02:14:49.141 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.141 7f3b6089d828 [kafka.conn] [DEBUG]: Response 283 (602.4415493011475 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.141 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 38 12/26/2024 02:14:49.141 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.142 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:49.142 7f3b609b78d0 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:49.157 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 248 12/26/2024 02:14:49.157 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.157 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:49.158 7f3b37fcd780 [kafka.conn] [DEBUG]: Request 311: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:49.159 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 12/26/2024 02:14:49.159 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.159 7f3b6089dcc0 [kafka.conn] [DEBUG]: Response 295 (601.7787456512451 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.162 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4064 12/26/2024 02:14:49.162 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.162 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4064, max_bytes=1048576)])]) 12/26/2024 02:14:49.162 7f3b60899390 [kafka.conn] [DEBUG]: Request 458: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4064, max_bytes=1048576)])]) 12/26/2024 02:14:49.177 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 12/26/2024 02:14:49.177 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.177 7f3b609b7588 [kafka.conn] [DEBUG]: Response 289 (601.5071868896484 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.206 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 166 12/26/2024 02:14:49.207 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.207 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:49.207 7f3b58419d68 [kafka.conn] [DEBUG]: Request 311: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:49.225 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 313 12/26/2024 02:14:49.225 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.225 7f3b5836ee10 [kafka.conn] [DEBUG]: Response 313 (601.3209819793701 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=188, last_stable_offset=188, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.231 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 12/26/2024 02:14:49.231 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.231 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:49.231 7f3b58372390 [kafka.conn] [DEBUG]: Request 316: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:49.232 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 38 12/26/2024 02:14:49.232 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.232 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:49.232 7f3b609b7cc0 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:49.274 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 305 12/26/2024 02:14:49.274 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.274 7f3b583720f0 [kafka.conn] [DEBUG]: Response 305 (601.2787818908691 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=171, last_stable_offset=171, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.274 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 12/26/2024 02:14:49.275 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.275 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:49.275 7f3b609bccc0 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:49.277 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 12/26/2024 02:14:49.277 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.277 7f3b609bcb70 [kafka.conn] [DEBUG]: Response 290 (601.4547348022461 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.277 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 12/26/2024 02:14:49.278 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.278 7f3b609bc978 [kafka.conn] [DEBUG]: Response 290 (601.4478206634521 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.280 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 308 12/26/2024 02:14:49.280 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.280 7f3b5836eb70 [kafka.conn] [DEBUG]: Response 308 (600.9442806243896 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=89, last_stable_offset=89, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.383 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135 12/26/2024 02:14:49.383 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.383 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:49.383 7f3b5836e8d0 [kafka.conn] [DEBUG]: Request 307: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:49.455 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 276 12/26/2024 02:14:49.455 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.456 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:49.456 7f3b37f446d8 [kafka.conn] [DEBUG]: Request 328: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:49.484 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:49.485 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.485 7f3b609b4588 [kafka.conn] [DEBUG]: Response 281 (601.4673709869385 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.490 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 12/26/2024 02:14:49.490 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.490 7f3b609bc048 [kafka.conn] [DEBUG]: Response 284 (602.2734642028809 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.491 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:49.491 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.491 7f3b60947240 [kafka.conn] [DEBUG]: Response 282 (602.4580001831055 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.583 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/26/2024 02:14:49.584 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.584 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:49.584 7f3b60899d68 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:49.589 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/26/2024 02:14:49.589 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.589 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:49.589 7f3b609b7048 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:49.590 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 12/26/2024 02:14:49.590 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.590 7f3b6089d978 [kafka.conn] [DEBUG]: Response 280 (601.1021137237549 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.673 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 12/26/2024 02:14:49.673 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.673 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:49.673 7f3b609a9828 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:49.678 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 12/26/2024 02:14:49.678 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.678 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:49.678 7f3b6089df60 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:49.681 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 55 12/26/2024 02:14:49.682 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.682 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:49.682 7f3b609bc588 [kafka.conn] [DEBUG]: Request 299: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:49.683 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 12/26/2024 02:14:49.683 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.683 7f3b60947390 [kafka.conn] [DEBUG]: Response 287 (600.9678840637207 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.738 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/26/2024 02:14:49.739 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.739 7f3b58419cc0 [kafka.conn] [DEBUG]: Response 328 (601.5324592590332 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=297, last_stable_offset=297, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.739 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 12/26/2024 02:14:49.739 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.739 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:49.740 7f3b60905f60 [kafka.conn] [DEBUG]: Request 307: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:49.740 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:49.740 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.740 7f3b608da0f0 [kafka.conn] [DEBUG]: Response 281 (601.4995574951172 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.741 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 4 12/26/2024 02:14:49.741 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.741 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:49.742 7f3b6089d828 [kafka.conn] [DEBUG]: Request 284: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:49.742 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 12/26/2024 02:14:49.743 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.743 7f3b609b78d0 [kafka.conn] [DEBUG]: Response 291 (600.9688377380371 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.759 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 311 12/26/2024 02:14:49.759 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.759 7f3b37fcd780 [kafka.conn] [DEBUG]: Response 311 (601.5663146972656 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=248, last_stable_offset=248, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.760 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 12/26/2024 02:14:49.760 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.760 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:49.760 7f3b6089dcc0 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:49.763 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 12/26/2024 02:14:49.763 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.763 7f3b60899390 [kafka.conn] [DEBUG]: Response 458 (600.9738445281982 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4065, last_stable_offset=4065, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xe0\x00\x00\x01\x04\x00\x00\x00\x00\x02j\xa9c\xd9\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 12/26/2024 02:14:49.763 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4064 to buffered record list 12/26/2024 02:14:49.778 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 35 12/26/2024 02:14:49.778 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.779 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:49.779 7f3b609b7588 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:49.809 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 311 12/26/2024 02:14:49.809 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.810 7f3b58419d68 [kafka.conn] [DEBUG]: Response 311 (602.5521755218506 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.826 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 188 12/26/2024 02:14:49.827 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.827 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:49.827 7f3b5836ee10 [kafka.conn] [DEBUG]: Request 314: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=188, max_bytes=1048576)])]) 12/26/2024 02:14:49.834 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 316 12/26/2024 02:14:49.834 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.834 7f3b58372390 [kafka.conn] [DEBUG]: Response 316 (602.8122901916504 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=160, last_stable_offset=160, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.835 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 12/26/2024 02:14:49.835 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.835 7f3b609b7cc0 [kafka.conn] [DEBUG]: Response 293 (602.9860973358154 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.864 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4065 12/26/2024 02:14:49.864 7f3b60899390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.864 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4065, max_bytes=1048576)])]) 12/26/2024 02:14:49.864 7f3b60899390 [kafka.conn] [DEBUG]: Request 459: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-0', partitions=[(partition=0, offset=4065, max_bytes=1048576)])]) 12/26/2024 02:14:49.875 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 171 12/26/2024 02:14:49.875 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.875 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:49.876 7f3b583720f0 [kafka.conn] [DEBUG]: Request 306: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=171, max_bytes=1048576)])]) 12/26/2024 02:14:49.876 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 12/26/2024 02:14:49.876 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.876 7f3b609bccc0 [kafka.conn] [DEBUG]: Response 293 (601.4688014984131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=48, last_stable_offset=48, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:49.879 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 12/26/2024 02:14:49.879 7f3b609bcb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.879 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:49.880 7f3b609bcb70 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=41, max_bytes=1048576)])]) 12/26/2024 02:14:49.880 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 38 12/26/2024 02:14:49.880 7f3b609bc978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.880 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:49.880 7f3b609bc978 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:49.882 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 89 12/26/2024 02:14:49.882 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:49.882 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:49.882 7f3b5836eb70 [kafka.conn] [DEBUG]: Request 309: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=89, max_bytes=1048576)])]) 12/26/2024 02:14:49.984 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 12/26/2024 02:14:49.984 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:49.984 7f3b5836e8d0 [kafka.conn] [DEBUG]: Response 307 (601.2048721313477 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=135, last_stable_offset=135, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.057 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/26/2024 02:14:50.057 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.057 7f3b37f446d8 [kafka.conn] [DEBUG]: Response 328 (601.2277603149414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=276, last_stable_offset=276, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.086 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/26/2024 02:14:50.086 7f3b609b4588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.086 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.087 7f3b609b4588 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.091 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 10 12/26/2024 02:14:50.091 7f3b609bc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.091 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:50.091 7f3b609bc048 [kafka.conn] [DEBUG]: Request 285: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=10, max_bytes=1048576)])]) 12/26/2024 02:14:50.092 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 5 12/26/2024 02:14:50.092 7f3b60947240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.092 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:50.092 7f3b60947240 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=5, max_bytes=1048576)])]) 12/26/2024 02:14:50.185 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:50.185 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.185 7f3b60899d68 [kafka.conn] [DEBUG]: Response 281 (601.2563705444336 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-1', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.190 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:50.190 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.190 7f3b609b7048 [kafka.conn] [DEBUG]: Response 281 (601.1056900024414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.191 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/26/2024 02:14:50.191 7f3b6089d978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.191 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.191 7f3b6089d978 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.274 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:50.274 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.275 7f3b609a9828 [kafka.conn] [DEBUG]: Response 282 (601.2988090515137 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.279 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 12/26/2024 02:14:50.280 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.280 7f3b6089df60 [kafka.conn] [DEBUG]: Response 283 (601.5057563781738 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.283 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 12/26/2024 02:14:50.283 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.283 7f3b609bc588 [kafka.conn] [DEBUG]: Response 299 (600.9781360626221 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=55, last_stable_offset=55, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.284 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 20 12/26/2024 02:14:50.284 7f3b60947390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.284 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:50.284 7f3b60947390 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=20, max_bytes=1048576)])]) 12/26/2024 02:14:50.339 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 297 12/26/2024 02:14:50.340 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.340 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:50.340 7f3b58419cc0 [kafka.conn] [DEBUG]: Request 329: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=297, max_bytes=1048576)])]) 12/26/2024 02:14:50.341 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 307 12/26/2024 02:14:50.341 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.341 7f3b60905f60 [kafka.conn] [DEBUG]: Response 307 (601.2814044952393 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=132, last_stable_offset=132, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.341 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2 12/26/2024 02:14:50.341 7f3b608da0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.341 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:50.342 7f3b608da0f0 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:50.343 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 12/26/2024 02:14:50.343 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.343 7f3b6089d828 [kafka.conn] [DEBUG]: Response 284 (600.9423732757568 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=4, last_stable_offset=4, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.343 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 38 12/26/2024 02:14:50.343 7f3b609b78d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.343 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:50.344 7f3b609b78d0 [kafka.conn] [DEBUG]: Request 292: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:50.360 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 248 12/26/2024 02:14:50.360 7f3b37fcd780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.360 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:50.361 7f3b37fcd780 [kafka.conn] [DEBUG]: Request 312: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=248, max_bytes=1048576)])]) 12/26/2024 02:14:50.361 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 12/26/2024 02:14:50.361 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.361 7f3b6089dcc0 [kafka.conn] [DEBUG]: Response 296 (601.2558937072754 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.381 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 12/26/2024 02:14:50.381 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.381 7f3b609b7588 [kafka.conn] [DEBUG]: Response 290 (602.325439453125 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.410 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 166 12/26/2024 02:14:50.410 7f3b58419d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.410 7f3b58419d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:50.411 7f3b58419d68 [kafka.conn] [DEBUG]: Request 312: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=166, max_bytes=1048576)])]) 12/26/2024 02:14:50.428 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 314 12/26/2024 02:14:50.428 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.428 7f3b5836ee10 [kafka.conn] [DEBUG]: Response 314 (601.3462543487549 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=190, last_stable_offset=190, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xbc\x00\x00\x01\xeb\x00\x00\x00\x00\x02+\xc8A\xe3\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xb6\x03\x00\x00\x00\xf8\x02ObjectGeneratorInfo:cn-jenkins-d...')])]) 12/26/2024 02:14:50.429 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 188 to buffered record list 12/26/2024 02:14:50.435 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 12/26/2024 02:14:50.435 7f3b58372390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.435 7f3b58372390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:50.435 7f3b58372390 [kafka.conn] [DEBUG]: Request 317: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-26', partitions=[(partition=0, offset=160, max_bytes=1048576)])]) 12/26/2024 02:14:50.435 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 38 12/26/2024 02:14:50.435 7f3b609b7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.436 7f3b609b7cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:50.436 7f3b609b7cc0 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=38, max_bytes=1048576)])]) 12/26/2024 02:14:50.465 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 459 12/26/2024 02:14:50.465 7f3b60899390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.466 7f3b60899390 [kafka.conn] [DEBUG]: Response 459 (601.2051105499268 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4065, last_stable_offset=4065, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.476 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 306 12/26/2024 02:14:50.476 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.477 7f3b583720f0 [kafka.conn] [DEBUG]: Response 306 (601.1683940887451 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=172, last_stable_offset=172, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xab\x00\x00\x01X\x00\x00\x00\x00\x02++]"\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xca\x04\x00\x00\x00\x8c\x04ObjectVNTable:default-domain:tem...')])]) 12/26/2024 02:14:50.477 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 171 to buffered record list 12/26/2024 02:14:50.477 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 48 12/26/2024 02:14:50.477 7f3b609bccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.477 7f3b609bccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:50.478 7f3b609bccc0 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=48, max_bytes=1048576)])]) 12/26/2024 02:14:50.481 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 12/26/2024 02:14:50.481 7f3b609bcb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.481 7f3b609bcb70 [kafka.conn] [DEBUG]: Response 291 (601.7458438873291 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.482 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 12/26/2024 02:14:50.482 7f3b609bc978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.482 7f3b609bc978 [kafka.conn] [DEBUG]: Response 291 (601.7272472381592 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.483 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 309 12/26/2024 02:14:50.483 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.483 7f3b5836eb70 [kafka.conn] [DEBUG]: Response 309 (600.8493900299072 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=91, last_stable_offset=91, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00Y\x00\x00\x01\xd4\x00\x00\x00\x00\x02\x87\xb6P\xc8\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xa2\x03\x00\x00\x00\xe4\x02ObjectXmppPeerInfo:cn-jenkins-de...')])]) 12/26/2024 02:14:50.483 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 89 to buffered record list 12/26/2024 02:14:50.529 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 190 12/26/2024 02:14:50.530 7f3b5836ee10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.530 7f3b5836ee10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=190, max_bytes=1048576)])]) 12/26/2024 02:14:50.530 7f3b5836ee10 [kafka.conn] [DEBUG]: Request 315: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=190, max_bytes=1048576)])]) 12/26/2024 02:14:50.578 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 172 12/26/2024 02:14:50.578 7f3b583720f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.578 7f3b583720f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=172, max_bytes=1048576)])]) 12/26/2024 02:14:50.578 7f3b583720f0 [kafka.conn] [DEBUG]: Request 307: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-25', partitions=[(partition=0, offset=172, max_bytes=1048576)])]) 12/26/2024 02:14:50.584 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 91 12/26/2024 02:14:50.584 7f3b5836eb70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.584 7f3b5836eb70 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=91, max_bytes=1048576)])]) 12/26/2024 02:14:50.584 7f3b5836eb70 [kafka.conn] [DEBUG]: Request 310: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=91, max_bytes=1048576)])]) 12/26/2024 02:14:50.586 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 135 12/26/2024 02:14:50.586 7f3b5836e8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.586 7f3b5836e8d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:50.586 7f3b5836e8d0 [kafka.conn] [DEBUG]: Request 308: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=135, max_bytes=1048576)])]) 12/26/2024 02:14:50.658 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 276 12/26/2024 02:14:50.658 7f3b37f446d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.658 7f3b37f446d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:50.658 7f3b37f446d8 [kafka.conn] [DEBUG]: Request 329: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=276, max_bytes=1048576)])]) 12/26/2024 02:14:50.687 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:50.688 7f3b609b4588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.688 7f3b609b4588 [kafka.conn] [DEBUG]: Response 282 (601.3779640197754 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.693 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 12/26/2024 02:14:50.693 7f3b609bc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.693 7f3b609bc048 [kafka.conn] [DEBUG]: Response 285 (601.9918918609619 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.694 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 12/26/2024 02:14:50.694 7f3b60947240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.695 7f3b60947240 [kafka.conn] [DEBUG]: Response 283 (602.5435924530029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=5, last_stable_offset=5, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.786 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/26/2024 02:14:50.786 7f3b60899d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.786 7f3b60899d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.787 7f3b60899d68 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.791 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/26/2024 02:14:50.791 7f3b609b7048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.791 7f3b609b7048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.792 7f3b609b7048 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 12/26/2024 02:14:50.792 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 12/26/2024 02:14:50.792 7f3b6089d978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.793 7f3b6089d978 [kafka.conn] [DEBUG]: Response 281 (601.6132831573486 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-3', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.875 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 12/26/2024 02:14:50.876 7f3b609a9828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.876 7f3b609a9828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:50.876 7f3b609a9828 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 12/26/2024 02:14:50.880 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 12/26/2024 02:14:50.880 7f3b6089df60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.881 7f3b6089df60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:50.881 7f3b6089df60 [kafka.conn] [DEBUG]: Request 284: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 12/26/2024 02:14:50.883 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 55 12/26/2024 02:14:50.884 7f3b609bc588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.884 7f3b609bc588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:50.884 7f3b609bc588 [kafka.conn] [DEBUG]: Request 300: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 12/26/2024 02:14:50.885 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 12/26/2024 02:14:50.885 7f3b60947390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.885 7f3b60947390 [kafka.conn] [DEBUG]: Response 288 (601.0341644287109 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=20, last_stable_offset=20, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.941 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/26/2024 02:14:50.941 7f3b58419cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.942 7f3b58419cc0 [kafka.conn] [DEBUG]: Response 329 (601.5465259552002 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=299, last_stable_offset=299, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x01)\x00\x00\x00\xfd\x00\x00\x00\x00\x02\xc2n\xa3\x1a\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x94\x03\x00\x00\x00\xd6\x02ObjectVNTable:default-domain:def...')])]) 12/26/2024 02:14:50.942 7f3b58419cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 297 to buffered record list 12/26/2024 02:14:50.942 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 12/26/2024 02:14:50.943 7f3b60905f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.943 7f3b60905f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:50.943 7f3b60905f60 [kafka.conn] [DEBUG]: Request 308: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=132, max_bytes=1048576)])]) 12/26/2024 02:14:50.944 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 12/26/2024 02:14:50.944 7f3b608da0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.944 7f3b608da0f0 [kafka.conn] [DEBUG]: Response 282 (602.3077964782715 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.944 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 4 12/26/2024 02:14:50.945 7f3b6089d828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.945 7f3b6089d828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:50.945 7f3b6089d828 [kafka.conn] [DEBUG]: Request 285: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=4, max_bytes=1048576)])]) 12/26/2024 02:14:50.945 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 12/26/2024 02:14:50.945 7f3b609b78d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.946 7f3b609b78d0 [kafka.conn] [DEBUG]: Response 292 (602.0164489746094 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.961 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 312 12/26/2024 02:14:50.962 7f3b37fcd780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 12/26/2024 02:14:50.962 7f3b37fcd780 [kafka.conn] [DEBUG]: Response 312 (601.2709140777588 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=248, last_stable_offset=248, aborted_transactions=NULL, message_set=b'')])]) 12/26/2024 02:14:50.962 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 58 12/26/2024 02:14:50.962 7f3b6089dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.962 7f3b6089dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:50.963 7f3b6089dcc0 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 12/26/2024 02:14:50.982 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 35 12/26/2024 02:14:50.982 7f3b609b7588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/26/2024 02:14:50.982 7f3b609b7588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])]) 12/26/2024 02:14:50.982 7f3b609b7588 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=35, max_bytes=1048576)])])