01/20/2025 02:18:02.906 7fb0334b5588 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:02.908 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 01/20/2025 02:18:02.909 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:02.909 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:02.909 7fb0334b5cc0 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:02.911 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:02.911 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.912 7fb0334cf048 [kafka.conn] [DEBUG]: Response 280 (602.5590896606445 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:02.912 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 461 01/20/2025 02:18:02.913 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.913 7fb0334a0ac8 [kafka.conn] [DEBUG]: Response 461 (602.7183532714844 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4037, last_stable_offset=4037, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xc4\x00\x00\x01\x02\x00\x00\x00\x00\x02\x8a\x00U\xb3\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9e\x03\x00\x00\x00\xe0\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 01/20/2025 02:18:02.913 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4036 to buffered record list 01/20/2025 02:18:02.914 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 277 01/20/2025 02:18:02.914 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.914 7fb0330fa588 [kafka.conn] [DEBUG]: Response 277 (603.203296661377 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'')])]) 01/20/2025 02:18:02.914 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 226 01/20/2025 02:18:02.914 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:02.915 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: 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=226, max_bytes=1048576)])]) 01/20/2025 02:18:02.915 7fb03d9d8630 [kafka.conn] [DEBUG]: Request 323: 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=226, max_bytes=1048576)])]) 01/20/2025 02:18:02.915 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 311 01/20/2025 02:18:02.916 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.916 7fb0334cb048 [kafka.conn] [DEBUG]: Response 311 (604.367733001709 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=190, last_stable_offset=190, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:02.916 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 326 01/20/2025 02:18:02.916 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.916 7fb0334c2b70 [kafka.conn] [DEBUG]: Response 326 (603.5668849945068 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=330, last_stable_offset=330, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:02.940 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 55 01/20/2025 02:18:02.940 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:02.940 7fb032f89048 [kafka.protocol.parser] [DEBUG]: 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=55, max_bytes=1048576)])]) 01/20/2025 02:18:02.940 7fb032f89048 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 01/20/2025 02:18:02.970 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:02.970 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.971 7fb0334cff60 [kafka.conn] [DEBUG]: Response 280 (601.9206047058105 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:02.972 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 321 01/20/2025 02:18:02.972 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:02.972 7fb0334cb240 [kafka.conn] [DEBUG]: Response 321 (602.4148464202881 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=217, last_stable_offset=217, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.006 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 1 01/20/2025 02:18:03.006 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.006 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: 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=1, max_bytes=1048576)])]) 01/20/2025 02:18:03.006 7fb0334cf630 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:03.014 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4037 01/20/2025 02:18:03.014 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.014 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: 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=4037, max_bytes=1048576)])]) 01/20/2025 02:18:03.014 7fb0334a0ac8 [kafka.conn] [DEBUG]: Request 462: 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=4037, max_bytes=1048576)])]) 01/20/2025 02:18:03.019 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 57 01/20/2025 02:18:03.019 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.019 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: 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=57, max_bytes=1048576)])]) 01/20/2025 02:18:03.020 7fb0334b8198 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=57, max_bytes=1048576)])]) 01/20/2025 02:18:03.025 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/20/2025 02:18:03.025 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.025 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:03.025 7fb0334a7cc0 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:03.031 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 01/20/2025 02:18:03.031 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.031 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:03.032 7fb0334b5d68 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:03.058 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 156 01/20/2025 02:18:03.058 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.058 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 01/20/2025 02:18:03.059 7fb0339e9f60 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=156, max_bytes=1048576)])]) 01/20/2025 02:18:03.106 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 01/20/2025 02:18:03.107 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.107 7fb0334cb390 [kafka.conn] [DEBUG]: Response 291 (601.3269424438477 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=97, last_stable_offset=97, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.107 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 227 01/20/2025 02:18:03.107 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.107 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: 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=227, max_bytes=1048576)])]) 01/20/2025 02:18:03.108 7fb0334cbd68 [kafka.conn] [DEBUG]: Request 321: 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=227, max_bytes=1048576)])]) 01/20/2025 02:18:03.124 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:03.124 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.124 7fb0330fa780 [kafka.conn] [DEBUG]: Response 278 (601.2015342712402 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.125 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 01/20/2025 02:18:03.125 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.125 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:03.125 7fb0334b5eb8 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:03.167 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 01/20/2025 02:18:03.167 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.167 7fb0334cb630 [kafka.conn] [DEBUG]: Response 296 (601.3100147247314 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=119, last_stable_offset=119, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.196 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 13 01/20/2025 02:18:03.196 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.196 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: 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=13, max_bytes=1048576)])]) 01/20/2025 02:18:03.196 7fb0334cf978 [kafka.conn] [DEBUG]: Request 284: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 01/20/2025 02:18:03.247 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 01/20/2025 02:18:03.247 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.247 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:03.248 7fb033de5ac8 [kafka.conn] [DEBUG]: Request 299: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 01/20/2025 02:18:03.294 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 01/20/2025 02:18:03.295 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.295 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: 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=59, max_bytes=1048576)])]) 01/20/2025 02:18:03.295 7fb032fb20f0 [kafka.conn] [DEBUG]: Request 292: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=59, max_bytes=1048576)])]) 01/20/2025 02:18:03.296 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 01/20/2025 02:18:03.296 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.296 7fb03346e4e0 [kafka.conn] [DEBUG]: Response 286 (601.0839939117432 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=29, last_stable_offset=29, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.331 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 49 01/20/2025 02:18:03.331 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.332 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: 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=49, max_bytes=1048576)])]) 01/20/2025 02:18:03.332 7fb033de5c18 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=49, max_bytes=1048576)])]) 01/20/2025 02:18:03.333 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 01/20/2025 02:18:03.333 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.333 7fb0334b8390 [kafka.conn] [DEBUG]: Response 292 (601.7847061157227 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.338 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 36 01/20/2025 02:18:03.338 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.338 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:03.338 7fb0334ab6d8 [kafka.conn] [DEBUG]: Request 286: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 01/20/2025 02:18:03.407 7fb033de5780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 150 01/20/2025 02:18:03.407 7fb033de5780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.408 7fb033de5780 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 01/20/2025 02:18:03.408 7fb033de5780 [kafka.conn] [DEBUG]: Request 302: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=150, max_bytes=1048576)])]) 01/20/2025 02:18:03.410 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 43 01/20/2025 02:18:03.410 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.410 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: 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=43, max_bytes=1048576)])]) 01/20/2025 02:18:03.410 7fb03346ef60 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=43, max_bytes=1048576)])]) 01/20/2025 02:18:03.507 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:03.507 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.507 7fb0334b5588 [kafka.conn] [DEBUG]: Response 278 (601.820707321167 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.510 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:03.510 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.510 7fb0334b5cc0 [kafka.conn] [DEBUG]: Response 278 (601.1922359466553 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.512 7fb0334cf048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 8 01/20/2025 02:18:03.512 7fb0334cf048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.512 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: 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=8, max_bytes=1048576)])]) 01/20/2025 02:18:03.513 7fb0334cf048 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 01/20/2025 02:18:03.515 7fb0330fa588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 01/20/2025 02:18:03.515 7fb0330fa588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.515 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:03.515 7fb0330fa588 [kafka.conn] [DEBUG]: Request 278: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:03.516 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 190 01/20/2025 02:18:03.516 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.516 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: 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=190, max_bytes=1048576)])]) 01/20/2025 02:18:03.516 7fb0334cb048 [kafka.conn] [DEBUG]: Request 312: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=190, max_bytes=1048576)])]) 01/20/2025 02:18:03.517 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 330 01/20/2025 02:18:03.517 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.517 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: 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=330, max_bytes=1048576)])]) 01/20/2025 02:18:03.517 7fb0334c2b70 [kafka.conn] [DEBUG]: Request 327: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=330, max_bytes=1048576)])]) 01/20/2025 02:18:03.517 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 323 01/20/2025 02:18:03.517 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.518 7fb03d9d8630 [kafka.conn] [DEBUG]: Response 323 (602.7798652648926 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=226, last_stable_offset=226, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.541 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 01/20/2025 02:18:03.542 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.542 7fb032f89048 [kafka.conn] [DEBUG]: Response 295 (601.4482975006104 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=55, last_stable_offset=55, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.572 7fb0334cff60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 8 01/20/2025 02:18:03.572 7fb0334cff60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.572 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: 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=8, max_bytes=1048576)])]) 01/20/2025 02:18:03.572 7fb0334cff60 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 01/20/2025 02:18:03.573 7fb0334cb240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 217 01/20/2025 02:18:03.573 7fb0334cb240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.573 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: 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=217, max_bytes=1048576)])]) 01/20/2025 02:18:03.573 7fb0334cb240 [kafka.conn] [DEBUG]: Request 322: 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=217, max_bytes=1048576)])]) 01/20/2025 02:18:03.608 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:03.608 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.608 7fb0334cf630 [kafka.conn] [DEBUG]: Response 278 (601.7346382141113 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.615 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 462 01/20/2025 02:18:03.615 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.616 7fb0334a0ac8 [kafka.conn] [DEBUG]: Response 462 (601.2954711914062 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4038, last_stable_offset=4038, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xc5\x00\x00\x01\x04\x00\x00\x00\x00\x02<\x05\xde\xe2\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...')])]) 01/20/2025 02:18:03.616 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4037 to buffered record list 01/20/2025 02:18:03.620 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 01/20/2025 02:18:03.621 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.621 7fb0334b8198 [kafka.conn] [DEBUG]: Response 294 (601.2461185455322 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.626 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:03.626 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.626 7fb0334a7cc0 [kafka.conn] [DEBUG]: Response 278 (601.1536121368408 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'')])]) 01/20/2025 02:18:03.632 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:03.632 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.633 7fb0334b5d68 [kafka.conn] [DEBUG]: Response 279 (601.0386943817139 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.660 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 01/20/2025 02:18:03.660 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.660 7fb0339e9f60 [kafka.conn] [DEBUG]: Response 294 (601.4926433563232 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.707 7fb0334cb390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 97 01/20/2025 02:18:03.708 7fb0334cb390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.708 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: 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=97, max_bytes=1048576)])]) 01/20/2025 02:18:03.708 7fb0334cb390 [kafka.conn] [DEBUG]: Request 292: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=97, max_bytes=1048576)])]) 01/20/2025 02:18:03.709 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 321 01/20/2025 02:18:03.709 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.709 7fb0334cbd68 [kafka.conn] [DEBUG]: Response 321 (601.7951965332031 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=227, last_stable_offset=227, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.716 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4038 01/20/2025 02:18:03.717 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.717 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: 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=4038, max_bytes=1048576)])]) 01/20/2025 02:18:03.717 7fb0334a0ac8 [kafka.conn] [DEBUG]: Request 463: 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=4038, max_bytes=1048576)])]) 01/20/2025 02:18:03.725 7fb0330fa780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2 01/20/2025 02:18:03.725 7fb0330fa780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.725 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:03.725 7fb0330fa780 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:03.726 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:03.726 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.726 7fb0334b5eb8 [kafka.conn] [DEBUG]: Response 278 (601.557731628418 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.768 7fb0334cb630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 119 01/20/2025 02:18:03.768 7fb0334cb630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.768 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: 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=119, max_bytes=1048576)])]) 01/20/2025 02:18:03.768 7fb0334cb630 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=119, max_bytes=1048576)])]) 01/20/2025 02:18:03.797 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 284 01/20/2025 02:18:03.797 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.797 7fb0334cf978 [kafka.conn] [DEBUG]: Response 284 (601.1555194854736 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.849 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 01/20/2025 02:18:03.849 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.849 7fb033de5ac8 [kafka.conn] [DEBUG]: Response 299 (601.4275550842285 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'')])]) 01/20/2025 02:18:03.896 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 01/20/2025 02:18:03.896 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.896 7fb032fb20f0 [kafka.conn] [DEBUG]: Response 292 (601.2065410614014 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=59, last_stable_offset=59, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.897 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 29 01/20/2025 02:18:03.897 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.897 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: 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=29, max_bytes=1048576)])]) 01/20/2025 02:18:03.897 7fb03346e4e0 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=29, max_bytes=1048576)])]) 01/20/2025 02:18:03.933 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 01/20/2025 02:18:03.933 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.933 7fb033de5c18 [kafka.conn] [DEBUG]: Response 294 (601.3755798339844 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=49, last_stable_offset=49, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:03.934 7fb0334b8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 36 01/20/2025 02:18:03.934 7fb0334b8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:03.934 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:03.934 7fb0334b8390 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 01/20/2025 02:18:03.939 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 01/20/2025 02:18:03.939 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:03.939 7fb0334ab6d8 [kafka.conn] [DEBUG]: Response 286 (601.0580062866211 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.009 7fb033de5780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 302 01/20/2025 02:18:04.009 7fb033de5780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.009 7fb033de5780 [kafka.conn] [DEBUG]: Response 302 (601.1025905609131 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.011 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 290 01/20/2025 02:18:04.011 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.011 7fb03346ef60 [kafka.conn] [DEBUG]: Response 290 (600.9860038757324 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=43, last_stable_offset=43, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.109 7fb0334b5588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 01/20/2025 02:18:04.109 7fb0334b5588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.109 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:04.109 7fb0334b5588 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:04.111 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 01/20/2025 02:18:04.111 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.111 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:04.111 7fb0334b5cc0 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:04.113 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 01/20/2025 02:18:04.113 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.114 7fb0334cf048 [kafka.conn] [DEBUG]: Response 281 (600.8865833282471 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.116 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 278 01/20/2025 02:18:04.117 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.117 7fb0330fa588 [kafka.conn] [DEBUG]: Response 278 (601.5181541442871 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'')])]) 01/20/2025 02:18:04.118 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 312 01/20/2025 02:18:04.118 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.118 7fb0334cb048 [kafka.conn] [DEBUG]: Response 312 (601.3646125793457 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=190, last_stable_offset=190, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.118 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 226 01/20/2025 02:18:04.118 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.118 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: 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=226, max_bytes=1048576)])]) 01/20/2025 02:18:04.119 7fb03d9d8630 [kafka.conn] [DEBUG]: Request 324: 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=226, max_bytes=1048576)])]) 01/20/2025 02:18:04.119 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 327 01/20/2025 02:18:04.119 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.119 7fb0334c2b70 [kafka.conn] [DEBUG]: Response 327 (602.3075580596924 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=330, last_stable_offset=330, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.143 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 55 01/20/2025 02:18:04.143 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.143 7fb032f89048 [kafka.protocol.parser] [DEBUG]: 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=55, max_bytes=1048576)])]) 01/20/2025 02:18:04.143 7fb032f89048 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=55, max_bytes=1048576)])]) 01/20/2025 02:18:04.174 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 01/20/2025 02:18:04.174 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.174 7fb0334cff60 [kafka.conn] [DEBUG]: Response 281 (601.9346714019775 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.175 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 322 01/20/2025 02:18:04.175 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.175 7fb0334cb240 [kafka.conn] [DEBUG]: Response 322 (601.9546985626221 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=217, last_stable_offset=217, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.209 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 1 01/20/2025 02:18:04.209 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.209 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: 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=1, max_bytes=1048576)])]) 01/20/2025 02:18:04.210 7fb0334cf630 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:04.222 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 57 01/20/2025 02:18:04.222 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.222 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: 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=57, max_bytes=1048576)])]) 01/20/2025 02:18:04.222 7fb0334b8198 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=57, max_bytes=1048576)])]) 01/20/2025 02:18:04.227 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/20/2025 02:18:04.227 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.227 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:04.228 7fb0334a7cc0 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:04.233 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 01/20/2025 02:18:04.233 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.233 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:04.234 7fb0334b5d68 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:04.261 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 156 01/20/2025 02:18:04.261 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.261 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 01/20/2025 02:18:04.261 7fb0339e9f60 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=156, max_bytes=1048576)])]) 01/20/2025 02:18:04.309 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 01/20/2025 02:18:04.310 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.310 7fb0334cb390 [kafka.conn] [DEBUG]: Response 292 (601.682186126709 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=97, last_stable_offset=97, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.310 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 227 01/20/2025 02:18:04.310 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.310 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: 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=227, max_bytes=1048576)])]) 01/20/2025 02:18:04.311 7fb0334cbd68 [kafka.conn] [DEBUG]: Request 322: 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=227, max_bytes=1048576)])]) 01/20/2025 02:18:04.318 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 463 01/20/2025 02:18:04.318 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.318 7fb0334a0ac8 [kafka.conn] [DEBUG]: Response 463 (601.2008190155029 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4038, last_stable_offset=4038, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.326 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:04.327 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.327 7fb0330fa780 [kafka.conn] [DEBUG]: Response 279 (601.3274192810059 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.327 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 01/20/2025 02:18:04.327 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.327 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:04.328 7fb0334b5eb8 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:04.369 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 01/20/2025 02:18:04.370 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.370 7fb0334cb630 [kafka.conn] [DEBUG]: Response 297 (601.2930870056152 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=119, last_stable_offset=119, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.398 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 13 01/20/2025 02:18:04.398 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.398 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: 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=13, max_bytes=1048576)])]) 01/20/2025 02:18:04.399 7fb0334cf978 [kafka.conn] [DEBUG]: Request 285: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 01/20/2025 02:18:04.449 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 01/20/2025 02:18:04.450 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.450 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:04.450 7fb033de5ac8 [kafka.conn] [DEBUG]: Request 300: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 01/20/2025 02:18:04.497 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 59 01/20/2025 02:18:04.497 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.497 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: 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=59, max_bytes=1048576)])]) 01/20/2025 02:18:04.497 7fb032fb20f0 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=59, max_bytes=1048576)])]) 01/20/2025 02:18:04.498 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 01/20/2025 02:18:04.498 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.498 7fb03346e4e0 [kafka.conn] [DEBUG]: Response 287 (601.3107299804688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=30, last_stable_offset=30, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x1d\x00\x00\x01\x94\x00\x00\x00\x00\x02s\xb2\xef\x9d\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\xc2\x05\x00\x00\x00\x84\x05ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:04.499 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-14', partition=0) with offset 29 to buffered record list 01/20/2025 02:18:04.534 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 49 01/20/2025 02:18:04.534 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.534 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: 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=49, max_bytes=1048576)])]) 01/20/2025 02:18:04.534 7fb033de5c18 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=49, max_bytes=1048576)])]) 01/20/2025 02:18:04.535 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 01/20/2025 02:18:04.535 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.535 7fb0334b8390 [kafka.conn] [DEBUG]: Response 293 (601.238489151001 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.540 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 36 01/20/2025 02:18:04.540 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.540 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:04.540 7fb0334ab6d8 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 01/20/2025 02:18:04.599 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 30 01/20/2025 02:18:04.599 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.599 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: 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=30, max_bytes=1048576)])]) 01/20/2025 02:18:04.600 7fb03346e4e0 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=30, max_bytes=1048576)])]) 01/20/2025 02:18:04.610 7fb033de5780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 150 01/20/2025 02:18:04.610 7fb033de5780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.610 7fb033de5780 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 01/20/2025 02:18:04.610 7fb033de5780 [kafka.conn] [DEBUG]: Request 303: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=150, max_bytes=1048576)])]) 01/20/2025 02:18:04.611 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 43 01/20/2025 02:18:04.612 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.612 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: 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=43, max_bytes=1048576)])]) 01/20/2025 02:18:04.612 7fb03346ef60 [kafka.conn] [DEBUG]: Request 291: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=43, max_bytes=1048576)])]) 01/20/2025 02:18:04.612 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 291 01/20/2025 02:18:04.612 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.612 7fb03346ef60 [kafka.conn] [DEBUG]: Response 291 (0.6208419799804688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00+\x00\x00\x01\x95\x00\x00\x00\x00\x02\x9d\xa0D2\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\xc4\x05\x00\x00\x00\x86\x05ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:04.613 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-16', partition=0) with offset 43 to buffered record list 01/20/2025 02:18:04.711 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:04.711 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.711 7fb0334b5588 [kafka.conn] [DEBUG]: Response 279 (601.7370223999023 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.712 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:04.712 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.712 7fb0334b5cc0 [kafka.conn] [DEBUG]: Response 279 (600.9268760681152 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.713 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 45 01/20/2025 02:18:04.713 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.714 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: 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=45, max_bytes=1048576)])]) 01/20/2025 02:18:04.714 7fb03346ef60 [kafka.conn] [DEBUG]: Request 292: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 01/20/2025 02:18:04.714 7fb0334cf048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 8 01/20/2025 02:18:04.714 7fb0334cf048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.714 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: 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=8, max_bytes=1048576)])]) 01/20/2025 02:18:04.715 7fb0334cf048 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 01/20/2025 02:18:04.717 7fb0330fa588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 01/20/2025 02:18:04.717 7fb0330fa588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.717 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:04.718 7fb0330fa588 [kafka.conn] [DEBUG]: Request 279: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:04.718 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 190 01/20/2025 02:18:04.718 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.718 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: 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=190, max_bytes=1048576)])]) 01/20/2025 02:18:04.719 7fb0334cb048 [kafka.conn] [DEBUG]: Request 313: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=190, max_bytes=1048576)])]) 01/20/2025 02:18:04.720 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 330 01/20/2025 02:18:04.720 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.720 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: 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=330, max_bytes=1048576)])]) 01/20/2025 02:18:04.720 7fb0334c2b70 [kafka.conn] [DEBUG]: Request 328: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=330, max_bytes=1048576)])]) 01/20/2025 02:18:04.721 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 324 01/20/2025 02:18:04.721 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.721 7fb03d9d8630 [kafka.conn] [DEBUG]: Response 324 (602.2865772247314 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=228, last_stable_offset=228, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xe2\x00\x00\x02-\x00\x00\x00\x00\x02\xd0\x032`\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\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...')])]) 01/20/2025 02:18:04.721 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 226 to buffered record list 01/20/2025 02:18:04.744 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 01/20/2025 02:18:04.744 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.744 7fb032f89048 [kafka.conn] [DEBUG]: Response 296 (601.1428833007812 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=56, last_stable_offset=56, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x007\x00\x00\x01\x8a\x00\x00\x00\x00\x02\x80\xe7\xba$\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\xae\x05\x00\x00\x00\xf0\x04ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:04.745 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-17', partition=0) with offset 55 to buffered record list 01/20/2025 02:18:04.775 7fb0334cff60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 8 01/20/2025 02:18:04.775 7fb0334cff60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.775 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: 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=8, max_bytes=1048576)])]) 01/20/2025 02:18:04.776 7fb0334cff60 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 01/20/2025 02:18:04.776 7fb0334cb240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 217 01/20/2025 02:18:04.776 7fb0334cb240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.776 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: 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=217, max_bytes=1048576)])]) 01/20/2025 02:18:04.776 7fb0334cb240 [kafka.conn] [DEBUG]: Request 323: 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=217, max_bytes=1048576)])]) 01/20/2025 02:18:04.811 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:04.812 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.812 7fb0334cf630 [kafka.conn] [DEBUG]: Response 279 (602.0541191101074 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.822 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 228 01/20/2025 02:18:04.822 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.822 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: 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=228, max_bytes=1048576)])]) 01/20/2025 02:18:04.822 7fb03d9d8630 [kafka.conn] [DEBUG]: Request 325: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=228, max_bytes=1048576)])]) 01/20/2025 02:18:04.823 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 01/20/2025 02:18:04.823 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.823 7fb0334b8198 [kafka.conn] [DEBUG]: Response 295 (601.2287139892578 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=58, last_stable_offset=58, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x009\x00\x00\x01\x8b\x00\x00\x00\x00\x02\x0eznj\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\xb0\x05\x00\x00\x00\xf2\x04ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:04.824 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-19', partition=0) with offset 57 to buffered record list 01/20/2025 02:18:04.828 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:04.828 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.828 7fb0334a7cc0 [kafka.conn] [DEBUG]: Response 279 (600.9931564331055 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'')])]) 01/20/2025 02:18:04.834 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:04.834 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.835 7fb0334b5d68 [kafka.conn] [DEBUG]: Response 280 (601.0377407073975 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.845 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 56 01/20/2025 02:18:04.845 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.845 7fb032f89048 [kafka.protocol.parser] [DEBUG]: 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=56, max_bytes=1048576)])]) 01/20/2025 02:18:04.846 7fb032f89048 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=56, max_bytes=1048576)])]) 01/20/2025 02:18:04.862 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 01/20/2025 02:18:04.862 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.862 7fb0339e9f60 [kafka.conn] [DEBUG]: Response 295 (601.1748313903809 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.910 7fb0334cb390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 97 01/20/2025 02:18:04.910 7fb0334cb390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.911 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: 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=97, max_bytes=1048576)])]) 01/20/2025 02:18:04.911 7fb0334cb390 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=97, max_bytes=1048576)])]) 01/20/2025 02:18:04.911 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 322 01/20/2025 02:18:04.912 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.912 7fb0334cbd68 [kafka.conn] [DEBUG]: Response 322 (601.0832786560059 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=229, last_stable_offset=229, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xe3\x00\x00\x02\x13\x00\x00\x00\x00\x02\xaf\xbc\x03\xec\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...')])]) 01/20/2025 02:18:04.912 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 227 to buffered record list 01/20/2025 02:18:04.919 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4038 01/20/2025 02:18:04.919 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.919 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: 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=4038, max_bytes=1048576)])]) 01/20/2025 02:18:04.919 7fb0334a0ac8 [kafka.conn] [DEBUG]: Request 464: 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=4038, max_bytes=1048576)])]) 01/20/2025 02:18:04.924 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 58 01/20/2025 02:18:04.924 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.924 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: 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=58, max_bytes=1048576)])]) 01/20/2025 02:18:04.925 7fb0334b8198 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=58, max_bytes=1048576)])]) 01/20/2025 02:18:04.927 7fb0330fa780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2 01/20/2025 02:18:04.927 7fb0330fa780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.927 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:04.928 7fb0330fa780 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:04.928 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:04.928 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:04.928 7fb0334b5eb8 [kafka.conn] [DEBUG]: Response 279 (600.8484363555908 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:04.970 7fb0334cb630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 119 01/20/2025 02:18:04.970 7fb0334cb630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:04.971 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: 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=119, max_bytes=1048576)])]) 01/20/2025 02:18:04.971 7fb0334cb630 [kafka.conn] [DEBUG]: Request 298: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=119, max_bytes=1048576)])]) 01/20/2025 02:18:05.001 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 285 01/20/2025 02:18:05.001 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.002 7fb0334cf978 [kafka.conn] [DEBUG]: Response 285 (602.790117263794 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.013 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 229 01/20/2025 02:18:05.013 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.013 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: 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=229, max_bytes=1048576)])]) 01/20/2025 02:18:05.013 7fb0334cbd68 [kafka.conn] [DEBUG]: Request 323: 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=229, max_bytes=1048576)])]) 01/20/2025 02:18:05.051 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 300 01/20/2025 02:18:05.051 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.051 7fb033de5ac8 [kafka.conn] [DEBUG]: Response 300 (601.2063026428223 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'')])]) 01/20/2025 02:18:05.098 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 01/20/2025 02:18:05.098 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.099 7fb032fb20f0 [kafka.conn] [DEBUG]: Response 293 (601.3906002044678 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=63, last_stable_offset=63, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00;\x00\x00\x03Y\x00\x00\x00\x00\x02\xf6^ \xdc\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-...')])]) 01/20/2025 02:18:05.099 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 59 to buffered record list 01/20/2025 02:18:05.135 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 01/20/2025 02:18:05.135 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.136 7fb033de5c18 [kafka.conn] [DEBUG]: Response 295 (601.3350486755371 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=49, last_stable_offset=49, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.136 7fb0334b8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 36 01/20/2025 02:18:05.136 7fb0334b8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.136 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:05.136 7fb0334b8390 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 01/20/2025 02:18:05.141 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 287 01/20/2025 02:18:05.141 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.141 7fb0334ab6d8 [kafka.conn] [DEBUG]: Response 287 (601.1664867401123 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.200 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 63 01/20/2025 02:18:05.200 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.200 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: 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=63, max_bytes=1048576)])]) 01/20/2025 02:18:05.200 7fb032fb20f0 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=63, max_bytes=1048576)])]) 01/20/2025 02:18:05.201 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 01/20/2025 02:18:05.201 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.201 7fb03346e4e0 [kafka.conn] [DEBUG]: Response 288 (601.6647815704346 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\x1e\x00\x00\x02o\x00\x00\x00\x00\x02\xf2\xc4\xf09\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\xac\x05\x00\x00\x00\xee\x04ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:05.201 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-14', partition=0) with offset 30 to buffered record list 01/20/2025 02:18:05.212 7fb033de5780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 303 01/20/2025 02:18:05.212 7fb033de5780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.212 7fb033de5780 [kafka.conn] [DEBUG]: Response 303 (601.7248630523682 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.302 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 32 01/20/2025 02:18:05.302 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.302 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: 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=32, max_bytes=1048576)])]) 01/20/2025 02:18:05.303 7fb03346e4e0 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 01/20/2025 02:18:05.312 7fb0334b5588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 01/20/2025 02:18:05.313 7fb0334b5588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.313 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:05.313 7fb0334b5588 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:05.313 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 01/20/2025 02:18:05.314 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.314 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:05.314 7fb0334b5cc0 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:05.315 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 292 01/20/2025 02:18:05.315 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.315 7fb03346ef60 [kafka.conn] [DEBUG]: Response 292 (601.6726493835449 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.316 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 01/20/2025 02:18:05.316 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.316 7fb0334cf048 [kafka.conn] [DEBUG]: Response 282 (601.5863418579102 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.318 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 279 01/20/2025 02:18:05.318 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.318 7fb0330fa588 [kafka.conn] [DEBUG]: Response 279 (600.8632183074951 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'')])]) 01/20/2025 02:18:05.319 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 313 01/20/2025 02:18:05.319 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.319 7fb0334cb048 [kafka.conn] [DEBUG]: Response 313 (600.8400917053223 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=190, last_stable_offset=190, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.321 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 01/20/2025 02:18:05.321 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.321 7fb0334c2b70 [kafka.conn] [DEBUG]: Response 328 (600.9535789489746 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=332, last_stable_offset=332, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x01J\x00\x00\x02$\x00\x00\x00\x00\x02-\x92H\x01\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\x8a\x03\x00\x00\x00\xcc\x02ObjectVNTable:default-domain:adm...')])]) 01/20/2025 02:18:05.321 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 330 to buffered record list 01/20/2025 02:18:05.377 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 282 01/20/2025 02:18:05.377 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.378 7fb0334cff60 [kafka.conn] [DEBUG]: Response 282 (602.3342609405518 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.378 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 323 01/20/2025 02:18:05.378 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.379 7fb0334cb240 [kafka.conn] [DEBUG]: Response 323 (602.2665500640869 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=217, last_stable_offset=217, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.412 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 1 01/20/2025 02:18:05.413 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.413 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: 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=1, max_bytes=1048576)])]) 01/20/2025 02:18:05.413 7fb0334cf630 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:05.422 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 332 01/20/2025 02:18:05.422 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.422 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: 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=332, max_bytes=1048576)])]) 01/20/2025 02:18:05.423 7fb0334c2b70 [kafka.conn] [DEBUG]: Request 329: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-29', partitions=[(partition=0, offset=332, max_bytes=1048576)])]) 01/20/2025 02:18:05.423 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 325 01/20/2025 02:18:05.423 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.424 7fb03d9d8630 [kafka.conn] [DEBUG]: Response 325 (601.2511253356934 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=228, last_stable_offset=228, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.429 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/20/2025 02:18:05.429 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.429 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:05.430 7fb0334a7cc0 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:05.435 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 01/20/2025 02:18:05.435 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.435 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:05.436 7fb0334b5d68 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:05.447 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 01/20/2025 02:18:05.447 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.447 7fb032f89048 [kafka.conn] [DEBUG]: Response 297 (601.1323928833008 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x008\x00\x00\x01\x7f\x00\x00\x00\x00\x02t\x15R\xb4\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\x98\x05\x00\x00\x00\xda\x04ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:05.447 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-17', partition=0) with offset 56 to buffered record list 01/20/2025 02:18:05.463 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 156 01/20/2025 02:18:05.463 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.463 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 01/20/2025 02:18:05.464 7fb0339e9f60 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=156, max_bytes=1048576)])]) 01/20/2025 02:18:05.512 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 01/20/2025 02:18:05.512 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.512 7fb0334cb390 [kafka.conn] [DEBUG]: Response 293 (601.2692451477051 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=97, last_stable_offset=97, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.520 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 464 01/20/2025 02:18:05.520 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.520 7fb0334a0ac8 [kafka.conn] [DEBUG]: Response 464 (601.1791229248047 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4039, last_stable_offset=4039, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x0f\xc6\x00\x00\x01\x06\x00\x00\x00\x00\x022\x87\xf1]\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\xa6\x03\x00\x00\x00\xe8\x02ObjectDatabaseInfo:cn-jenkins-de...')])]) 01/20/2025 02:18:05.520 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4038 to buffered record list 01/20/2025 02:18:05.525 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 01/20/2025 02:18:05.525 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.525 7fb0334b8198 [kafka.conn] [DEBUG]: Response 296 (600.9883880615234 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=59, last_stable_offset=59, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00:\x00\x00\x01\x80\x00\x00\x00\x00\x02\x02\x07G\xe1\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9a\x05\x00\x00\x00\xdc\x04ObjectVMITable:default-domain:te...')])]) 01/20/2025 02:18:05.526 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-19', partition=0) with offset 58 to buffered record list 01/20/2025 02:18:05.528 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:05.528 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.528 7fb0330fa780 [kafka.conn] [DEBUG]: Response 280 (600.9821891784668 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.529 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 01/20/2025 02:18:05.529 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.529 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:05.529 7fb0334b5eb8 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:05.548 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 57 01/20/2025 02:18:05.548 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.548 7fb032f89048 [kafka.protocol.parser] [DEBUG]: 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=57, max_bytes=1048576)])]) 01/20/2025 02:18:05.548 7fb032f89048 [kafka.conn] [DEBUG]: Request 298: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=57, max_bytes=1048576)])]) 01/20/2025 02:18:05.572 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 298 01/20/2025 02:18:05.572 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.572 7fb0334cb630 [kafka.conn] [DEBUG]: Response 298 (601.1686325073242 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=119, last_stable_offset=119, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.602 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 13 01/20/2025 02:18:05.602 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.602 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: 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=13, max_bytes=1048576)])]) 01/20/2025 02:18:05.603 7fb0334cf978 [kafka.conn] [DEBUG]: Request 286: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 01/20/2025 02:18:05.614 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 323 01/20/2025 02:18:05.615 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.615 7fb0334cbd68 [kafka.conn] [DEBUG]: Response 323 (601.3917922973633 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=229, last_stable_offset=229, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.622 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4039 01/20/2025 02:18:05.622 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.622 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: 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=4039, max_bytes=1048576)])]) 01/20/2025 02:18:05.622 7fb0334a0ac8 [kafka.conn] [DEBUG]: Request 465: 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=4039, max_bytes=1048576)])]) 01/20/2025 02:18:05.627 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 59 01/20/2025 02:18:05.627 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.627 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: 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=59, max_bytes=1048576)])]) 01/20/2025 02:18:05.627 7fb0334b8198 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=59, max_bytes=1048576)])]) 01/20/2025 02:18:05.652 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 01/20/2025 02:18:05.652 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.652 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:05.652 7fb033de5ac8 [kafka.conn] [DEBUG]: Request 301: 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)])]) 01/20/2025 02:18:05.736 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 49 01/20/2025 02:18:05.736 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.737 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: 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=49, max_bytes=1048576)])]) 01/20/2025 02:18:05.737 7fb033de5c18 [kafka.conn] [DEBUG]: Request 296: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=49, max_bytes=1048576)])]) 01/20/2025 02:18:05.737 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 01/20/2025 02:18:05.738 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.738 7fb0334b8390 [kafka.conn] [DEBUG]: Response 294 (601.3379096984863 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.742 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 36 01/20/2025 02:18:05.742 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.742 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:05.743 7fb0334ab6d8 [kafka.conn] [DEBUG]: Request 288: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 01/20/2025 02:18:05.801 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 01/20/2025 02:18:05.802 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.802 7fb032fb20f0 [kafka.conn] [DEBUG]: Response 294 (601.6123294830322 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=63, last_stable_offset=63, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.814 7fb033de5780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 150 01/20/2025 02:18:05.814 7fb033de5780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.814 7fb033de5780 [kafka.protocol.parser] [DEBUG]: 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=150, max_bytes=1048576)])]) 01/20/2025 02:18:05.815 7fb033de5780 [kafka.conn] [DEBUG]: Request 304: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-20', partitions=[(partition=0, offset=150, max_bytes=1048576)])]) 01/20/2025 02:18:05.904 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 289 01/20/2025 02:18:05.904 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.904 7fb03346e4e0 [kafka.conn] [DEBUG]: Response 289 (601.4719009399414 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=32, last_stable_offset=32, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.915 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:05.915 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.915 7fb0334b5588 [kafka.conn] [DEBUG]: Response 280 (602.139949798584 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-6', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.916 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:05.916 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.916 7fb0334b5cc0 [kafka.conn] [DEBUG]: Response 280 (602.5145053863525 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-8', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:05.917 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 45 01/20/2025 02:18:05.917 7fb03346ef60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.917 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: 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=45, max_bytes=1048576)])]) 01/20/2025 02:18:05.918 7fb03346ef60 [kafka.conn] [DEBUG]: Request 293: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-16', partitions=[(partition=0, offset=45, max_bytes=1048576)])]) 01/20/2025 02:18:05.918 7fb0334cf048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 8 01/20/2025 02:18:05.918 7fb0334cf048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.918 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: 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=8, max_bytes=1048576)])]) 01/20/2025 02:18:05.919 7fb0334cf048 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-10', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 01/20/2025 02:18:05.919 7fb0330fa588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 01/20/2025 02:18:05.919 7fb0330fa588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.919 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:05.919 7fb0330fa588 [kafka.conn] [DEBUG]: Request 280: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-3', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:05.920 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 190 01/20/2025 02:18:05.920 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.920 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: 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=190, max_bytes=1048576)])]) 01/20/2025 02:18:05.921 7fb0334cb048 [kafka.conn] [DEBUG]: Request 314: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=190, max_bytes=1048576)])]) 01/20/2025 02:18:05.921 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 314 01/20/2025 02:18:05.921 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:05.921 7fb0334cb048 [kafka.conn] [DEBUG]: Response 314 (0.6971359252929688 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=192, last_stable_offset=192, aborted_transactions=NULL, message_set=b'\x00\x00\x00\x00\x00\x00\x00\xbe\x00\x00\x02\x0f\x00\x00\x00\x00\x02z$@4\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\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/20/2025 02:18:05.921 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetched record for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 190 to buffered record list 01/20/2025 02:18:05.978 7fb0334cff60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 8 01/20/2025 02:18:05.979 7fb0334cff60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.979 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: 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=8, max_bytes=1048576)])]) 01/20/2025 02:18:05.979 7fb0334cff60 [kafka.conn] [DEBUG]: Request 283: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-11', partitions=[(partition=0, offset=8, max_bytes=1048576)])]) 01/20/2025 02:18:05.979 7fb0334cb240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 217 01/20/2025 02:18:05.980 7fb0334cb240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:05.980 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: 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=217, max_bytes=1048576)])]) 01/20/2025 02:18:05.980 7fb0334cb240 [kafka.conn] [DEBUG]: Request 324: 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=217, max_bytes=1048576)])]) 01/20/2025 02:18:06.019 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:06.019 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.019 7fb0334cf630 [kafka.conn] [DEBUG]: Response 280 (606.2526702880859 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-9', partitions=[(partition=0, error_code=0, highwater_offset=1, last_stable_offset=1, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.026 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 192 01/20/2025 02:18:06.026 7fb0334cb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.026 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: 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=192, max_bytes=1048576)])]) 01/20/2025 02:18:06.026 7fb0334cb048 [kafka.conn] [DEBUG]: Request 315: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-27', partitions=[(partition=0, offset=192, max_bytes=1048576)])]) 01/20/2025 02:18:06.026 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 228 01/20/2025 02:18:06.027 7fb03d9d8630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.027 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: 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=228, max_bytes=1048576)])]) 01/20/2025 02:18:06.027 7fb03d9d8630 [kafka.conn] [DEBUG]: Request 326: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-22', partitions=[(partition=0, offset=228, max_bytes=1048576)])]) 01/20/2025 02:18:06.027 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 01/20/2025 02:18:06.027 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.027 7fb0334c2b70 [kafka.conn] [DEBUG]: Response 329 (604.7840118408203 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=332, last_stable_offset=332, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.030 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:06.030 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.030 7fb0334a7cc0 [kafka.conn] [DEBUG]: Response 280 (600.9383201599121 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'')])]) 01/20/2025 02:18:06.036 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 01/20/2025 02:18:06.036 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.036 7fb0334b5d68 [kafka.conn] [DEBUG]: Response 281 (600.9762287139893 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-5', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.064 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 01/20/2025 02:18:06.064 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.064 7fb0339e9f60 [kafka.conn] [DEBUG]: Response 296 (601.0069847106934 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=156, last_stable_offset=156, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.113 7fb0334cb390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 97 01/20/2025 02:18:06.113 7fb0334cb390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.113 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: 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=97, max_bytes=1048576)])]) 01/20/2025 02:18:06.113 7fb0334cb390 [kafka.conn] [DEBUG]: Request 294: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-23', partitions=[(partition=0, offset=97, max_bytes=1048576)])]) 01/20/2025 02:18:06.129 7fb0330fa780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2 01/20/2025 02:18:06.129 7fb0330fa780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.129 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:06.130 7fb0330fa780 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-4', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:06.130 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:06.130 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.131 7fb0334b5eb8 [kafka.conn] [DEBUG]: Response 280 (601.3221740722656 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-7', partitions=[(partition=0, error_code=0, highwater_offset=0, last_stable_offset=0, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.149 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 298 01/20/2025 02:18:06.149 7fb032f89048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.149 7fb032f89048 [kafka.conn] [DEBUG]: Response 298 (601.0754108428955 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-17', partitions=[(partition=0, error_code=0, highwater_offset=57, last_stable_offset=57, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.172 7fb0334cb630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 119 01/20/2025 02:18:06.173 7fb0334cb630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.173 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: 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=119, max_bytes=1048576)])]) 01/20/2025 02:18:06.173 7fb0334cb630 [kafka.conn] [DEBUG]: Request 299: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-24', partitions=[(partition=0, offset=119, max_bytes=1048576)])]) 01/20/2025 02:18:06.203 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 286 01/20/2025 02:18:06.205 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.205 7fb0334cf978 [kafka.conn] [DEBUG]: Response 286 (602.5269031524658 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=13, last_stable_offset=13, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.215 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 229 01/20/2025 02:18:06.215 7fb0334cbd68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.215 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: 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=229, max_bytes=1048576)])]) 01/20/2025 02:18:06.216 7fb0334cbd68 [kafka.conn] [DEBUG]: Request 324: 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=229, max_bytes=1048576)])]) 01/20/2025 02:18:06.223 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 465 01/20/2025 02:18:06.223 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.223 7fb0334a0ac8 [kafka.conn] [DEBUG]: Response 465 (601.0255813598633 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4039, last_stable_offset=4039, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.228 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 297 01/20/2025 02:18:06.228 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.228 7fb0334b8198 [kafka.conn] [DEBUG]: Response 297 (600.9390354156494 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=59, last_stable_offset=59, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.253 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 301 01/20/2025 02:18:06.253 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.253 7fb033de5ac8 [kafka.conn] [DEBUG]: Response 301 (601.0665893554688 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'')])]) 01/20/2025 02:18:06.338 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 296 01/20/2025 02:18:06.338 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.338 7fb033de5c18 [kafka.conn] [DEBUG]: Response 296 (601.4208793640137 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=49, last_stable_offset=49, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.339 7fb0334b8390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 36 01/20/2025 02:18:06.339 7fb0334b8390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.339 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:06.339 7fb0334b8390 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-12', partitions=[(partition=0, offset=36, max_bytes=1048576)])]) 01/20/2025 02:18:06.343 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 288 01/20/2025 02:18:06.343 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.344 7fb0334ab6d8 [kafka.conn] [DEBUG]: Response 288 (601.121187210083 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.403 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 63 01/20/2025 02:18:06.403 7fb032fb20f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.403 7fb032fb20f0 [kafka.protocol.parser] [DEBUG]: 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=63, max_bytes=1048576)])]) 01/20/2025 02:18:06.403 7fb032fb20f0 [kafka.conn] [DEBUG]: Request 295: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-2', partitions=[(partition=0, offset=63, max_bytes=1048576)])]) 01/20/2025 02:18:06.416 7fb033de5780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 304 01/20/2025 02:18:06.416 7fb033de5780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.417 7fb033de5780 [kafka.conn] [DEBUG]: Response 304 (602.0395755767822 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=150, last_stable_offset=150, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.516 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 32 01/20/2025 02:18:06.516 7fb03346e4e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.517 7fb03346e4e0 [kafka.protocol.parser] [DEBUG]: 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=32, max_bytes=1048576)])]) 01/20/2025 02:18:06.517 7fb03346e4e0 [kafka.conn] [DEBUG]: Request 290: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-14', partitions=[(partition=0, offset=32, max_bytes=1048576)])]) 01/20/2025 02:18:06.517 7fb0334b5588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 1 01/20/2025 02:18:06.517 7fb0334b5588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.517 7fb0334b5588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:06.518 7fb0334b5588 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-6', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:06.525 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2 01/20/2025 02:18:06.526 7fb0334b5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.526 7fb0334b5cc0 [kafka.protocol.parser] [DEBUG]: 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=2, max_bytes=1048576)])]) 01/20/2025 02:18:06.526 7fb0334b5cc0 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-8', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:06.527 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 293 01/20/2025 02:18:06.527 7fb03346ef60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.527 7fb03346ef60 [kafka.conn] [DEBUG]: Response 293 (609.3518733978271 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-16', partitions=[(partition=0, error_code=0, highwater_offset=45, last_stable_offset=45, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.527 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 01/20/2025 02:18:06.527 7fb0334cf048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.527 7fb0334cf048 [kafka.conn] [DEBUG]: Response 283 (608.9482307434082 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-10', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.528 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 280 01/20/2025 02:18:06.528 7fb0330fa588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.528 7fb0330fa588 [kafka.conn] [DEBUG]: Response 280 (608.5481643676758 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'')])]) 01/20/2025 02:18:06.581 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 283 01/20/2025 02:18:06.581 7fb0334cff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.581 7fb0334cff60 [kafka.conn] [DEBUG]: Response 283 (602.3154258728027 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=8, last_stable_offset=8, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.582 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 324 01/20/2025 02:18:06.582 7fb0334cb240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.582 7fb0334cb240 [kafka.conn] [DEBUG]: Response 324 (602.2477149963379 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=217, last_stable_offset=217, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.620 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 1 01/20/2025 02:18:06.620 7fb0334cf630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.620 7fb0334cf630 [kafka.protocol.parser] [DEBUG]: 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=1, max_bytes=1048576)])]) 01/20/2025 02:18:06.621 7fb0334cf630 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-9', partitions=[(partition=0, offset=1, max_bytes=1048576)])]) 01/20/2025 02:18:06.628 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 332 01/20/2025 02:18:06.628 7fb0334c2b70 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.628 7fb0334c2b70 [kafka.protocol.parser] [DEBUG]: 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=332, max_bytes=1048576)])]) 01/20/2025 02:18:06.628 7fb0334c2b70 [kafka.conn] [DEBUG]: Request 330: 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=332, max_bytes=1048576)])]) 01/20/2025 02:18:06.629 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 315 01/20/2025 02:18:06.629 7fb0334cb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.629 7fb0334cb048 [kafka.conn] [DEBUG]: Response 315 (603.1627655029297 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=192, last_stable_offset=192, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.630 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 326 01/20/2025 02:18:06.630 7fb03d9d8630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.630 7fb03d9d8630 [kafka.conn] [DEBUG]: Response 326 (603.0006408691406 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=228, last_stable_offset=228, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.631 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/20/2025 02:18:06.631 7fb0334a7cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.631 7fb0334a7cc0 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:06.631 7fb0334a7cc0 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-1', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:06.637 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 01/20/2025 02:18:06.637 7fb0334b5d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.637 7fb0334b5d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:06.637 7fb0334b5d68 [kafka.conn] [DEBUG]: Request 282: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-5', partitions=[(partition=0, offset=2, max_bytes=1048576)])]) 01/20/2025 02:18:06.665 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 156 01/20/2025 02:18:06.665 7fb0339e9f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.665 7fb0339e9f60 [kafka.protocol.parser] [DEBUG]: 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=156, max_bytes=1048576)])]) 01/20/2025 02:18:06.666 7fb0339e9f60 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-28', partitions=[(partition=0, offset=156, max_bytes=1048576)])]) 01/20/2025 02:18:06.714 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 294 01/20/2025 02:18:06.714 7fb0334cb390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.714 7fb0334cb390 [kafka.conn] [DEBUG]: Response 294 (601.3424396514893 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=97, last_stable_offset=97, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.730 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 281 01/20/2025 02:18:06.730 7fb0330fa780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.731 7fb0330fa780 [kafka.conn] [DEBUG]: Response 281 (601.11403465271 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-4', partitions=[(partition=0, error_code=0, highwater_offset=2, last_stable_offset=2, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.731 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 01/20/2025 02:18:06.731 7fb0334b5eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.731 7fb0334b5eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:06.732 7fb0334b5eb8 [kafka.conn] [DEBUG]: Request 281: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-7', partitions=[(partition=0, offset=0, max_bytes=1048576)])]) 01/20/2025 02:18:06.750 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 57 01/20/2025 02:18:06.750 7fb032f89048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.750 7fb032f89048 [kafka.protocol.parser] [DEBUG]: 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=57, max_bytes=1048576)])]) 01/20/2025 02:18:06.750 7fb032f89048 [kafka.conn] [DEBUG]: Request 299: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-17', partitions=[(partition=0, offset=57, max_bytes=1048576)])]) 01/20/2025 02:18:06.774 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 299 01/20/2025 02:18:06.774 7fb0334cb630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.774 7fb0334cb630 [kafka.conn] [DEBUG]: Response 299 (601.4161109924316 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=119, last_stable_offset=119, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.806 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 13 01/20/2025 02:18:06.806 7fb0334cf978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.806 7fb0334cf978 [kafka.protocol.parser] [DEBUG]: 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=13, max_bytes=1048576)])]) 01/20/2025 02:18:06.806 7fb0334cf978 [kafka.conn] [DEBUG]: Request 287: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-15', partitions=[(partition=0, offset=13, max_bytes=1048576)])]) 01/20/2025 02:18:06.817 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 324 01/20/2025 02:18:06.817 7fb0334cbd68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.817 7fb0334cbd68 [kafka.conn] [DEBUG]: Response 324 (601.4258861541748 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=229, last_stable_offset=229, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.824 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4039 01/20/2025 02:18:06.824 7fb0334a0ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.824 7fb0334a0ac8 [kafka.protocol.parser] [DEBUG]: 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=4039, max_bytes=1048576)])]) 01/20/2025 02:18:06.825 7fb0334a0ac8 [kafka.conn] [DEBUG]: Request 466: 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=4039, max_bytes=1048576)])]) 01/20/2025 02:18:06.829 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 59 01/20/2025 02:18:06.830 7fb0334b8198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.830 7fb0334b8198 [kafka.protocol.parser] [DEBUG]: 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=59, max_bytes=1048576)])]) 01/20/2025 02:18:06.830 7fb0334b8198 [kafka.conn] [DEBUG]: Request 298: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-19', partitions=[(partition=0, offset=59, max_bytes=1048576)])]) 01/20/2025 02:18:06.854 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 122 01/20/2025 02:18:06.854 7fb033de5ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.854 7fb033de5ac8 [kafka.protocol.parser] [DEBUG]: 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)])]) 01/20/2025 02:18:06.855 7fb033de5ac8 [kafka.conn] [DEBUG]: Request 302: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-21', partitions=[(partition=0, offset=122, max_bytes=1048576)])]) 01/20/2025 02:18:06.939 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 49 01/20/2025 02:18:06.939 7fb033de5c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.939 7fb033de5c18 [kafka.protocol.parser] [DEBUG]: 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=49, max_bytes=1048576)])]) 01/20/2025 02:18:06.939 7fb033de5c18 [kafka.conn] [DEBUG]: Request 297: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-18', partitions=[(partition=0, offset=49, max_bytes=1048576)])]) 01/20/2025 02:18:06.940 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 295 01/20/2025 02:18:06.940 7fb0334b8390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v4 01/20/2025 02:18:06.940 7fb0334b8390 [kafka.conn] [DEBUG]: Response 295 (601.233720779419 ms): FetchResponse_v4(throttle_time_ms=0, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=36, last_stable_offset=36, aborted_transactions=NULL, message_set=b'')])]) 01/20/2025 02:18:06.944 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 36 01/20/2025 02:18:06.944 7fb0334ab6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/20/2025 02:18:06.944 7fb0334ab6d8 [kafka.protocol.parser] [DEBUG]: 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=36, max_bytes=1048576)])]) 01/20/2025 02:18:06.944 7fb0334ab6d8 [kafka.conn] [DEBUG]: Request 289: FetchRequest_v4(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, topics=[(topic='-uve-topic-13', partitions=[(partition=0, offset=36, max_bytes=1048576)])])