10/28/2024 02:25:50.744 7f56ec1e0a20 [kafka.conn] [DEBUG]: Response 583 (605.7829856872559 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:50.832 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 621 10/28/2024 02:25:50.833 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:50.833 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 621 (601.6778945922852 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=155, last_stable_offset=155, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:50.833 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 10/28/2024 02:25:50.834 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:50.834 7f56ec1a50f0 [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)])]) 10/28/2024 02:25:50.834 7f56ec1a50f0 [kafka.conn] [DEBUG]: Request 626: 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)])]) 10/28/2024 02:25:50.860 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:50.860 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:50.860 7f56ec1e0630 [kafka.conn] [DEBUG]: Response 589 (601.3467311859131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:50.900 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 10/28/2024 02:25:50.901 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:50.901 7f56ef2bfeb8 [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=6, max_bytes=1048576)])]) 10/28/2024 02:25:50.901 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Request 586: 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=6, max_bytes=1048576)])]) 10/28/2024 02:25:50.945 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 614 10/28/2024 02:25:50.945 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:50.945 7f56ec1a58d0 [kafka.conn] [DEBUG]: Response 614 (602.1087169647217 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=172, last_stable_offset=172, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.012 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 588 10/28/2024 02:25:51.012 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.012 7f56ef2f50f0 [kafka.conn] [DEBUG]: Response 588 (601.3388633728027 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.013 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 584 10/28/2024 02:25:51.013 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.013 7f56ec12c390 [kafka.conn] [DEBUG]: Response 584 (600.9981632232666 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.014 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15 10/28/2024 02:25:51.014 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.014 7f56ef2f56d8 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:51.014 7f56ef2f56d8 [kafka.conn] [DEBUG]: Request 589: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:51.094 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 632 10/28/2024 02:25:51.094 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.094 7f56ec1a1e10 [kafka.conn] [DEBUG]: Response 632 (602.452278137207 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=287, last_stable_offset=287, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.095 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 596 10/28/2024 02:25:51.095 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.095 7f56ec1e0f60 [kafka.conn] [DEBUG]: Response 596 (602.2891998291016 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.095 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 617 10/28/2024 02:25:51.095 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.095 7f56ec1a5390 [kafka.conn] [DEBUG]: Response 617 (602.3228168487549 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.171 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 630 10/28/2024 02:25:51.171 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.172 7f56ec1a5e10 [kafka.conn] [DEBUG]: Response 630 (601.4344692230225 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.172 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 81 10/28/2024 02:25:51.173 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.173 7f56ef2f5ac8 [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=81, max_bytes=1048576)])]) 10/28/2024 02:25:51.173 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Request 604: 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=81, max_bytes=1048576)])]) 10/28/2024 02:25:51.173 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 137 10/28/2024 02:25:51.173 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.173 7f56ef2c74e0 [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=137, max_bytes=1048576)])]) 10/28/2024 02:25:51.174 7f56ef2c74e0 [kafka.conn] [DEBUG]: Request 619: 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=137, max_bytes=1048576)])]) 10/28/2024 02:25:51.174 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 10 10/28/2024 02:25:51.174 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.174 7f56ef2f5e10 [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=10, max_bytes=1048576)])]) 10/28/2024 02:25:51.175 7f56ef2f5e10 [kafka.conn] [DEBUG]: Request 588: 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=10, max_bytes=1048576)])]) 10/28/2024 02:25:51.175 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 582 10/28/2024 02:25:51.176 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.176 7f56ef3718d0 [kafka.conn] [DEBUG]: Response 582 (601.5539169311523 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.176 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 618 10/28/2024 02:25:51.176 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.176 7f56ec1a1828 [kafka.conn] [DEBUG]: Response 618 (601.5739440917969 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.177 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 61 10/28/2024 02:25:51.177 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.177 7f56ec12c630 [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=61, max_bytes=1048576)])]) 10/28/2024 02:25:51.177 7f56ec12c630 [kafka.conn] [DEBUG]: Request 599: 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=61, max_bytes=1048576)])]) 10/28/2024 02:25:51.177 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 10/28/2024 02:25:51.178 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.178 7f56ef2c7240 [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)])]) 10/28/2024 02:25:51.178 7f56ef2c7240 [kafka.conn] [DEBUG]: Request 583: 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)])]) 10/28/2024 02:25:51.178 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 623 10/28/2024 02:25:51.178 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.179 7f56ec12c0f0 [kafka.conn] [DEBUG]: Response 623 (601.0243892669678 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=139, last_stable_offset=139, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.210 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 920 10/28/2024 02:25:51.210 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.210 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 920 (601.4418601989746 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2447, last_stable_offset=2447, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.342 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:51.342 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.342 7f56ef3e28d0 [kafka.conn] [DEBUG]: Response 589 (603.8315296173096 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.342 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 15 10/28/2024 02:25:51.343 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.343 7f56ec1e0cc0 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:51.343 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Request 590: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:51.344 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 122 10/28/2024 02:25:51.345 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.345 7f56ec1a5b70 [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=122, max_bytes=1048576)])]) 10/28/2024 02:25:51.345 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 619: 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=122, max_bytes=1048576)])]) 10/28/2024 02:25:51.345 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 10/28/2024 02:25:51.345 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.346 7f56ec1e0780 [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)])]) 10/28/2024 02:25:51.346 7f56ec1e0780 [kafka.conn] [DEBUG]: Request 595: 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)])]) 10/28/2024 02:25:51.347 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 595 10/28/2024 02:25:51.347 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.347 7f56ec12c8d0 [kafka.conn] [DEBUG]: Response 595 (607.703685760498 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.347 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 587 10/28/2024 02:25:51.347 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.348 7f56ef2f5438 [kafka.conn] [DEBUG]: Response 587 (607.6993942260742 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.348 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 623 10/28/2024 02:25:51.348 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.348 7f56ec1a1b70 [kafka.conn] [DEBUG]: Response 623 (607.689380645752 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=220, last_stable_offset=220, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xda\x00\x00\x02\x17\x00\x00\x00\x00\x02\xde\xa7\xf0\xad\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\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:51.348 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 218 to buffered record list 10/28/2024 02:25:51.349 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 10/28/2024 02:25:51.349 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.349 7f56ec1e0a20 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:51.349 7f56ec1e0a20 [kafka.conn] [DEBUG]: Request 584: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:51.350 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 619 10/28/2024 02:25:51.350 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.350 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 619 (5.114078521728516 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=123, last_stable_offset=123, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00z\x00\x00\x00\xfc\x00\x00\x00\x00\x02;\xc6q9\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\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...')])]) 10/28/2024 02:25:51.350 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 122 to buffered record list 10/28/2024 02:25:51.351 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 582 10/28/2024 02:25:51.351 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.351 7f56ef3ba240 [kafka.conn] [DEBUG]: Response 582 (607.377290725708 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'')])]) 10/28/2024 02:25:51.434 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 155 10/28/2024 02:25:51.434 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.434 7f56ec1a5630 [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=155, max_bytes=1048576)])]) 10/28/2024 02:25:51.434 7f56ec1a5630 [kafka.conn] [DEBUG]: Request 622: 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=155, max_bytes=1048576)])]) 10/28/2024 02:25:51.435 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 626 10/28/2024 02:25:51.435 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.435 7f56ec1a50f0 [kafka.conn] [DEBUG]: Response 626 (601.4225482940674 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'')])]) 10/28/2024 02:25:51.449 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 220 10/28/2024 02:25:51.449 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.449 7f56ec1a1b70 [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=220, max_bytes=1048576)])]) 10/28/2024 02:25:51.450 7f56ec1a1b70 [kafka.conn] [DEBUG]: Request 624: 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=220, max_bytes=1048576)])]) 10/28/2024 02:25:51.451 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 123 10/28/2024 02:25:51.451 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.451 7f56ec1a5b70 [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=123, max_bytes=1048576)])]) 10/28/2024 02:25:51.451 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 620: 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=123, max_bytes=1048576)])]) 10/28/2024 02:25:51.452 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 620 10/28/2024 02:25:51.452 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.452 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 620 (1.0843276977539062 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=125, last_stable_offset=125, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00{\x00\x00\x02\x13\x00\x00\x00\x00\x02\x90R\xfcR\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\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:51.453 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 123 to buffered record list 10/28/2024 02:25:51.461 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 32 10/28/2024 02:25:51.461 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.461 7f56ec1e0630 [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=32, max_bytes=1048576)])]) 10/28/2024 02:25:51.462 7f56ec1e0630 [kafka.conn] [DEBUG]: Request 590: 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=32, max_bytes=1048576)])]) 10/28/2024 02:25:51.502 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 586 10/28/2024 02:25:51.502 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.502 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Response 586 (601.3996601104736 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.546 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 172 10/28/2024 02:25:51.546 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.546 7f56ec1a58d0 [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=172, max_bytes=1048576)])]) 10/28/2024 02:25:51.547 7f56ec1a58d0 [kafka.conn] [DEBUG]: Request 615: 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=172, max_bytes=1048576)])]) 10/28/2024 02:25:51.553 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 125 10/28/2024 02:25:51.554 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.554 7f56ec1a5b70 [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=125, max_bytes=1048576)])]) 10/28/2024 02:25:51.554 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 621: 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=125, max_bytes=1048576)])]) 10/28/2024 02:25:51.613 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 10/28/2024 02:25:51.613 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.613 7f56ef2f50f0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:51.614 7f56ef2f50f0 [kafka.conn] [DEBUG]: Request 589: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:51.614 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 8 10/28/2024 02:25:51.614 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.614 7f56ec12c390 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:51.614 7f56ec12c390 [kafka.conn] [DEBUG]: Request 585: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:51.615 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:51.615 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.615 7f56ef2f56d8 [kafka.conn] [DEBUG]: Response 589 (601.3174057006836 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.695 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 287 10/28/2024 02:25:51.695 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.695 7f56ec1a1e10 [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=287, max_bytes=1048576)])]) 10/28/2024 02:25:51.695 7f56ec1a1e10 [kafka.conn] [DEBUG]: Request 633: 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=287, max_bytes=1048576)])]) 10/28/2024 02:25:51.696 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 10/28/2024 02:25:51.696 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.696 7f56ec1e0f60 [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=35, max_bytes=1048576)])]) 10/28/2024 02:25:51.696 7f56ec1e0f60 [kafka.conn] [DEBUG]: Request 597: 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=35, max_bytes=1048576)])]) 10/28/2024 02:25:51.697 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 166 10/28/2024 02:25:51.697 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.697 7f56ec1a5390 [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=166, max_bytes=1048576)])]) 10/28/2024 02:25:51.697 7f56ec1a5390 [kafka.conn] [DEBUG]: Request 618: 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=166, max_bytes=1048576)])]) 10/28/2024 02:25:51.772 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 10/28/2024 02:25:51.773 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.773 7f56ec1a5e10 [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=122, max_bytes=1048576)])]) 10/28/2024 02:25:51.773 7f56ec1a5e10 [kafka.conn] [DEBUG]: Request 631: 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=122, max_bytes=1048576)])]) 10/28/2024 02:25:51.774 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 604 10/28/2024 02:25:51.774 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.775 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Response 604 (601.7389297485352 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, last_stable_offset=82, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00Q\x00\x00\x01\x17\x00\x00\x00\x00\x02\xdc\x94\x04\xcb\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\xc8\x03\x00\x00\x00\x8a\x03ObjectVMITable:default-global-sy...')])]) 10/28/2024 02:25:51.775 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-12', partition=0) with offset 81 to buffered record list 10/28/2024 02:25:51.775 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 619 10/28/2024 02:25:51.776 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.776 7f56ef2c74e0 [kafka.conn] [DEBUG]: Response 619 (602.0815372467041 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x89\x00\x00\x03Y\x00\x00\x00\x00\x02\r1\x17\xe1\x00\x00\x00\x00\x00\x03\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\x04\x90\x03\x00\x00\x00\xd2\x02ObjectVRouter:cn-jenkins-deploy-...')])]) 10/28/2024 02:25:51.776 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 137 to buffered record list 10/28/2024 02:25:51.776 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 588 10/28/2024 02:25:51.776 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.776 7f56ef2f5e10 [kafka.conn] [DEBUG]: Response 588 (602.0791530609131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.777 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 10/28/2024 02:25:51.777 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.777 7f56ef3718d0 [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=0, max_bytes=1048576)])]) 10/28/2024 02:25:51.777 7f56ef3718d0 [kafka.conn] [DEBUG]: Request 583: 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=0, max_bytes=1048576)])]) 10/28/2024 02:25:51.777 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 118 10/28/2024 02:25:51.778 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.778 7f56ec1a1828 [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=118, max_bytes=1048576)])]) 10/28/2024 02:25:51.778 7f56ec1a1828 [kafka.conn] [DEBUG]: Request 619: 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=118, max_bytes=1048576)])]) 10/28/2024 02:25:51.779 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 599 10/28/2024 02:25:51.779 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.779 7f56ec12c630 [kafka.conn] [DEBUG]: Response 599 (601.654052734375 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.779 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 139 10/28/2024 02:25:51.779 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.779 7f56ec12c0f0 [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=139, max_bytes=1048576)])]) 10/28/2024 02:25:51.780 7f56ec12c0f0 [kafka.conn] [DEBUG]: Request 624: 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=139, max_bytes=1048576)])]) 10/28/2024 02:25:51.780 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 583 10/28/2024 02:25:51.780 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.780 7f56ef2c7240 [kafka.conn] [DEBUG]: Response 583 (602.3750305175781 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'')])]) 10/28/2024 02:25:51.811 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2447 10/28/2024 02:25:51.811 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.812 7f56ef2c7780 [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=2447, max_bytes=1048576)])]) 10/28/2024 02:25:51.812 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 921: 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=2447, max_bytes=1048576)])]) 10/28/2024 02:25:51.812 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 921 10/28/2024 02:25:51.813 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.813 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 921 (0.8404254913330078 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2448, last_stable_offset=2448, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t\x8f\x00\x00\x01\x04\x00\x00\x00\x00\x02\xcf\x86\x83\x10\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...')])]) 10/28/2024 02:25:51.813 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2447 to buffered record list 10/28/2024 02:25:51.876 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 82 10/28/2024 02:25:51.876 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.876 7f56ef2f5ac8 [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=82, max_bytes=1048576)])]) 10/28/2024 02:25:51.876 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Request 605: 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=82, max_bytes=1048576)])]) 10/28/2024 02:25:51.877 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 141 10/28/2024 02:25:51.877 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.877 7f56ef2c74e0 [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=141, max_bytes=1048576)])]) 10/28/2024 02:25:51.877 7f56ef2c74e0 [kafka.conn] [DEBUG]: Request 620: 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=141, max_bytes=1048576)])]) 10/28/2024 02:25:51.914 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2448 10/28/2024 02:25:51.914 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.914 7f56ef2c7780 [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=2448, max_bytes=1048576)])]) 10/28/2024 02:25:51.914 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 922: 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=2448, max_bytes=1048576)])]) 10/28/2024 02:25:51.943 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 18 10/28/2024 02:25:51.943 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.943 7f56ef3e28d0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:51.943 7f56ef3e28d0 [kafka.conn] [DEBUG]: Request 590: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:51.947 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:51.947 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.947 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Response 590 (604.2933464050293 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:51.948 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 54 10/28/2024 02:25:51.948 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.948 7f56ec12c8d0 [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=54, max_bytes=1048576)])]) 10/28/2024 02:25:51.948 7f56ec12c8d0 [kafka.conn] [DEBUG]: Request 596: 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=54, max_bytes=1048576)])]) 10/28/2024 02:25:51.948 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 13 10/28/2024 02:25:51.949 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.949 7f56ef2f5438 [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=13, max_bytes=1048576)])]) 10/28/2024 02:25:51.949 7f56ef2f5438 [kafka.conn] [DEBUG]: Request 588: 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=13, max_bytes=1048576)])]) 10/28/2024 02:25:51.952 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 595 10/28/2024 02:25:51.952 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.952 7f56ec1e0780 [kafka.conn] [DEBUG]: Response 595 (606.2767505645752 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'')])]) 10/28/2024 02:25:51.952 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/28/2024 02:25:51.953 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:51.953 7f56ef3ba240 [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)])]) 10/28/2024 02:25:51.953 7f56ef3ba240 [kafka.conn] [DEBUG]: Request 583: 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)])]) 10/28/2024 02:25:51.953 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 584 10/28/2024 02:25:51.953 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:51.954 7f56ec1e0a20 [kafka.conn] [DEBUG]: Response 584 (604.3322086334229 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.035 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 622 10/28/2024 02:25:52.036 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.036 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 622 (601.4859676361084 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=155, last_stable_offset=155, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.036 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 10/28/2024 02:25:52.036 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.036 7f56ec1a50f0 [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)])]) 10/28/2024 02:25:52.037 7f56ec1a50f0 [kafka.conn] [DEBUG]: Request 627: 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)])]) 10/28/2024 02:25:52.051 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 624 10/28/2024 02:25:52.051 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.051 7f56ec1a1b70 [kafka.conn] [DEBUG]: Response 624 (601.3062000274658 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=220, last_stable_offset=220, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.063 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:52.063 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.063 7f56ec1e0630 [kafka.conn] [DEBUG]: Response 590 (601.3069152832031 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.103 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 10/28/2024 02:25:52.103 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.103 7f56ef2bfeb8 [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=6, max_bytes=1048576)])]) 10/28/2024 02:25:52.104 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Request 587: 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=6, max_bytes=1048576)])]) 10/28/2024 02:25:52.148 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 615 10/28/2024 02:25:52.148 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.148 7f56ec1a58d0 [kafka.conn] [DEBUG]: Response 615 (601.4838218688965 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=172, last_stable_offset=172, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.155 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 621 10/28/2024 02:25:52.155 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.155 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 621 (601.1312007904053 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=125, last_stable_offset=125, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.215 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:52.215 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.216 7f56ef2f50f0 [kafka.conn] [DEBUG]: Response 589 (602.1170616149902 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.216 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15 10/28/2024 02:25:52.216 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.216 7f56ef2f56d8 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:52.217 7f56ef2f56d8 [kafka.conn] [DEBUG]: Request 590: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:52.217 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 585 10/28/2024 02:25:52.217 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.217 7f56ec12c390 [kafka.conn] [DEBUG]: Response 585 (603.0590534210205 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.297 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 633 10/28/2024 02:25:52.297 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.298 7f56ec1a1e10 [kafka.conn] [DEBUG]: Response 633 (602.2806167602539 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=287, last_stable_offset=287, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.298 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 597 10/28/2024 02:25:52.298 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.299 7f56ec1e0f60 [kafka.conn] [DEBUG]: Response 597 (602.5052070617676 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.299 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 618 10/28/2024 02:25:52.299 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.299 7f56ec1a5390 [kafka.conn] [DEBUG]: Response 618 (602.3421287536621 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.374 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 631 10/28/2024 02:25:52.374 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.374 7f56ec1a5e10 [kafka.conn] [DEBUG]: Response 631 (601.3851165771484 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.378 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 10 10/28/2024 02:25:52.378 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.378 7f56ef2f5e10 [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=10, max_bytes=1048576)])]) 10/28/2024 02:25:52.378 7f56ef2f5e10 [kafka.conn] [DEBUG]: Request 589: 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=10, max_bytes=1048576)])]) 10/28/2024 02:25:52.379 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 583 10/28/2024 02:25:52.379 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.379 7f56ef3718d0 [kafka.conn] [DEBUG]: Response 583 (602.149248123169 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.380 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 619 10/28/2024 02:25:52.380 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.380 7f56ec1a1828 [kafka.conn] [DEBUG]: Response 619 (602.1530628204346 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.380 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 61 10/28/2024 02:25:52.380 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.381 7f56ec12c630 [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=61, max_bytes=1048576)])]) 10/28/2024 02:25:52.381 7f56ec12c630 [kafka.conn] [DEBUG]: Request 600: 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=61, max_bytes=1048576)])]) 10/28/2024 02:25:52.381 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 10/28/2024 02:25:52.381 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.381 7f56ef2c7240 [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)])]) 10/28/2024 02:25:52.381 7f56ef2c7240 [kafka.conn] [DEBUG]: Request 584: 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)])]) 10/28/2024 02:25:52.382 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 624 10/28/2024 02:25:52.382 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.382 7f56ec12c0f0 [kafka.conn] [DEBUG]: Response 624 (602.7965545654297 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=139, last_stable_offset=139, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.478 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 605 10/28/2024 02:25:52.478 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.479 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Response 605 (602.3006439208984 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, last_stable_offset=82, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.479 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 620 10/28/2024 02:25:52.479 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.479 7f56ef2c74e0 [kafka.conn] [DEBUG]: Response 620 (602.0033359527588 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.515 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 922 10/28/2024 02:25:52.516 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.516 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 922 (601.4983654022217 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2448, last_stable_offset=2448, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.544 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:52.544 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.545 7f56ef3e28d0 [kafka.conn] [DEBUG]: Response 590 (601.386547088623 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.548 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 15 10/28/2024 02:25:52.548 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.548 7f56ec1e0cc0 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:52.548 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Request 591: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:52.550 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 596 10/28/2024 02:25:52.550 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.550 7f56ec12c8d0 [kafka.conn] [DEBUG]: Response 596 (601.7193794250488 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.550 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 588 10/28/2024 02:25:52.550 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.551 7f56ef2f5438 [kafka.conn] [DEBUG]: Response 588 (601.6764640808105 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.553 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 10/28/2024 02:25:52.553 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.553 7f56ec1e0780 [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)])]) 10/28/2024 02:25:52.553 7f56ec1e0780 [kafka.conn] [DEBUG]: Request 596: 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)])]) 10/28/2024 02:25:52.554 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 10/28/2024 02:25:52.554 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.554 7f56ec1e0a20 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:52.554 7f56ec1e0a20 [kafka.conn] [DEBUG]: Request 585: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:52.555 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 583 10/28/2024 02:25:52.555 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.555 7f56ef3ba240 [kafka.conn] [DEBUG]: Response 583 (602.165699005127 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'')])]) 10/28/2024 02:25:52.636 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 155 10/28/2024 02:25:52.637 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.637 7f56ec1a5630 [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=155, max_bytes=1048576)])]) 10/28/2024 02:25:52.637 7f56ec1a5630 [kafka.conn] [DEBUG]: Request 623: 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=155, max_bytes=1048576)])]) 10/28/2024 02:25:52.638 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 627 10/28/2024 02:25:52.638 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.638 7f56ec1a50f0 [kafka.conn] [DEBUG]: Response 627 (601.29714012146 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'')])]) 10/28/2024 02:25:52.652 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 220 10/28/2024 02:25:52.652 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.652 7f56ec1a1b70 [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=220, max_bytes=1048576)])]) 10/28/2024 02:25:52.652 7f56ec1a1b70 [kafka.conn] [DEBUG]: Request 625: 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=220, max_bytes=1048576)])]) 10/28/2024 02:25:52.664 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 32 10/28/2024 02:25:52.664 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.664 7f56ec1e0630 [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=32, max_bytes=1048576)])]) 10/28/2024 02:25:52.664 7f56ec1e0630 [kafka.conn] [DEBUG]: Request 591: 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=32, max_bytes=1048576)])]) 10/28/2024 02:25:52.705 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 587 10/28/2024 02:25:52.705 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.705 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Response 587 (601.3906002044678 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.749 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 172 10/28/2024 02:25:52.749 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.749 7f56ec1a58d0 [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=172, max_bytes=1048576)])]) 10/28/2024 02:25:52.749 7f56ec1a58d0 [kafka.conn] [DEBUG]: Request 616: 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=172, max_bytes=1048576)])]) 10/28/2024 02:25:52.755 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 125 10/28/2024 02:25:52.756 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.756 7f56ec1a5b70 [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=125, max_bytes=1048576)])]) 10/28/2024 02:25:52.756 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 622: 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=125, max_bytes=1048576)])]) 10/28/2024 02:25:52.816 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 10/28/2024 02:25:52.817 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.817 7f56ef2f50f0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:52.817 7f56ef2f50f0 [kafka.conn] [DEBUG]: Request 590: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:52.818 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 8 10/28/2024 02:25:52.818 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.818 7f56ec12c390 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:52.818 7f56ec12c390 [kafka.conn] [DEBUG]: Request 586: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:52.819 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:52.819 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.819 7f56ef2f56d8 [kafka.conn] [DEBUG]: Response 590 (602.3778915405273 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.920 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 287 10/28/2024 02:25:52.920 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.920 7f56ec1a1e10 [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=287, max_bytes=1048576)])]) 10/28/2024 02:25:52.921 7f56ec1a1e10 [kafka.conn] [DEBUG]: Request 634: 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=287, max_bytes=1048576)])]) 10/28/2024 02:25:52.921 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 10/28/2024 02:25:52.921 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.921 7f56ec1e0f60 [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=35, max_bytes=1048576)])]) 10/28/2024 02:25:52.921 7f56ec1e0f60 [kafka.conn] [DEBUG]: Request 598: 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=35, max_bytes=1048576)])]) 10/28/2024 02:25:52.922 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 166 10/28/2024 02:25:52.922 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.922 7f56ec1a5390 [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=166, max_bytes=1048576)])]) 10/28/2024 02:25:52.922 7f56ec1a5390 [kafka.conn] [DEBUG]: Request 619: 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=166, max_bytes=1048576)])]) 10/28/2024 02:25:52.975 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 10/28/2024 02:25:52.975 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.975 7f56ec1a5e10 [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=122, max_bytes=1048576)])]) 10/28/2024 02:25:52.976 7f56ec1a5e10 [kafka.conn] [DEBUG]: Request 632: 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=122, max_bytes=1048576)])]) 10/28/2024 02:25:52.980 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:52.980 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.980 7f56ef2f5e10 [kafka.conn] [DEBUG]: Response 589 (601.8884181976318 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.981 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 10/28/2024 02:25:52.981 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.981 7f56ef3718d0 [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=0, max_bytes=1048576)])]) 10/28/2024 02:25:52.981 7f56ef3718d0 [kafka.conn] [DEBUG]: Request 584: 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=0, max_bytes=1048576)])]) 10/28/2024 02:25:52.981 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 118 10/28/2024 02:25:52.982 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.982 7f56ec1a1828 [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=118, max_bytes=1048576)])]) 10/28/2024 02:25:52.982 7f56ec1a1828 [kafka.conn] [DEBUG]: Request 620: 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=118, max_bytes=1048576)])]) 10/28/2024 02:25:52.983 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 600 10/28/2024 02:25:52.983 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.983 7f56ec12c630 [kafka.conn] [DEBUG]: Response 600 (602.3862361907959 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:52.984 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 139 10/28/2024 02:25:52.984 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:52.984 7f56ec12c0f0 [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=139, max_bytes=1048576)])]) 10/28/2024 02:25:52.984 7f56ec12c0f0 [kafka.conn] [DEBUG]: Request 625: 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=139, max_bytes=1048576)])]) 10/28/2024 02:25:52.984 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 584 10/28/2024 02:25:52.984 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:52.985 7f56ef2c7240 [kafka.conn] [DEBUG]: Response 584 (603.1773090362549 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'')])]) 10/28/2024 02:25:53.079 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 82 10/28/2024 02:25:53.079 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.079 7f56ef2f5ac8 [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=82, max_bytes=1048576)])]) 10/28/2024 02:25:53.080 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Request 606: 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=82, max_bytes=1048576)])]) 10/28/2024 02:25:53.080 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 141 10/28/2024 02:25:53.080 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.080 7f56ef2c74e0 [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=141, max_bytes=1048576)])]) 10/28/2024 02:25:53.081 7f56ef2c74e0 [kafka.conn] [DEBUG]: Request 621: 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=141, max_bytes=1048576)])]) 10/28/2024 02:25:53.116 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2448 10/28/2024 02:25:53.117 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.117 7f56ef2c7780 [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=2448, max_bytes=1048576)])]) 10/28/2024 02:25:53.117 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 923: 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=2448, max_bytes=1048576)])]) 10/28/2024 02:25:53.145 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 18 10/28/2024 02:25:53.145 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.145 7f56ef3e28d0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:53.146 7f56ef3e28d0 [kafka.conn] [DEBUG]: Request 591: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:53.149 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:53.149 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.149 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Response 591 (601.0408401489258 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.150 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 54 10/28/2024 02:25:53.150 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.150 7f56ec12c8d0 [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=54, max_bytes=1048576)])]) 10/28/2024 02:25:53.151 7f56ec12c8d0 [kafka.conn] [DEBUG]: Request 597: 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=54, max_bytes=1048576)])]) 10/28/2024 02:25:53.151 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 13 10/28/2024 02:25:53.151 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.151 7f56ef2f5438 [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=13, max_bytes=1048576)])]) 10/28/2024 02:25:53.151 7f56ef2f5438 [kafka.conn] [DEBUG]: Request 589: 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=13, max_bytes=1048576)])]) 10/28/2024 02:25:53.154 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 596 10/28/2024 02:25:53.154 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.154 7f56ec1e0780 [kafka.conn] [DEBUG]: Response 596 (600.9047031402588 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'')])]) 10/28/2024 02:25:53.155 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 585 10/28/2024 02:25:53.155 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.155 7f56ec1e0a20 [kafka.conn] [DEBUG]: Response 585 (600.9111404418945 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.156 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/28/2024 02:25:53.156 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.156 7f56ef3ba240 [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)])]) 10/28/2024 02:25:53.156 7f56ef3ba240 [kafka.conn] [DEBUG]: Request 584: 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)])]) 10/28/2024 02:25:53.238 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 623 10/28/2024 02:25:53.238 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.238 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 623 (601.3941764831543 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=155, last_stable_offset=155, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.239 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 10/28/2024 02:25:53.239 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.239 7f56ec1a50f0 [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)])]) 10/28/2024 02:25:53.239 7f56ec1a50f0 [kafka.conn] [DEBUG]: Request 628: 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)])]) 10/28/2024 02:25:53.253 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 625 10/28/2024 02:25:53.253 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.253 7f56ec1a1b70 [kafka.conn] [DEBUG]: Response 625 (601.1221408843994 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=220, last_stable_offset=220, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.265 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:53.265 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.265 7f56ec1e0630 [kafka.conn] [DEBUG]: Response 591 (601.1004447937012 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.306 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 10/28/2024 02:25:53.306 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.306 7f56ef2bfeb8 [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=6, max_bytes=1048576)])]) 10/28/2024 02:25:53.306 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Request 588: 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=6, max_bytes=1048576)])]) 10/28/2024 02:25:53.351 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 616 10/28/2024 02:25:53.351 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.351 7f56ec1a58d0 [kafka.conn] [DEBUG]: Response 616 (601.9241809844971 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=172, last_stable_offset=172, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.357 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 622 10/28/2024 02:25:53.357 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.357 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 622 (601.4194488525391 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=125, last_stable_offset=125, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.418 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:53.418 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.418 7f56ef2f50f0 [kafka.conn] [DEBUG]: Response 590 (601.3152599334717 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.419 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 586 10/28/2024 02:25:53.419 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.419 7f56ec12c390 [kafka.conn] [DEBUG]: Response 586 (600.9311676025391 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.419 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15 10/28/2024 02:25:53.420 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.420 7f56ef2f56d8 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:53.420 7f56ef2f56d8 [kafka.conn] [DEBUG]: Request 591: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:53.524 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 634 10/28/2024 02:25:53.524 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.524 7f56ec1a1e10 [kafka.conn] [DEBUG]: Response 634 (603.496789932251 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=287, last_stable_offset=287, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.525 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 598 10/28/2024 02:25:53.525 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.525 7f56ec1e0f60 [kafka.conn] [DEBUG]: Response 598 (603.5139560699463 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.525 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 619 10/28/2024 02:25:53.525 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.525 7f56ec1a5390 [kafka.conn] [DEBUG]: Response 619 (603.4436225891113 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=166, last_stable_offset=166, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.577 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 632 10/28/2024 02:25:53.577 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.577 7f56ec1a5e10 [kafka.conn] [DEBUG]: Response 632 (601.4034748077393 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=122, last_stable_offset=122, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.581 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 10 10/28/2024 02:25:53.581 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.581 7f56ef2f5e10 [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=10, max_bytes=1048576)])]) 10/28/2024 02:25:53.582 7f56ef2f5e10 [kafka.conn] [DEBUG]: Request 590: 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=10, max_bytes=1048576)])]) 10/28/2024 02:25:53.583 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 584 10/28/2024 02:25:53.583 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.583 7f56ef3718d0 [kafka.conn] [DEBUG]: Response 584 (601.7031669616699 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.583 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 620 10/28/2024 02:25:53.583 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.584 7f56ec1a1828 [kafka.conn] [DEBUG]: Response 620 (601.7496585845947 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.584 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 61 10/28/2024 02:25:53.584 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.584 7f56ec12c630 [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=61, max_bytes=1048576)])]) 10/28/2024 02:25:53.584 7f56ec12c630 [kafka.conn] [DEBUG]: Request 601: 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=61, max_bytes=1048576)])]) 10/28/2024 02:25:53.585 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 10/28/2024 02:25:53.585 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.585 7f56ef2c7240 [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)])]) 10/28/2024 02:25:53.585 7f56ef2c7240 [kafka.conn] [DEBUG]: Request 585: 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)])]) 10/28/2024 02:25:53.586 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 625 10/28/2024 02:25:53.586 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.586 7f56ec12c0f0 [kafka.conn] [DEBUG]: Response 625 (602.280855178833 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=139, last_stable_offset=139, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.681 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 606 10/28/2024 02:25:53.682 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.682 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Response 606 (601.9768714904785 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, last_stable_offset=82, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.682 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 621 10/28/2024 02:25:53.682 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.683 7f56ef2c74e0 [kafka.conn] [DEBUG]: Response 621 (602.0565032958984 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.718 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 923 10/28/2024 02:25:53.718 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.718 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 923 (601.3898849487305 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2449, last_stable_offset=2449, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t\x90\x00\x00\x01\x04\x00\x00\x00\x00\x028\xe0\xd0w\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...')])]) 10/28/2024 02:25:53.719 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2448 to buffered record list 10/28/2024 02:25:53.747 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:53.747 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.747 7f56ef3e28d0 [kafka.conn] [DEBUG]: Response 591 (601.3283729553223 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.750 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 15 10/28/2024 02:25:53.750 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.750 7f56ec1e0cc0 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:53.750 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Request 592: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:53.752 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 597 10/28/2024 02:25:53.752 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.752 7f56ec12c8d0 [kafka.conn] [DEBUG]: Response 597 (601.691722869873 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.753 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:53.753 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.753 7f56ef2f5438 [kafka.conn] [DEBUG]: Response 589 (601.6519069671631 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.754 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 10/28/2024 02:25:53.754 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.755 7f56ec1e0780 [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)])]) 10/28/2024 02:25:53.755 7f56ec1e0780 [kafka.conn] [DEBUG]: Request 597: 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)])]) 10/28/2024 02:25:53.756 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 10/28/2024 02:25:53.756 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.756 7f56ec1e0a20 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:53.756 7f56ec1e0a20 [kafka.conn] [DEBUG]: Request 586: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:53.757 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 584 10/28/2024 02:25:53.757 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.757 7f56ef3ba240 [kafka.conn] [DEBUG]: Response 584 (600.7983684539795 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'')])]) 10/28/2024 02:25:53.820 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2449 10/28/2024 02:25:53.820 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.820 7f56ef2c7780 [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=2449, max_bytes=1048576)])]) 10/28/2024 02:25:53.820 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 924: 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=2449, max_bytes=1048576)])]) 10/28/2024 02:25:53.839 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 155 10/28/2024 02:25:53.839 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.839 7f56ec1a5630 [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=155, max_bytes=1048576)])]) 10/28/2024 02:25:53.840 7f56ec1a5630 [kafka.conn] [DEBUG]: Request 624: 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=155, max_bytes=1048576)])]) 10/28/2024 02:25:53.840 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 628 10/28/2024 02:25:53.840 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.841 7f56ec1a50f0 [kafka.conn] [DEBUG]: Response 628 (601.2110710144043 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'')])]) 10/28/2024 02:25:53.854 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 220 10/28/2024 02:25:53.854 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.854 7f56ec1a1b70 [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=220, max_bytes=1048576)])]) 10/28/2024 02:25:53.854 7f56ec1a1b70 [kafka.conn] [DEBUG]: Request 626: 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=220, max_bytes=1048576)])]) 10/28/2024 02:25:53.866 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 32 10/28/2024 02:25:53.866 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.866 7f56ec1e0630 [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=32, max_bytes=1048576)])]) 10/28/2024 02:25:53.866 7f56ec1e0630 [kafka.conn] [DEBUG]: Request 592: 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=32, max_bytes=1048576)])]) 10/28/2024 02:25:53.907 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 588 10/28/2024 02:25:53.908 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.908 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Response 588 (601.3712882995605 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:53.952 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 172 10/28/2024 02:25:53.952 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.952 7f56ec1a58d0 [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=172, max_bytes=1048576)])]) 10/28/2024 02:25:53.953 7f56ec1a58d0 [kafka.conn] [DEBUG]: Request 617: 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=172, max_bytes=1048576)])]) 10/28/2024 02:25:53.958 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 125 10/28/2024 02:25:53.958 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:53.958 7f56ec1a5b70 [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=125, max_bytes=1048576)])]) 10/28/2024 02:25:53.958 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 623: 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=125, max_bytes=1048576)])]) 10/28/2024 02:25:53.959 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 623 10/28/2024 02:25:53.959 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:53.959 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 623 (0.7662773132324219 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=126, last_stable_offset=126, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00}\x00\x00\x01!\x00\x00\x00\x00\x02\xcbO\xaa\xef\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\xdc\x03\x00\x00\x00\x9e\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:53.959 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 125 to buffered record list 10/28/2024 02:25:54.019 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 10/28/2024 02:25:54.019 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.019 7f56ef2f50f0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:54.020 7f56ef2f50f0 [kafka.conn] [DEBUG]: Request 591: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:54.020 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 8 10/28/2024 02:25:54.020 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.020 7f56ec12c390 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:54.020 7f56ec12c390 [kafka.conn] [DEBUG]: Request 587: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:54.021 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:54.021 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.021 7f56ef2f56d8 [kafka.conn] [DEBUG]: Response 591 (601.3472080230713 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.060 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 126 10/28/2024 02:25:54.060 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.060 7f56ec1a5b70 [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=126, max_bytes=1048576)])]) 10/28/2024 02:25:54.061 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 624: 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=126, max_bytes=1048576)])]) 10/28/2024 02:25:54.125 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 287 10/28/2024 02:25:54.125 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.125 7f56ec1a1e10 [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=287, max_bytes=1048576)])]) 10/28/2024 02:25:54.125 7f56ec1a1e10 [kafka.conn] [DEBUG]: Request 635: 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=287, max_bytes=1048576)])]) 10/28/2024 02:25:54.126 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 10/28/2024 02:25:54.126 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.126 7f56ec1e0f60 [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=35, max_bytes=1048576)])]) 10/28/2024 02:25:54.126 7f56ec1e0f60 [kafka.conn] [DEBUG]: Request 599: 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=35, max_bytes=1048576)])]) 10/28/2024 02:25:54.126 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 166 10/28/2024 02:25:54.127 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.127 7f56ec1a5390 [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=166, max_bytes=1048576)])]) 10/28/2024 02:25:54.127 7f56ec1a5390 [kafka.conn] [DEBUG]: Request 620: 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=166, max_bytes=1048576)])]) 10/28/2024 02:25:54.127 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 620 10/28/2024 02:25:54.127 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.128 7f56ec1a5390 [kafka.conn] [DEBUG]: Response 620 (0.7784366607666016 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, last_stable_offset=168, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xa6\x00\x00\x02\x16\x00\x00\x00\x00\x02$\xaf\x10\xc0\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\xe0\x03\x00\x00\x00\xa2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.128 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 166 to buffered record list 10/28/2024 02:25:54.178 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 10/28/2024 02:25:54.178 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.178 7f56ec1a5e10 [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=122, max_bytes=1048576)])]) 10/28/2024 02:25:54.178 7f56ec1a5e10 [kafka.conn] [DEBUG]: Request 633: 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=122, max_bytes=1048576)])]) 10/28/2024 02:25:54.179 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 633 10/28/2024 02:25:54.179 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.179 7f56ec1a5e10 [kafka.conn] [DEBUG]: Response 633 (0.8540153503417969 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00z\x00\x00\x01(\x00\x00\x00\x00\x02qMV\x0e\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\xea\x03\x00\x00\x00\xac\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.179 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-21', partition=0) with offset 122 to buffered record list 10/28/2024 02:25:54.182 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:54.183 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.183 7f56ef2f5e10 [kafka.conn] [DEBUG]: Response 590 (601.1996269226074 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.183 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 10/28/2024 02:25:54.183 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.183 7f56ef3718d0 [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=0, max_bytes=1048576)])]) 10/28/2024 02:25:54.184 7f56ef3718d0 [kafka.conn] [DEBUG]: Request 585: 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=0, max_bytes=1048576)])]) 10/28/2024 02:25:54.184 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 118 10/28/2024 02:25:54.184 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.184 7f56ec1a1828 [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=118, max_bytes=1048576)])]) 10/28/2024 02:25:54.184 7f56ec1a1828 [kafka.conn] [DEBUG]: Request 621: 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=118, max_bytes=1048576)])]) 10/28/2024 02:25:54.185 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 601 10/28/2024 02:25:54.185 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.185 7f56ec12c630 [kafka.conn] [DEBUG]: Response 601 (601.0391712188721 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.186 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 585 10/28/2024 02:25:54.186 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.186 7f56ef2c7240 [kafka.conn] [DEBUG]: Response 585 (601.0570526123047 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'')])]) 10/28/2024 02:25:54.187 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 139 10/28/2024 02:25:54.187 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.187 7f56ec12c0f0 [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=139, max_bytes=1048576)])]) 10/28/2024 02:25:54.187 7f56ec12c0f0 [kafka.conn] [DEBUG]: Request 626: 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=139, max_bytes=1048576)])]) 10/28/2024 02:25:54.229 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168 10/28/2024 02:25:54.229 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.229 7f56ec1a5390 [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=168, max_bytes=1048576)])]) 10/28/2024 02:25:54.229 7f56ec1a5390 [kafka.conn] [DEBUG]: Request 621: 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=168, max_bytes=1048576)])]) 10/28/2024 02:25:54.280 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 124 10/28/2024 02:25:54.280 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.280 7f56ec1a5e10 [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=124, max_bytes=1048576)])]) 10/28/2024 02:25:54.281 7f56ec1a5e10 [kafka.conn] [DEBUG]: Request 634: 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=124, max_bytes=1048576)])]) 10/28/2024 02:25:54.282 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 82 10/28/2024 02:25:54.282 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.282 7f56ef2f5ac8 [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=82, max_bytes=1048576)])]) 10/28/2024 02:25:54.283 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Request 607: 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=82, max_bytes=1048576)])]) 10/28/2024 02:25:54.283 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 141 10/28/2024 02:25:54.283 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.283 7f56ef2c74e0 [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=141, max_bytes=1048576)])]) 10/28/2024 02:25:54.283 7f56ef2c74e0 [kafka.conn] [DEBUG]: Request 622: 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=141, max_bytes=1048576)])]) 10/28/2024 02:25:54.348 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 18 10/28/2024 02:25:54.348 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.348 7f56ef3e28d0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:54.348 7f56ef3e28d0 [kafka.conn] [DEBUG]: Request 592: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:54.351 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 592 10/28/2024 02:25:54.351 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.351 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Response 592 (601.0069847106934 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.353 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 54 10/28/2024 02:25:54.353 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.353 7f56ec12c8d0 [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=54, max_bytes=1048576)])]) 10/28/2024 02:25:54.353 7f56ec12c8d0 [kafka.conn] [DEBUG]: Request 598: 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=54, max_bytes=1048576)])]) 10/28/2024 02:25:54.354 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 13 10/28/2024 02:25:54.354 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.354 7f56ef2f5438 [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=13, max_bytes=1048576)])]) 10/28/2024 02:25:54.354 7f56ef2f5438 [kafka.conn] [DEBUG]: Request 590: 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=13, max_bytes=1048576)])]) 10/28/2024 02:25:54.355 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 597 10/28/2024 02:25:54.356 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.356 7f56ec1e0780 [kafka.conn] [DEBUG]: Response 597 (600.9438037872314 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'')])]) 10/28/2024 02:25:54.357 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 586 10/28/2024 02:25:54.357 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.357 7f56ec1e0a20 [kafka.conn] [DEBUG]: Response 586 (600.8048057556152 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.357 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/28/2024 02:25:54.357 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.357 7f56ef3ba240 [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)])]) 10/28/2024 02:25:54.358 7f56ef3ba240 [kafka.conn] [DEBUG]: Request 585: 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)])]) 10/28/2024 02:25:54.425 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 924 10/28/2024 02:25:54.425 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.425 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 924 (605.0360202789307 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2451, last_stable_offset=2451, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t\x91\x00\x00\x01\xcd\x00\x00\x00\x00\x02\x1aH\x85\xf9\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\x96\x03\x00\x00\x00\xd8\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.425 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2449 to buffered record list 10/28/2024 02:25:54.441 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 624 10/28/2024 02:25:54.441 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.441 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 624 (601.4182567596436 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x9b\x00\x00\x013\x00\x00\x00\x00\x02\x00,Ba\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\x80\x04\x00\x00\x00\xc2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.441 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 155 to buffered record list 10/28/2024 02:25:54.442 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 160 10/28/2024 02:25:54.442 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.442 7f56ec1a50f0 [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)])]) 10/28/2024 02:25:54.443 7f56ec1a50f0 [kafka.conn] [DEBUG]: Request 629: 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)])]) 10/28/2024 02:25:54.443 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 629 10/28/2024 02:25:54.443 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.443 7f56ec1a50f0 [kafka.conn] [DEBUG]: Response 629 (1.424551010131836 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xa0\x00\x00\x01\x17\x00\x00\x00\x00\x02aq\x01\xb2\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\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.444 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 160 to buffered record list 10/28/2024 02:25:54.455 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 626 10/28/2024 02:25:54.455 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.455 7f56ec1a1b70 [kafka.conn] [DEBUG]: Response 626 (601.1507511138916 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=223, last_stable_offset=223, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xdc\x00\x00\x02\xf9\x00\x00\x00\x00\x02\xd1X},\x00\x00\x00\x00\x00\x02\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\x03\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.456 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 220 to buffered record list 10/28/2024 02:25:54.467 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 592 10/28/2024 02:25:54.467 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.467 7f56ec1e0630 [kafka.conn] [DEBUG]: Response 592 (601.081132888794 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.508 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 10/28/2024 02:25:54.509 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.509 7f56ef2bfeb8 [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=6, max_bytes=1048576)])]) 10/28/2024 02:25:54.509 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Request 589: 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=6, max_bytes=1048576)])]) 10/28/2024 02:25:54.526 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2451 10/28/2024 02:25:54.526 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.526 7f56ef2c7780 [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=2451, max_bytes=1048576)])]) 10/28/2024 02:25:54.527 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 925: 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=2451, max_bytes=1048576)])]) 10/28/2024 02:25:54.528 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 925 10/28/2024 02:25:54.528 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.528 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 925 (1.1684894561767578 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2452, last_stable_offset=2452, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t\x93\x00\x00\x01\x04\x00\x00\x00\x00\x02q!\x8d\x16\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...')])]) 10/28/2024 02:25:54.528 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2451 to buffered record list 10/28/2024 02:25:54.542 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 156 10/28/2024 02:25:54.542 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.542 7f56ec1a5630 [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=156, max_bytes=1048576)])]) 10/28/2024 02:25:54.543 7f56ec1a5630 [kafka.conn] [DEBUG]: Request 625: 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=156, max_bytes=1048576)])]) 10/28/2024 02:25:54.543 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 625 10/28/2024 02:25:54.543 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.543 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 625 (0.9250640869140625 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=157, last_stable_offset=157, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x9c\x00\x00\x01)\x00\x00\x00\x00\x02\x15\xa3\xf8\xbd\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\xec\x03\x00\x00\x00\xae\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.544 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 156 to buffered record list 10/28/2024 02:25:54.544 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 162 10/28/2024 02:25:54.544 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.545 7f56ec1a50f0 [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=162, max_bytes=1048576)])]) 10/28/2024 02:25:54.545 7f56ec1a50f0 [kafka.conn] [DEBUG]: Request 630: 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=162, max_bytes=1048576)])]) 10/28/2024 02:25:54.553 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 617 10/28/2024 02:25:54.554 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.554 7f56ec1a58d0 [kafka.conn] [DEBUG]: Response 617 (601.2091636657715 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=177, last_stable_offset=177, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xac\x00\x00\x01#\x00\x00\x00\x00\x02c-$s\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\xe0\x03\x00\x00\x00\xa2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.554 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 172 to buffered record list 10/28/2024 02:25:54.556 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 223 10/28/2024 02:25:54.556 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.557 7f56ec1a1b70 [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=223, max_bytes=1048576)])]) 10/28/2024 02:25:54.557 7f56ec1a1b70 [kafka.conn] [DEBUG]: Request 627: 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=223, max_bytes=1048576)])]) 10/28/2024 02:25:54.621 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:54.621 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.622 7f56ef2f50f0 [kafka.conn] [DEBUG]: Response 591 (602.031946182251 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.622 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15 10/28/2024 02:25:54.622 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.622 7f56ef2f56d8 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:54.623 7f56ef2f56d8 [kafka.conn] [DEBUG]: Request 592: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:54.623 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 587 10/28/2024 02:25:54.623 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.623 7f56ec12c390 [kafka.conn] [DEBUG]: Response 587 (602.8225421905518 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.629 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2452 10/28/2024 02:25:54.629 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.629 7f56ef2c7780 [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=2452, max_bytes=1048576)])]) 10/28/2024 02:25:54.629 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 926: 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=2452, max_bytes=1048576)])]) 10/28/2024 02:25:54.644 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 157 10/28/2024 02:25:54.645 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.645 7f56ec1a5630 [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=157, max_bytes=1048576)])]) 10/28/2024 02:25:54.645 7f56ec1a5630 [kafka.conn] [DEBUG]: Request 626: 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=157, max_bytes=1048576)])]) 10/28/2024 02:25:54.655 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 177 10/28/2024 02:25:54.655 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.655 7f56ec1a58d0 [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=177, max_bytes=1048576)])]) 10/28/2024 02:25:54.655 7f56ec1a58d0 [kafka.conn] [DEBUG]: Request 618: 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=177, max_bytes=1048576)])]) 10/28/2024 02:25:54.661 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 624 10/28/2024 02:25:54.661 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.662 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 624 (601.1605262756348 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=126, last_stable_offset=126, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.727 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 635 10/28/2024 02:25:54.727 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.727 7f56ec1a1e10 [kafka.conn] [DEBUG]: Response 635 (602.0593643188477 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=289, last_stable_offset=289, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x01\x1f\x00\x00\x01%\x00\x00\x00\x00\x02El\xcfO\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\xe4\x03\x00\x00\x00\xa6\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.727 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 287 to buffered record list 10/28/2024 02:25:54.728 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 599 10/28/2024 02:25:54.728 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.728 7f56ec1e0f60 [kafka.conn] [DEBUG]: Response 599 (602.2231578826904 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.784 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 10 10/28/2024 02:25:54.784 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.784 7f56ef2f5e10 [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=10, max_bytes=1048576)])]) 10/28/2024 02:25:54.785 7f56ef2f5e10 [kafka.conn] [DEBUG]: Request 591: 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=10, max_bytes=1048576)])]) 10/28/2024 02:25:54.785 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 585 10/28/2024 02:25:54.785 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.785 7f56ef3718d0 [kafka.conn] [DEBUG]: Response 585 (601.8111705780029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.786 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 61 10/28/2024 02:25:54.786 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.786 7f56ec12c630 [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=61, max_bytes=1048576)])]) 10/28/2024 02:25:54.786 7f56ec12c630 [kafka.conn] [DEBUG]: Request 602: 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=61, max_bytes=1048576)])]) 10/28/2024 02:25:54.787 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 621 10/28/2024 02:25:54.787 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.787 7f56ec1a1828 [kafka.conn] [DEBUG]: Response 621 (602.5586128234863 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.787 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 10/28/2024 02:25:54.787 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.788 7f56ef2c7240 [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)])]) 10/28/2024 02:25:54.788 7f56ef2c7240 [kafka.conn] [DEBUG]: Request 586: 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)])]) 10/28/2024 02:25:54.788 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 626 10/28/2024 02:25:54.788 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.789 7f56ec12c0f0 [kafka.conn] [DEBUG]: Response 626 (601.2587547302246 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x8b\x00\x00\x01\x1b\x00\x00\x00\x00\x02\x8c\x8eO\x9f\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\xd0\x03\x00\x00\x00\x92\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 10/28/2024 02:25:54.789 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 139 to buffered record list 10/28/2024 02:25:54.828 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 289 10/28/2024 02:25:54.828 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.829 7f56ec1a1e10 [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=289, max_bytes=1048576)])]) 10/28/2024 02:25:54.829 7f56ec1a1e10 [kafka.conn] [DEBUG]: Request 636: 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=289, max_bytes=1048576)])]) 10/28/2024 02:25:54.830 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 621 10/28/2024 02:25:54.830 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.830 7f56ec1a5390 [kafka.conn] [DEBUG]: Response 621 (601.1464595794678 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, last_stable_offset=168, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.882 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 634 10/28/2024 02:25:54.882 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.882 7f56ec1a5e10 [kafka.conn] [DEBUG]: Response 634 (601.3810634613037 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.884 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 607 10/28/2024 02:25:54.884 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.884 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Response 607 (601.7205715179443 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, last_stable_offset=82, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.885 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 622 10/28/2024 02:25:54.885 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.885 7f56ef2c74e0 [kafka.conn] [DEBUG]: Response 622 (601.7341613769531 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.890 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 141 10/28/2024 02:25:54.890 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.890 7f56ec12c0f0 [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=141, max_bytes=1048576)])]) 10/28/2024 02:25:54.890 7f56ec12c0f0 [kafka.conn] [DEBUG]: Request 627: 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=141, max_bytes=1048576)])]) 10/28/2024 02:25:54.949 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 592 10/28/2024 02:25:54.950 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.950 7f56ef3e28d0 [kafka.conn] [DEBUG]: Response 592 (601.4328002929688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.952 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 15 10/28/2024 02:25:54.952 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.952 7f56ec1e0cc0 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:54.952 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Request 593: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:54.955 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 598 10/28/2024 02:25:54.955 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.955 7f56ec12c8d0 [kafka.conn] [DEBUG]: Response 598 (602.0045280456543 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.956 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:54.956 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.956 7f56ef2f5438 [kafka.conn] [DEBUG]: Response 590 (601.8335819244385 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:54.956 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 10/28/2024 02:25:54.956 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.956 7f56ec1e0780 [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)])]) 10/28/2024 02:25:54.957 7f56ec1e0780 [kafka.conn] [DEBUG]: Request 598: 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)])]) 10/28/2024 02:25:54.957 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 10/28/2024 02:25:54.957 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:54.957 7f56ec1e0a20 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:54.958 7f56ec1e0a20 [kafka.conn] [DEBUG]: Request 587: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:54.958 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 585 10/28/2024 02:25:54.958 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:54.959 7f56ef3ba240 [kafka.conn] [DEBUG]: Response 585 (600.9337902069092 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'')])]) 10/28/2024 02:25:55.068 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 32 10/28/2024 02:25:55.068 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.068 7f56ec1e0630 [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=32, max_bytes=1048576)])]) 10/28/2024 02:25:55.069 7f56ec1e0630 [kafka.conn] [DEBUG]: Request 593: 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=32, max_bytes=1048576)])]) 10/28/2024 02:25:55.110 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 589 10/28/2024 02:25:55.110 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.110 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Response 589 (601.4895439147949 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.146 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 630 10/28/2024 02:25:55.146 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.146 7f56ec1a50f0 [kafka.conn] [DEBUG]: Response 630 (601.4401912689209 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.158 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 627 10/28/2024 02:25:55.158 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.158 7f56ec1a1b70 [kafka.conn] [DEBUG]: Response 627 (601.2396812438965 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=223, last_stable_offset=223, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.222 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 10/28/2024 02:25:55.222 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.223 7f56ef2f50f0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:55.223 7f56ef2f50f0 [kafka.conn] [DEBUG]: Request 592: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:55.224 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 8 10/28/2024 02:25:55.224 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.224 7f56ec12c390 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:55.224 7f56ec12c390 [kafka.conn] [DEBUG]: Request 588: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:55.225 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 592 10/28/2024 02:25:55.225 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.225 7f56ef2f56d8 [kafka.conn] [DEBUG]: Response 592 (602.3645401000977 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.230 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 926 10/28/2024 02:25:55.230 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.230 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 926 (601.0024547576904 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2452, last_stable_offset=2452, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.246 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 626 10/28/2024 02:25:55.246 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.246 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 626 (601.2454032897949 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=157, last_stable_offset=157, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.256 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 618 10/28/2024 02:25:55.256 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.256 7f56ec1a58d0 [kafka.conn] [DEBUG]: Response 618 (601.0982990264893 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=177, last_stable_offset=177, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.263 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 126 10/28/2024 02:25:55.263 7f56ec1a5b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.264 7f56ec1a5b70 [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=126, max_bytes=1048576)])]) 10/28/2024 02:25:55.264 7f56ec1a5b70 [kafka.conn] [DEBUG]: Request 625: 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=126, max_bytes=1048576)])]) 10/28/2024 02:25:55.329 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 10/28/2024 02:25:55.330 7f56ec1e0f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.330 7f56ec1e0f60 [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=35, max_bytes=1048576)])]) 10/28/2024 02:25:55.330 7f56ec1e0f60 [kafka.conn] [DEBUG]: Request 600: 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=35, max_bytes=1048576)])]) 10/28/2024 02:25:55.389 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 0 10/28/2024 02:25:55.389 7f56ef3718d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.389 7f56ef3718d0 [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=0, max_bytes=1048576)])]) 10/28/2024 02:25:55.390 7f56ef3718d0 [kafka.conn] [DEBUG]: Request 586: 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=0, max_bytes=1048576)])]) 10/28/2024 02:25:55.390 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 118 10/28/2024 02:25:55.390 7f56ec1a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.390 7f56ec1a1828 [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=118, max_bytes=1048576)])]) 10/28/2024 02:25:55.390 7f56ec1a1828 [kafka.conn] [DEBUG]: Request 622: 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=118, max_bytes=1048576)])]) 10/28/2024 02:25:55.396 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:55.396 7f56ef2f5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.397 7f56ef2f5e10 [kafka.conn] [DEBUG]: Response 591 (611.9849681854248 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=10, last_stable_offset=10, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.397 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 602 10/28/2024 02:25:55.397 7f56ec12c630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.397 7f56ec12c630 [kafka.conn] [DEBUG]: Response 602 (610.9099388122559 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=61, last_stable_offset=61, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.398 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 586 10/28/2024 02:25:55.398 7f56ef2c7240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.398 7f56ef2c7240 [kafka.conn] [DEBUG]: Response 586 (610.1882457733154 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'')])]) 10/28/2024 02:25:55.431 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 168 10/28/2024 02:25:55.431 7f56ec1a5390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.431 7f56ec1a5390 [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=168, max_bytes=1048576)])]) 10/28/2024 02:25:55.432 7f56ec1a5390 [kafka.conn] [DEBUG]: Request 622: 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=168, max_bytes=1048576)])]) 10/28/2024 02:25:55.467 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 636 10/28/2024 02:25:55.467 7f56ec1a1e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.467 7f56ec1a1e10 [kafka.conn] [DEBUG]: Response 636 (638.1473541259766 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=289, last_stable_offset=289, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.484 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 124 10/28/2024 02:25:55.485 7f56ec1a5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.485 7f56ec1a5e10 [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=124, max_bytes=1048576)])]) 10/28/2024 02:25:55.485 7f56ec1a5e10 [kafka.conn] [DEBUG]: Request 635: 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=124, max_bytes=1048576)])]) 10/28/2024 02:25:55.490 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 82 10/28/2024 02:25:55.491 7f56ef2f5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.491 7f56ef2f5ac8 [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=82, max_bytes=1048576)])]) 10/28/2024 02:25:55.491 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Request 608: 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=82, max_bytes=1048576)])]) 10/28/2024 02:25:55.491 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 141 10/28/2024 02:25:55.491 7f56ef2c74e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.491 7f56ef2c74e0 [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=141, max_bytes=1048576)])]) 10/28/2024 02:25:55.492 7f56ef2c74e0 [kafka.conn] [DEBUG]: Request 623: 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=141, max_bytes=1048576)])]) 10/28/2024 02:25:55.494 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 627 10/28/2024 02:25:55.494 7f56ec12c0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.494 7f56ec12c0f0 [kafka.conn] [DEBUG]: Response 627 (604.3546199798584 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.550 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 18 10/28/2024 02:25:55.551 7f56ef3e28d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.551 7f56ef3e28d0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:55.551 7f56ef3e28d0 [kafka.conn] [DEBUG]: Request 593: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:55.553 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 593 10/28/2024 02:25:55.553 7f56ec1e0cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.553 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Response 593 (601.0229587554932 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.556 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 54 10/28/2024 02:25:55.556 7f56ec12c8d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.556 7f56ec12c8d0 [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=54, max_bytes=1048576)])]) 10/28/2024 02:25:55.556 7f56ec12c8d0 [kafka.conn] [DEBUG]: Request 599: 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=54, max_bytes=1048576)])]) 10/28/2024 02:25:55.557 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 13 10/28/2024 02:25:55.557 7f56ef2f5438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.557 7f56ef2f5438 [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=13, max_bytes=1048576)])]) 10/28/2024 02:25:55.557 7f56ef2f5438 [kafka.conn] [DEBUG]: Request 591: 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=13, max_bytes=1048576)])]) 10/28/2024 02:25:55.558 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 598 10/28/2024 02:25:55.558 7f56ec1e0780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.558 7f56ec1e0780 [kafka.conn] [DEBUG]: Response 598 (601.1009216308594 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'')])]) 10/28/2024 02:25:55.558 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 587 10/28/2024 02:25:55.558 7f56ec1e0a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.559 7f56ec1e0a20 [kafka.conn] [DEBUG]: Response 587 (600.9180545806885 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.560 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 10/28/2024 02:25:55.560 7f56ef3ba240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.560 7f56ef3ba240 [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)])]) 10/28/2024 02:25:55.561 7f56ef3ba240 [kafka.conn] [DEBUG]: Request 586: 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)])]) 10/28/2024 02:25:55.669 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 593 10/28/2024 02:25:55.670 7f56ec1e0630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.670 7f56ec1e0630 [kafka.conn] [DEBUG]: Response 593 (601.5868186950684 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.712 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 6 10/28/2024 02:25:55.712 7f56ef2bfeb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.712 7f56ef2bfeb8 [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=6, max_bytes=1048576)])]) 10/28/2024 02:25:55.712 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Request 590: 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=6, max_bytes=1048576)])]) 10/28/2024 02:25:55.747 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 162 10/28/2024 02:25:55.747 7f56ec1a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.747 7f56ec1a50f0 [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=162, max_bytes=1048576)])]) 10/28/2024 02:25:55.747 7f56ec1a50f0 [kafka.conn] [DEBUG]: Request 631: 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=162, max_bytes=1048576)])]) 10/28/2024 02:25:55.759 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 223 10/28/2024 02:25:55.759 7f56ec1a1b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.759 7f56ec1a1b70 [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=223, max_bytes=1048576)])]) 10/28/2024 02:25:55.760 7f56ec1a1b70 [kafka.conn] [DEBUG]: Request 628: 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=223, max_bytes=1048576)])]) 10/28/2024 02:25:55.824 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 592 10/28/2024 02:25:55.826 7f56ef2f50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.827 7f56ef2f50f0 [kafka.conn] [DEBUG]: Response 592 (603.8243770599365 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.827 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 15 10/28/2024 02:25:55.827 7f56ef2f56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.827 7f56ef2f56d8 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:55.828 7f56ef2f56d8 [kafka.conn] [DEBUG]: Request 593: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:55.828 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 588 10/28/2024 02:25:55.828 7f56ec12c390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.828 7f56ec12c390 [kafka.conn] [DEBUG]: Response 588 (604.4576168060303 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.831 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2452 10/28/2024 02:25:55.831 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.831 7f56ef2c7780 [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=2452, max_bytes=1048576)])]) 10/28/2024 02:25:55.831 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 927: 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=2452, max_bytes=1048576)])]) 10/28/2024 02:25:55.832 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 927 10/28/2024 02:25:55.832 7f56ef2c7780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.832 7f56ef2c7780 [kafka.conn] [DEBUG]: Response 927 (0.7355213165283203 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2453, last_stable_offset=2453, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\t\x94\x00\x00\x00\xfa\x00\x00\x00\x00\x02S\xf6A\xc3\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\x8e\x03\x00\x00\x00\xd0\x02ObjectDatabaseInfo:cn-jenkins-de...')])]) 10/28/2024 02:25:55.832 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2452 to buffered record list 10/28/2024 02:25:55.847 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 157 10/28/2024 02:25:55.847 7f56ec1a5630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.847 7f56ec1a5630 [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=157, max_bytes=1048576)])]) 10/28/2024 02:25:55.847 7f56ec1a5630 [kafka.conn] [DEBUG]: Request 627: 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=157, max_bytes=1048576)])]) 10/28/2024 02:25:55.857 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 177 10/28/2024 02:25:55.857 7f56ec1a58d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.857 7f56ec1a58d0 [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=177, max_bytes=1048576)])]) 10/28/2024 02:25:55.858 7f56ec1a58d0 [kafka.conn] [DEBUG]: Request 619: 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=177, max_bytes=1048576)])]) 10/28/2024 02:25:55.865 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 625 10/28/2024 02:25:55.865 7f56ec1a5b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.865 7f56ec1a5b70 [kafka.conn] [DEBUG]: Response 625 (601.2415885925293 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=126, last_stable_offset=126, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.931 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 600 10/28/2024 02:25:55.931 7f56ec1e0f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:55.932 7f56ec1e0f60 [kafka.conn] [DEBUG]: Response 600 (601.6066074371338 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:55.933 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2453 10/28/2024 02:25:55.933 7f56ef2c7780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.933 7f56ef2c7780 [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=2453, max_bytes=1048576)])]) 10/28/2024 02:25:55.933 7f56ef2c7780 [kafka.conn] [DEBUG]: Request 928: 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=2453, max_bytes=1048576)])]) 10/28/2024 02:25:55.997 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 10 10/28/2024 02:25:55.997 7f56ef2f5e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.997 7f56ef2f5e10 [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=10, max_bytes=1048576)])]) 10/28/2024 02:25:55.998 7f56ef2f5e10 [kafka.conn] [DEBUG]: Request 592: 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=10, max_bytes=1048576)])]) 10/28/2024 02:25:55.998 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 61 10/28/2024 02:25:55.998 7f56ec12c630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.998 7f56ec12c630 [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=61, max_bytes=1048576)])]) 10/28/2024 02:25:55.999 7f56ec12c630 [kafka.conn] [DEBUG]: Request 603: 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=61, max_bytes=1048576)])]) 10/28/2024 02:25:55.999 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 10/28/2024 02:25:55.999 7f56ef2c7240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:55.999 7f56ef2c7240 [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)])]) 10/28/2024 02:25:55.999 7f56ef2c7240 [kafka.conn] [DEBUG]: Request 587: 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)])]) 10/28/2024 02:25:56.027 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 586 10/28/2024 02:25:56.027 7f56ef3718d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.027 7f56ef3718d0 [kafka.conn] [DEBUG]: Response 586 (637.2206211090088 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.027 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 622 10/28/2024 02:25:56.028 7f56ec1a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.028 7f56ec1a1828 [kafka.conn] [DEBUG]: Response 622 (637.3159885406494 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=118, last_stable_offset=118, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.068 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 289 10/28/2024 02:25:56.068 7f56ec1a1e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.069 7f56ec1a1e10 [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=289, max_bytes=1048576)])]) 10/28/2024 02:25:56.069 7f56ec1a1e10 [kafka.conn] [DEBUG]: Request 637: 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=289, max_bytes=1048576)])]) 10/28/2024 02:25:56.069 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 622 10/28/2024 02:25:56.070 7f56ec1a5390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.070 7f56ec1a5390 [kafka.conn] [DEBUG]: Response 622 (638.2033824920654 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=168, last_stable_offset=168, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.094 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 635 10/28/2024 02:25:56.094 7f56ec1a5e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.094 7f56ec1a5e10 [kafka.conn] [DEBUG]: Response 635 (609.2686653137207 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=124, last_stable_offset=124, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.095 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 608 10/28/2024 02:25:56.095 7f56ef2f5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.095 7f56ef2f5ac8 [kafka.conn] [DEBUG]: Response 608 (604.2816638946533 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=82, last_stable_offset=82, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.096 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 623 10/28/2024 02:25:56.096 7f56ef2c74e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.096 7f56ef2c74e0 [kafka.conn] [DEBUG]: Response 623 (604.0987968444824 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=141, last_stable_offset=141, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.096 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 141 10/28/2024 02:25:56.096 7f56ec12c0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.096 7f56ec12c0f0 [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=141, max_bytes=1048576)])]) 10/28/2024 02:25:56.097 7f56ec12c0f0 [kafka.conn] [DEBUG]: Request 628: 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=141, max_bytes=1048576)])]) 10/28/2024 02:25:56.152 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 593 10/28/2024 02:25:56.152 7f56ef3e28d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.152 7f56ef3e28d0 [kafka.conn] [DEBUG]: Response 593 (601.506233215332 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=18, last_stable_offset=18, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.154 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 15 10/28/2024 02:25:56.154 7f56ec1e0cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.154 7f56ec1e0cc0 [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=15, max_bytes=1048576)])]) 10/28/2024 02:25:56.154 7f56ec1e0cc0 [kafka.conn] [DEBUG]: Request 594: 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=15, max_bytes=1048576)])]) 10/28/2024 02:25:56.158 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 599 10/28/2024 02:25:56.158 7f56ec12c8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.158 7f56ec12c8d0 [kafka.conn] [DEBUG]: Response 599 (601.5877723693848 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=54, last_stable_offset=54, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.158 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 591 10/28/2024 02:25:56.158 7f56ef2f5438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.158 7f56ef2f5438 [kafka.conn] [DEBUG]: Response 591 (601.5574932098389 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.159 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 41 10/28/2024 02:25:56.159 7f56ec1e0780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.159 7f56ec1e0780 [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)])]) 10/28/2024 02:25:56.159 7f56ec1e0780 [kafka.conn] [DEBUG]: Request 599: 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)])]) 10/28/2024 02:25:56.160 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 8 10/28/2024 02:25:56.160 7f56ec1e0a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.160 7f56ec1e0a20 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:56.160 7f56ec1e0a20 [kafka.conn] [DEBUG]: Request 588: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:56.161 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 586 10/28/2024 02:25:56.161 7f56ef3ba240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.161 7f56ef3ba240 [kafka.conn] [DEBUG]: Response 586 (600.9311676025391 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'')])]) 10/28/2024 02:25:56.271 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 32 10/28/2024 02:25:56.271 7f56ec1e0630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.271 7f56ec1e0630 [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=32, max_bytes=1048576)])]) 10/28/2024 02:25:56.271 7f56ec1e0630 [kafka.conn] [DEBUG]: Request 594: 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=32, max_bytes=1048576)])]) 10/28/2024 02:25:56.313 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 590 10/28/2024 02:25:56.313 7f56ef2bfeb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.314 7f56ef2bfeb8 [kafka.conn] [DEBUG]: Response 590 (601.3979911804199 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=6, last_stable_offset=6, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.348 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 631 10/28/2024 02:25:56.349 7f56ec1a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.349 7f56ec1a50f0 [kafka.conn] [DEBUG]: Response 631 (601.3283729553223 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=162, last_stable_offset=162, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.361 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 628 10/28/2024 02:25:56.361 7f56ec1a1b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.361 7f56ec1a1b70 [kafka.conn] [DEBUG]: Response 628 (601.1595726013184 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=223, last_stable_offset=223, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.427 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18 10/28/2024 02:25:56.428 7f56ef2f50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.428 7f56ef2f50f0 [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=18, max_bytes=1048576)])]) 10/28/2024 02:25:56.428 7f56ef2f50f0 [kafka.conn] [DEBUG]: Request 593: 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=18, max_bytes=1048576)])]) 10/28/2024 02:25:56.429 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 8 10/28/2024 02:25:56.429 7f56ec12c390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/28/2024 02:25:56.429 7f56ec12c390 [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=8, max_bytes=1048576)])]) 10/28/2024 02:25:56.429 7f56ec12c390 [kafka.conn] [DEBUG]: Request 589: 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=8, max_bytes=1048576)])]) 10/28/2024 02:25:56.430 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 593 10/28/2024 02:25:56.430 7f56ef2f56d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.430 7f56ef2f56d8 [kafka.conn] [DEBUG]: Response 593 (602.5972366333008 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=15, last_stable_offset=15, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.448 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 627 10/28/2024 02:25:56.449 7f56ec1a5630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 10/28/2024 02:25:56.449 7f56ec1a5630 [kafka.conn] [DEBUG]: Response 627 (601.3646125793457 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=157, last_stable_offset=157, aborted_transactions=NULL, message_set=b'')])]) 10/28/2024 02:25:56.459 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 619 10/28/2024 02:25:56.459 7f56ec1a58d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4