12/29/2025 02:09:12.845 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/29/2025 02:09:12.845 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 12/29/2025 02:09:12.845 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.845 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=358, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.845 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 361 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=358, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.845 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208631.310547, idle connection 147619.000000, request 304999.965668 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 225 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=358, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 361 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=358, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.846 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209336.719482, idle connection 147504.000000, request 304999.966860 12/29/2025 02:09:12.846 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 3 12/29/2025 02:09:12.846 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 12/29/2025 02:09:12.846 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 12/29/2025 02:09:12.847 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.847 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1509807947, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.847 7fe50528a680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1509807947, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.847 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207869.152100, idle connection 147149.000000, request 304999.969244 12/29/2025 02:09:12.847 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208629.663818, idle connection 147617.000000, request 304998.322010 12/29/2025 02:09:12.847 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209335.617920, idle connection 147503.000000, request 304998.868227 12/29/2025 02:09:12.848 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207868.387695, idle connection 147148.000000, request 304999.206543 12/29/2025 02:09:12.848 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361 12/29/2025 02:09:12.848 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:12.848 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 361 (1.7936229705810547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=234546897, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=226, last_stable_offset=226, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xe1\x00\x00\x01\x11\x00\x00\x00\x00\x02f\xa70D\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\xbc\x03\x00\x00\x00\xae\x03ObjectApplicationPolicySetTable:...')])]) 12/29/2025 02:09:12.848 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 234546897 with 1 response partitions (0 implied) 12/29/2025 02:09:12.848 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 285 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 225 12/29/2025 02:09:12.848 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 225 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 12/29/2025 02:09:12.849 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 226 (leader epoch 0) 12/29/2025 02:09:12.910 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208613.968994, idle connection 147509.000000, request 304399.029493 12/29/2025 02:09:12.910 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 360 12/29/2025 02:09:12.910 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:12.910 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 360 (601.6252040863037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=482714367, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=236, last_stable_offset=236, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xeb\x00\x00\x01\x10\x00\x00\x00\x00\x02\xfab\x8d\x04\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\xba\x03\x00\x00\x00\xac\x03ObjectApplicationPolicySetTable:...')])]) 12/29/2025 02:09:12.910 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 482714367 with 1 response partitions (0 implied) 12/29/2025 02:09:12.911 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 284 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 235 12/29/2025 02:09:12.911 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 235 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) 12/29/2025 02:09:12.911 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 236 (leader epoch 0) 12/29/2025 02:09:12.925 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 2 12/29/2025 02:09:12.925 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 12/29/2025 02:09:12.925 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 12/29/2025 02:09:12.925 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.925 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1354335972, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.925 7fe503c7e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1354335972, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.926 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208912.066895, idle connection 147243.000000, request 304999.951124 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 40 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=418798700, session_epoch=334, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 337 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=418798700, session_epoch=334, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.926 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209047.093994, idle connection 147299.000000, request 304999.964476 12/29/2025 02:09:12.926 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 12/29/2025 02:09:12.927 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 12/29/2025 02:09:12.927 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 12/29/2025 02:09:12.927 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.927 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=759178101, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.927 7fe503d5e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=759178101, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:12.927 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207880.283447, idle connection 147202.000000, request 304999.963522 12/29/2025 02:09:12.927 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208448.871338, idle connection 147414.000000, request 304395.672321 12/29/2025 02:09:12.927 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208910.279297, idle connection 147241.000000, request 304998.172045 12/29/2025 02:09:12.928 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 364 12/29/2025 02:09:12.928 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:12.928 7fe505cb5180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 364 (604.9950122833252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1688050189, topics=[]) 12/29/2025 02:09:12.928 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1688050189 with 0 response partitions (1 implied) 12/29/2025 02:09:12.928 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209045.173096, idle connection 147297.000000, request 304998.046398 12/29/2025 02:09:12.929 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207878.698486, idle connection 147200.000000, request 304998.384237 12/29/2025 02:09:12.939 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 173 12/29/2025 02:09:12.939 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 12/29/2025 02:09:12.939 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 12/29/2025 02:09:12.939 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.939 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876908981, session_epoch=354, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=173, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:12.940 7fe505cb5860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876908981, session_epoch=354, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=173, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:12.940 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208212.457764, idle connection 147527.000000, request 304999.957323 12/29/2025 02:09:12.940 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208212.111572, idle connection 147526.000000, request 304999.614477 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 66 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-2', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=720032835, session_epoch=338, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=66, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=720032835, session_epoch=338, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=66, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:12.941 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207800.952881, idle connection 147002.000000, request 304999.956131 12/29/2025 02:09:12.942 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207800.595215, idle connection 147002.000000, request 304999.599218 12/29/2025 02:09:12.949 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 226 12/29/2025 02:09:12.949 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/29/2025 02:09:12.949 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-23', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 12/29/2025 02:09:12.949 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:12.949 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=359, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=226, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:12.950 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 362 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=359, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=226, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:12.950 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209233.027344, idle connection 147401.000000, request 304999.951839 12/29/2025 02:09:12.950 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209232.584229, idle connection 147400.000000, request 304999.510527 12/29/2025 02:09:12.971 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208263.565918, idle connection 146954.000000, request 304399.064541 12/29/2025 02:09:12.972 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 505 12/29/2025 02:09:12.972 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:12.972 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 505 (601.7584800720215 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=209132245, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4115, last_stable_offset=4115, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10\x01\x00\x00\x01\x02\x00\x00\x00\x00\x02]\x11&\xc2\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9e\x03\x00\x00\x00\xe0\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 12/29/2025 02:09:12.972 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 209132245 with 1 response partitions (0 implied) 12/29/2025 02:09:12.973 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 4759 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4097 12/29/2025 02:09:12.973 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4097 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 12/29/2025 02:09:12.974 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4115 (leader epoch 0) 12/29/2025 02:09:13.011 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 236 12/29/2025 02:09:13.012 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/29/2025 02:09:13.012 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/29/2025 02:09:13.012 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.012 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=358, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=236, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.012 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 361 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=358, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=236, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.012 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208511.239502, idle connection 147406.000000, request 304999.950171 12/29/2025 02:09:13.013 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208510.648438, idle connection 147405.000000, request 304999.366283 12/29/2025 02:09:13.013 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361 12/29/2025 02:09:13.013 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.014 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 361 (1.3270378112792969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=482714367, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=237, last_stable_offset=237, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xec\x00\x00\x01\x10\x00\x00\x00\x00\x02\xf6\xf4\xcf\xf8\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\xba\x03\x00\x00\x00\xac\x03ObjectApplicationPolicySetTable:...')])]) 12/29/2025 02:09:13.014 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 482714367 with 1 response partitions (0 implied) 12/29/2025 02:09:13.014 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 284 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 236 12/29/2025 02:09:13.014 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 236 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) 12/29/2025 02:09:13.014 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 237 (leader epoch 0) 12/29/2025 02:09:13.020 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 81 12/29/2025 02:09:13.020 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 12/29/2025 02:09:13.020 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 12/29/2025 02:09:13.020 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.020 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650727247, session_epoch=346, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.020 7fe50528a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650727247, session_epoch=346, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.020 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208197.543457, idle connection 147238.000000, request 304999.956131 12/29/2025 02:09:13.021 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208197.096436, idle connection 147238.000000, request 304999.511003 12/29/2025 02:09:13.075 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4115 12/29/2025 02:09:13.075 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/29/2025 02:09:13.075 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 12/29/2025 02:09:13.075 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.075 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=503, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4115, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.075 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 506 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=503, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4115, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.076 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208159.287842, idle connection 146849.000000, request 304999.915838 12/29/2025 02:09:13.076 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208158.822510, idle connection 146849.000000, request 304999.463558 12/29/2025 02:09:13.089 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 37 12/29/2025 02:09:13.090 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 12/29/2025 02:09:13.090 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 12/29/2025 02:09:13.090 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.090 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277358227, session_epoch=335, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.090 7fe503c7e360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277358227, session_epoch=335, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.090 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208664.561523, idle connection 147076.000000, request 304999.942064 12/29/2025 02:09:13.091 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208663.933594, idle connection 147076.000000, request 304999.324799 12/29/2025 02:09:13.114 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 7 12/29/2025 02:09:13.114 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/29/2025 02:09:13.114 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/29/2025 02:09:13.115 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.115 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1923490575, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.115 7fe50528a2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1923490575, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.115 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208363.570312, idle connection 146893.000000, request 304999.945164 12/29/2025 02:09:13.115 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208414.534912, idle connection 147158.000000, request 304395.449162 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 237 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=359, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=237, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 362 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=359, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=237, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.116 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208407.212646, idle connection 147302.000000, request 304999.929667 12/29/2025 02:09:13.117 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208361.670654, idle connection 146891.000000, request 304998.054743 12/29/2025 02:09:13.117 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 12/29/2025 02:09:13.117 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.118 7fe50528ab80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 339 (606.8134307861328 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1166458351, topics=[]) 12/29/2025 02:09:13.118 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1166458351 with 0 response partitions (1 implied) 12/29/2025 02:09:13.118 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208405.239990, idle connection 147300.000000, request 304997.976065 12/29/2025 02:09:13.121 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207973.293457, idle connection 147217.000000, request 304397.724152 12/29/2025 02:09:13.122 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 353 12/29/2025 02:09:13.122 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.122 7fe505cb5040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 353 (602.837085723877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1910242677, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=136, last_stable_offset=136, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\x87\x00\x00\x01\x08\x00\x00\x00\x00\x02F\xce\x7fj\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\xaa\x03\x00\x00\x00\x9c\x03ObjectApplicationPolicySetTable:...')])]) 12/29/2025 02:09:13.122 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1910242677 with 1 response partitions (0 implied) 12/29/2025 02:09:13.122 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 276 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 135 12/29/2025 02:09:13.123 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 135 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 12/29/2025 02:09:13.123 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 136 (leader epoch 0) 12/29/2025 02:09:13.176 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/29/2025 02:09:13.176 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 12/29/2025 02:09:13.176 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 12/29/2025 02:09:13.176 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.176 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=510802178, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.177 7fe503fabd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=510802178, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.177 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207802.663574, idle connection 146762.000000, request 304999.947548 12/29/2025 02:09:13.177 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207802.192383, idle connection 146762.000000, request 304999.484777 12/29/2025 02:09:13.204 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/29/2025 02:09:13.205 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 12/29/2025 02:09:13.205 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 12/29/2025 02:09:13.205 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.205 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292206838, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.205 7fe50528a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292206838, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.205 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207782.640625, idle connection 146770.000000, request 304999.934912 12/29/2025 02:09:13.206 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207782.139404, idle connection 146770.000000, request 304999.447584 12/29/2025 02:09:13.207 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 12/29/2025 02:09:13.207 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 12/29/2025 02:09:13.207 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 12/29/2025 02:09:13.207 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.208 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807681411, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.208 7fe50528a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807681411, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.208 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207781.652832, idle connection 146772.000000, request 304999.944448 12/29/2025 02:09:13.208 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207946.194092, idle connection 147306.000000, request 304396.996975 12/29/2025 02:09:13.209 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207781.051514, idle connection 146772.000000, request 304999.349356 12/29/2025 02:09:13.209 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 360 12/29/2025 02:09:13.209 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.209 7fe505cb5cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 360 (603.84202003479 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1229513059, topics=[]) 12/29/2025 02:09:13.209 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1229513059 with 0 response partitions (1 implied) 12/29/2025 02:09:13.222 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/29/2025 02:09:13.222 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 12/29/2025 02:09:13.222 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 12/29/2025 02:09:13.222 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.222 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=13772558, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.223 7fe50438fea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=13772558, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.223 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207889.830566, idle connection 146882.000000, request 304999.953508 12/29/2025 02:09:13.223 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207889.463623, idle connection 146881.000000, request 304999.593735 12/29/2025 02:09:13.223 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 136 12/29/2025 02:09:13.223 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/29/2025 02:09:13.223 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/29/2025 02:09:13.224 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.224 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1910242677, session_epoch=351, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=136, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.224 7fe505cb5040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 354 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1910242677, session_epoch=351, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=136, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.224 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207870.690918, idle connection 147115.000000, request 304999.964237 12/29/2025 02:09:13.224 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207870.330566, idle connection 147115.000000, request 304999.606133 12/29/2025 02:09:13.226 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207924.098633, idle connection 147104.000000, request 304399.313450 12/29/2025 02:09:13.226 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345 12/29/2025 02:09:13.226 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.226 7fe50528acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 345 (601.0572910308838 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1456496388, topics=[]) 12/29/2025 02:09:13.227 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1456496388 with 0 response partitions (1 implied) 12/29/2025 02:09:13.231 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208463.874756, idle connection 146991.000000, request 304398.847818 12/29/2025 02:09:13.231 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333 12/29/2025 02:09:13.231 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.231 7fe50434b900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 333 (601.5210151672363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2062959213, topics=[]) 12/29/2025 02:09:13.232 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2062959213 with 0 response partitions (1 implied) 12/29/2025 02:09:13.282 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/29/2025 02:09:13.282 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/29/2025 02:09:13.282 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/29/2025 02:09:13.282 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.282 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=376128818, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.283 7fe503d5e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=376128818, session_epoch=325, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.283 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207865.854492, idle connection 146840.000000, request 304999.951839 12/29/2025 02:09:13.283 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207865.455811, idle connection 146840.000000, request 304999.559641 12/29/2025 02:09:13.283 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 43 12/29/2025 02:09:13.283 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/29/2025 02:09:13.283 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/29/2025 02:09:13.284 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.284 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29253219, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.284 7fe50528a7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29253219, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.284 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208514.656738, idle connection 146939.000000, request 304999.965668 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 43 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1796471111, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1796471111, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.284 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208549.808105, idle connection 146880.000000, request 304999.968767 12/29/2025 02:09:13.285 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208513.688965, idle connection 146938.000000, request 304999.000788 12/29/2025 02:09:13.285 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208549.272705, idle connection 146880.000000, request 304999.435663 12/29/2025 02:09:13.331 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 6 12/29/2025 02:09:13.331 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 12/29/2025 02:09:13.331 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 12/29/2025 02:09:13.331 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.331 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=926551996, session_epoch=329, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.332 7fe50432b0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=926551996, session_epoch=329, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.332 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207580.664551, idle connection 146816.000000, request 304999.948502 12/29/2025 02:09:13.332 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207580.224121, idle connection 146816.000000, request 304999.516726 12/29/2025 02:09:13.442 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207954.492676, idle connection 147014.000000, request 304397.805452 12/29/2025 02:09:13.442 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 356 12/29/2025 02:09:13.442 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.442 7fe505cb5900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 356 (602.7274131774902 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=664609216, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=213, last_stable_offset=213, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xd1\x00\x00\x00\xfc\x00\x00\x00\x00\x02mt\x86Z\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x92\x03\x00\x00\x00\xd4\x02ObjectProjectTable:default-domai...')])]) 12/29/2025 02:09:13.443 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 664609216 with 1 response partitions (0 implied) 12/29/2025 02:09:13.443 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1032 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 209 12/29/2025 02:09:13.443 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 209 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 12/29/2025 02:09:13.443 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 213 (leader epoch 0) 12/29/2025 02:09:13.444 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207965.795166, idle connection 146827.000000, request 304398.699045 12/29/2025 02:09:13.445 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 12/29/2025 02:09:13.445 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.445 7fe50528ae00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 338 (601.6459465026855 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=817968639, topics=[]) 12/29/2025 02:09:13.445 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 817968639 with 0 response partitions (1 implied) 12/29/2025 02:09:13.446 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208671.929932, idle connection 147071.000000, request 304398.316860 12/29/2025 02:09:13.446 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344 12/29/2025 02:09:13.446 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.446 7fe505cb5b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 344 (601.982831954956 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529473258, topics=[]) 12/29/2025 02:09:13.446 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529473258 with 0 response partitions (1 implied) 12/29/2025 02:09:13.448 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208028.896240, idle connection 147016.000000, request 304397.551775 12/29/2025 02:09:13.448 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361 12/29/2025 02:09:13.448 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.448 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 361 (602.7581691741943 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=961776489, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=184, last_stable_offset=184, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xae\x00\x00\x00\xf4\x00\x00\x00\x00\x02V*\xf4\xf0\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\x82\x03\x00\x00\x00\xc4\x02ObjectProjectTable:default-domai...')])]) 12/29/2025 02:09:13.448 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 961776489 with 1 response partitions (0 implied) 12/29/2025 02:09:13.448 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 2552 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 174 12/29/2025 02:09:13.449 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 174 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) 12/29/2025 02:09:13.449 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 184 (leader epoch 0) 12/29/2025 02:09:13.450 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207265.776611, idle connection 146546.000000, request 304396.591663 12/29/2025 02:09:13.450 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:13.450 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.451 7fe50528a680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (603.7619113922119 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1509807947, topics=[]) 12/29/2025 02:09:13.451 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1509807947 with 0 response partitions (1 implied) 12/29/2025 02:09:13.528 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 228 12/29/2025 02:09:13.528 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/29/2025 02:09:13.528 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/29/2025 02:09:13.529 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.529 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1688050189, session_epoch=362, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.529 7fe505cb5180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 365 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1688050189, session_epoch=362, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.529 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207847.036377, idle connection 146812.000000, request 304999.951124 12/29/2025 02:09:13.529 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208308.502197, idle connection 146639.000000, request 304396.392822 12/29/2025 02:09:13.529 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208444.059082, idle connection 146696.000000, request 304396.932364 12/29/2025 02:09:13.529 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207277.754150, idle connection 146599.000000, request 304397.438765 12/29/2025 02:09:13.530 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207846.205566, idle connection 146811.000000, request 304999.129772 12/29/2025 02:09:13.530 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:13.530 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.530 7fe503c7e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (604.5396327972412 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1354335972, topics=[]) 12/29/2025 02:09:13.530 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1354335972 with 0 response partitions (1 implied) 12/29/2025 02:09:13.530 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 337 12/29/2025 02:09:13.531 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.531 7fe50528a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 337 (604.3343544006348 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=418798700, topics=[]) 12/29/2025 02:09:13.531 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 418798700 with 0 response partitions (1 implied) 12/29/2025 02:09:13.531 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:13.531 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.531 7fe503d5e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (604.1858196258545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=759178101, topics=[]) 12/29/2025 02:09:13.531 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 759178101 with 0 response partitions (1 implied) 12/29/2025 02:09:13.540 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207611.725342, idle connection 146926.000000, request 304399.226427 12/29/2025 02:09:13.541 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357 12/29/2025 02:09:13.541 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.541 7fe505cb5860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 357 (601.1512279510498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876908981, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=177, last_stable_offset=177, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x00\xad\x00\x00\x00\xfd\x00\x00\x00\x00\x02/XP'\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x94\x03\x00\x00\x00\xd6\x02ObjectProjectTable:default-domai...")])]) 12/29/2025 02:09:13.541 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876908981 with 1 response partitions (0 implied) 12/29/2025 02:09:13.541 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1036 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 173 12/29/2025 02:09:13.541 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 173 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 12/29/2025 02:09:13.542 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 177 (leader epoch 0) 12/29/2025 02:09:13.542 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207200.284424, idle connection 146401.000000, request 304399.288654 12/29/2025 02:09:13.542 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 12/29/2025 02:09:13.542 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.542 7fe503fabea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 341 (601.0046005249023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=720032835, topics=[]) 12/29/2025 02:09:13.543 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 720032835 with 0 response partitions (1 implied) 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 213 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=664609216, session_epoch=354, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=213, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=664609216, session_epoch=354, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=213, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.544 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207852.090576, idle connection 146911.000000, request 304999.961853 12/29/2025 02:09:13.545 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207851.742188, idle connection 146911.000000, request 304999.615669 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 184 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-27', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=359, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=184, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 362 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=359, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=184, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.550 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207926.350586, idle connection 146914.000000, request 304999.964476 12/29/2025 02:09:13.551 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207926.046631, idle connection 146913.000000, request 304999.660969 12/29/2025 02:09:13.551 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208632.054688, idle connection 146800.000000, request 304398.983955 12/29/2025 02:09:13.551 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362 12/29/2025 02:09:13.551 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.551 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 362 (601.4537811279297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=234546897, topics=[]) 12/29/2025 02:09:13.551 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 234546897 with 0 response partitions (1 implied) 12/29/2025 02:09:13.621 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207596.614014, idle connection 146637.000000, request 304399.022579 12/29/2025 02:09:13.622 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 349 12/29/2025 02:09:13.622 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.622 7fe50528a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 349 (601.4814376831055 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=650727247, topics=[]) 12/29/2025 02:09:13.622 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 650727247 with 0 response partitions (1 implied) 12/29/2025 02:09:13.642 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 177 12/29/2025 02:09:13.642 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 12/29/2025 02:09:13.642 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 12/29/2025 02:09:13.642 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.643 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876908981, session_epoch=355, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=177, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.643 7fe505cb5860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876908981, session_epoch=355, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=177, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.643 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207509.323242, idle connection 146824.000000, request 304999.949694 12/29/2025 02:09:13.643 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207508.883301, idle connection 146823.000000, request 304999.517441 12/29/2025 02:09:13.677 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207557.746582, idle connection 146248.000000, request 304398.373604 12/29/2025 02:09:13.678 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 506 12/29/2025 02:09:13.678 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.678 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 506 (602.454662322998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=209132245, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4147, last_stable_offset=4147, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10\x13\x00\x00\x01\xdd\x00\x00\x00\x00\x02/OsK\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\xa8\x03\x00\x00\x00\xea\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])]) 12/29/2025 02:09:13.678 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 209132245 with 1 response partitions (0 implied) 12/29/2025 02:09:13.679 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 8190 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4115 12/29/2025 02:09:13.679 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4115 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 12/29/2025 02:09:13.682 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4147 (leader epoch 0) 12/29/2025 02:09:13.691 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208063.417480, idle connection 146475.000000, request 304398.797512 12/29/2025 02:09:13.692 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 12/29/2025 02:09:13.692 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.692 7fe503c7e360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 338 (602.0269393920898 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277358227, topics=[]) 12/29/2025 02:09:13.693 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277358227 with 0 response partitions (1 implied) 12/29/2025 02:09:13.718 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44 12/29/2025 02:09:13.719 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/29/2025 02:09:13.719 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/29/2025 02:09:13.719 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.719 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1166458351, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.719 7fe50528ab80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1166458351, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.719 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207810.416016, idle connection 146554.000000, request 304999.925375 12/29/2025 02:09:13.720 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207758.817139, idle connection 146288.000000, request 304395.194292 12/29/2025 02:09:13.720 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207803.596680, idle connection 146698.000000, request 304396.332264 12/29/2025 02:09:13.720 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207809.388184, idle connection 146553.000000, request 304998.912096 12/29/2025 02:09:13.721 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 12/29/2025 02:09:13.721 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.721 7fe50528a2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 331 (605.8847904205322 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1923490575, topics=[]) 12/29/2025 02:09:13.721 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1923490575 with 0 response partitions (1 implied) 12/29/2025 02:09:13.721 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362 12/29/2025 02:09:13.721 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.721 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 362 (605.0832271575928 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=482714367, topics=[]) 12/29/2025 02:09:13.721 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 482714367 with 0 response partitions (1 implied) 12/29/2025 02:09:13.778 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207201.624023, idle connection 146161.000000, request 304398.907661 12/29/2025 02:09:13.778 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/29/2025 02:09:13.778 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.778 7fe503fabd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 328 (601.6287803649902 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=510802178, topics=[]) 12/29/2025 02:09:13.778 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 510802178 with 0 response partitions (1 implied) 12/29/2025 02:09:13.783 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4147 12/29/2025 02:09:13.784 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/29/2025 02:09:13.784 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 12/29/2025 02:09:13.784 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.784 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=504, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4147, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.784 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 507 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=504, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4147, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:13.784 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207450.759033, idle connection 146141.000000, request 304999.953032 12/29/2025 02:09:13.785 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207450.345947, idle connection 146140.000000, request 304999.546051 12/29/2025 02:09:13.806 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207181.556641, idle connection 146169.000000, request 304398.856878 12/29/2025 02:09:13.807 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/29/2025 02:09:13.807 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.807 7fe50528a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 328 (601.6361713409424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1292206838, topics=[]) 12/29/2025 02:09:13.807 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1292206838 with 0 response partitions (1 implied) 12/29/2025 02:09:13.809 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 222 12/29/2025 02:09:13.809 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/29/2025 02:09:13.809 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/29/2025 02:09:13.810 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.810 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1229513059, session_epoch=358, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.810 7fe505cb5cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 361 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1229513059, session_epoch=358, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.810 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207344.428223, idle connection 146705.000000, request 304999.953508 12/29/2025 02:09:13.810 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207179.428467, idle connection 146170.000000, request 304397.724628 12/29/2025 02:09:13.810 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207343.895996, idle connection 146704.000000, request 304999.425888 12/29/2025 02:09:13.811 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/29/2025 02:09:13.811 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.811 7fe50528a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 328 (602.9322147369385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1807681411, topics=[]) 12/29/2025 02:09:13.811 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1807681411 with 0 response partitions (1 implied) 12/29/2025 02:09:13.824 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207288.169678, idle connection 146280.000000, request 304398.291111 12/29/2025 02:09:13.825 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/29/2025 02:09:13.825 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.825 7fe50438fea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 328 (602.3068428039551 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=13772558, topics=[]) 12/29/2025 02:09:13.825 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 13772558 with 0 response partitions (1 implied) 12/29/2025 02:09:13.825 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207269.364746, idle connection 146514.000000, request 304398.639679 12/29/2025 02:09:13.825 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 354 12/29/2025 02:09:13.825 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.826 7fe505cb5040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 354 (601.6654968261719 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1910242677, topics=[]) 12/29/2025 02:09:13.826 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1910242677 with 0 response partitions (1 implied) 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 168 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1456496388, session_epoch=343, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 346 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1456496388, session_epoch=343, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.827 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207322.844482, idle connection 146503.000000, request 304999.958277 12/29/2025 02:09:13.828 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207322.452881, idle connection 146502.000000, request 304999.572754 12/29/2025 02:09:13.832 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 18 12/29/2025 02:09:13.832 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 12/29/2025 02:09:13.832 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 12/29/2025 02:09:13.832 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:13.832 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062959213, session_epoch=331, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.832 7fe50434b900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062959213, session_epoch=331, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:13.833 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207862.204102, idle connection 146389.000000, request 304999.960184 12/29/2025 02:09:13.833 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207861.852783, idle connection 146389.000000, request 304999.610901 12/29/2025 02:09:13.885 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207263.946045, idle connection 146238.000000, request 304398.045063 12/29/2025 02:09:13.885 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328 12/29/2025 02:09:13.885 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.885 7fe503d5e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 328 (602.68235206604 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=376128818, topics=[]) 12/29/2025 02:09:13.886 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 376128818 with 0 response partitions (1 implied) 12/29/2025 02:09:13.886 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207912.594727, idle connection 146337.000000, request 304397.903919 12/29/2025 02:09:13.886 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207948.302979, idle connection 146279.000000, request 304398.465157 12/29/2025 02:09:13.886 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 12/29/2025 02:09:13.886 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.886 7fe50528a7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 339 (602.5731563568115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=29253219, topics=[]) 12/29/2025 02:09:13.886 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 29253219 with 0 response partitions (1 implied) 12/29/2025 02:09:13.887 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 12/29/2025 02:09:13.887 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.887 7fe503c7e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 340 (602.3154258728027 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1796471111, topics=[]) 12/29/2025 02:09:13.887 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1796471111 with 0 response partitions (1 implied) 12/29/2025 02:09:13.933 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206979.740234, idle connection 146215.000000, request 304399.024487 12/29/2025 02:09:13.933 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 12/29/2025 02:09:13.933 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:13.933 7fe50432b0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 332 (601.5429496765137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=926551996, topics=[]) 12/29/2025 02:09:13.933 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 926551996 with 0 response partitions (1 implied) 12/29/2025 02:09:14.045 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 31 12/29/2025 02:09:14.045 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 12/29/2025 02:09:14.045 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 12/29/2025 02:09:14.046 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.046 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=817968639, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.046 7fe50528ae00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=817968639, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.046 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207364.181396, idle connection 146225.000000, request 304999.942780 12/29/2025 02:09:14.047 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207363.631104, idle connection 146225.000000, request 304999.401093 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 117 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529473258, session_epoch=342, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 345 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529473258, session_epoch=342, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.047 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208070.221680, idle connection 146469.000000, request 304999.861717 12/29/2025 02:09:14.048 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208069.581543, idle connection 146468.000000, request 304999.222517 12/29/2025 02:09:14.051 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 3 12/29/2025 02:09:14.051 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 12/29/2025 02:09:14.051 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 12/29/2025 02:09:14.051 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.051 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1509807947, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.052 7fe50528a680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1509807947, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.052 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206664.294189, idle connection 145944.000000, request 304999.962091 12/29/2025 02:09:14.052 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206663.882080, idle connection 145944.000000, request 304999.553442 12/29/2025 02:09:14.131 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 2 12/29/2025 02:09:14.131 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 12/29/2025 02:09:14.131 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 12/29/2025 02:09:14.131 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.131 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1354335972, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.131 7fe503c7e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1354335972, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.132 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207706.129150, idle connection 146037.000000, request 304999.933481 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 40 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=418798700, session_epoch=335, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=418798700, session_epoch=335, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.132 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207840.983154, idle connection 146093.000000, request 304999.947309 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=759178101, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=759178101, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.133 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206674.073486, idle connection 145996.000000, request 304999.961376 12/29/2025 02:09:14.133 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207242.666260, idle connection 146208.000000, request 304395.585775 12/29/2025 02:09:14.134 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207703.945801, idle connection 146035.000000, request 304997.756720 12/29/2025 02:09:14.134 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 365 12/29/2025 02:09:14.134 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.134 7fe505cb5180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 365 (605.318546295166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1688050189, topics=[]) 12/29/2025 02:09:14.134 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1688050189 with 0 response partitions (1 implied) 12/29/2025 02:09:14.135 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207838.549316, idle connection 146090.000000, request 304997.518301 12/29/2025 02:09:14.135 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206671.992676, idle connection 145994.000000, request 304997.879982 12/29/2025 02:09:14.143 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 66 12/29/2025 02:09:14.143 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/29/2025 02:09:14.143 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/29/2025 02:09:14.143 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.144 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=720032835, session_epoch=339, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.144 7fe503fabea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=720032835, session_epoch=339, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.144 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206598.658447, idle connection 145800.000000, request 304999.956846 12/29/2025 02:09:14.144 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206598.239502, idle connection 145799.000000, request 304999.543428 12/29/2025 02:09:14.145 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207251.461670, idle connection 146311.000000, request 304399.334669 12/29/2025 02:09:14.145 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357 12/29/2025 02:09:14.145 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.145 7fe505cb5900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 357 (600.9962558746338 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=664609216, topics=[]) 12/29/2025 02:09:14.145 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 664609216 with 0 response partitions (1 implied) 12/29/2025 02:09:14.151 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207325.529541, idle connection 146313.000000, request 304399.141073 12/29/2025 02:09:14.151 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362 12/29/2025 02:09:14.152 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.152 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 362 (601.3379096984863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=961776489, topics=[]) 12/29/2025 02:09:14.152 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 961776489 with 0 response partitions (1 implied) 12/29/2025 02:09:14.152 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 226 12/29/2025 02:09:14.152 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/29/2025 02:09:14.152 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 12/29/2025 02:09:14.152 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.152 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=360, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.153 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 363 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=360, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.153 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208030.287842, idle connection 146198.000000, request 304999.959707 12/29/2025 02:09:14.153 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208029.876221, idle connection 146198.000000, request 304999.550581 12/29/2025 02:09:14.222 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 81 12/29/2025 02:09:14.223 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 12/29/2025 02:09:14.223 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 12/29/2025 02:09:14.223 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.223 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650727247, session_epoch=347, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.223 7fe50528a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650727247, session_epoch=347, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.223 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206994.853760, idle connection 146035.000000, request 304999.950647 12/29/2025 02:09:14.224 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206994.441406, idle connection 146035.000000, request 304999.541998 12/29/2025 02:09:14.244 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206908.417236, idle connection 146223.000000, request 304399.038553 12/29/2025 02:09:14.244 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358 12/29/2025 02:09:14.244 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.244 7fe505cb5860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 358 (601.4666557312012 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876908981, topics=[]) 12/29/2025 02:09:14.244 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876908981 with 0 response partitions (1 implied) 12/29/2025 02:09:14.293 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 37 12/29/2025 02:09:14.293 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 12/29/2025 02:09:14.293 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 12/29/2025 02:09:14.293 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.294 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277358227, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.294 7fe503c7e360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277358227, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.294 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207460.917969, idle connection 145873.000000, request 304999.945164 12/29/2025 02:09:14.294 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207460.514404, idle connection 145872.000000, request 304999.548912 12/29/2025 02:09:14.321 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 7 12/29/2025 02:09:14.322 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/29/2025 02:09:14.322 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/29/2025 02:09:14.322 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.322 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1923490575, session_epoch=329, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.322 7fe50528a2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1923490575, session_epoch=329, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.322 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207156.393799, idle connection 145686.000000, request 304999.941349 12/29/2025 02:09:14.323 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 237 12/29/2025 02:09:14.323 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/29/2025 02:09:14.323 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/29/2025 02:09:14.323 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.324 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=360, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.324 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 363 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=360, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.324 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207199.547607, idle connection 146094.000000, request 304999.958515 12/29/2025 02:09:14.324 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207205.589111, idle connection 145949.000000, request 304395.113230 12/29/2025 02:09:14.324 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207154.015869, idle connection 145683.000000, request 304997.577906 12/29/2025 02:09:14.325 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 12/29/2025 02:09:14.325 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.325 7fe50528ab80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 340 (605.9203147888184 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1166458351, topics=[]) 12/29/2025 02:09:14.326 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1166458351 with 0 response partitions (1 implied) 12/29/2025 02:09:14.326 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207197.279785, idle connection 146092.000000, request 304997.694254 12/29/2025 02:09:14.381 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/29/2025 02:09:14.382 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 12/29/2025 02:09:14.382 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 12/29/2025 02:09:14.382 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.382 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=510802178, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.382 7fe503fabd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=510802178, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.382 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206597.140381, idle connection 145557.000000, request 304999.949694 12/29/2025 02:09:14.383 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206596.716309, idle connection 145556.000000, request 304999.533176 12/29/2025 02:09:14.386 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206848.977539, idle connection 145539.000000, request 304398.175955 12/29/2025 02:09:14.386 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 507 12/29/2025 02:09:14.386 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.386 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 507 (602.1947860717773 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=209132245, topics=[]) 12/29/2025 02:09:14.386 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 209132245 with 0 response partitions (1 implied) 12/29/2025 02:09:14.407 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/29/2025 02:09:14.407 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 12/29/2025 02:09:14.408 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 12/29/2025 02:09:14.408 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.408 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292206838, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.408 7fe50528a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292206838, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.408 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206579.730713, idle connection 145568.000000, request 304999.932289 12/29/2025 02:09:14.409 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206579.251709, idle connection 145567.000000, request 304999.462366 12/29/2025 02:09:14.411 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 12/29/2025 02:09:14.411 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 12/29/2025 02:09:14.411 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 12/29/2025 02:09:14.411 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.411 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807681411, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.412 7fe50528a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807681411, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.412 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206577.840820, idle connection 145569.000000, request 304999.959707 12/29/2025 02:09:14.412 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206742.428711, idle connection 146103.000000, request 304397.957802 12/29/2025 02:09:14.412 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206577.372070, idle connection 145568.000000, request 304999.495268 12/29/2025 02:09:14.412 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361 12/29/2025 02:09:14.413 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.413 7fe505cb5cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 361 (602.7650833129883 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1229513059, topics=[]) 12/29/2025 02:09:14.413 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1229513059 with 0 response partitions (1 implied) 12/29/2025 02:09:14.425 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/29/2025 02:09:14.426 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 12/29/2025 02:09:14.426 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 12/29/2025 02:09:14.426 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.426 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=13772558, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.426 7fe50438fea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=13772558, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.426 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206686.464844, idle connection 145678.000000, request 304999.953508 12/29/2025 02:09:14.426 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 136 12/29/2025 02:09:14.426 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/29/2025 02:09:14.426 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/29/2025 02:09:14.426 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.427 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1910242677, session_epoch=352, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.427 7fe505cb5040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1910242677, session_epoch=352, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.427 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206667.837891, idle connection 145912.000000, request 304999.963999 12/29/2025 02:09:14.427 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206685.385986, idle connection 145677.000000, request 304998.882532 12/29/2025 02:09:14.428 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206667.116943, idle connection 145911.000000, request 304999.245405 12/29/2025 02:09:14.428 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206722.178467, idle connection 145902.000000, request 304399.299145 12/29/2025 02:09:14.428 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 346 12/29/2025 02:09:14.428 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.428 7fe50528acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 346 (601.0386943817139 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1456496388, topics=[]) 12/29/2025 02:09:14.428 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1456496388 with 0 response partitions (1 implied) 12/29/2025 02:09:14.434 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207261.173828, idle connection 145788.000000, request 304398.930550 12/29/2025 02:09:14.434 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334 12/29/2025 02:09:14.434 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.434 7fe50434b900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 334 (601.4153957366943 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2062959213, topics=[]) 12/29/2025 02:09:14.434 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2062959213 with 0 response partitions (1 implied) 12/29/2025 02:09:14.488 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/29/2025 02:09:14.488 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/29/2025 02:09:14.488 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/29/2025 02:09:14.488 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.488 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=376128818, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.488 7fe503d5e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=376128818, session_epoch=326, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.489 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206659.909912, idle connection 145634.000000, request 304999.931574 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 43 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29253219, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29253219, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.489 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207308.988281, idle connection 145734.000000, request 304999.950409 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 43 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1796471111, session_epoch=338, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1796471111, session_epoch=338, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.490 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207344.095215, idle connection 145675.000000, request 304999.947309 12/29/2025 02:09:14.491 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206657.914307, idle connection 145632.000000, request 304997.946024 12/29/2025 02:09:14.491 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207307.489502, idle connection 145732.000000, request 304998.460293 12/29/2025 02:09:14.491 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207343.056641, idle connection 145674.000000, request 304998.915672 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 6 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=926551996, session_epoch=330, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=926551996, session_epoch=330, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.535 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206376.944580, idle connection 145613.000000, request 304999.926805 12/29/2025 02:09:14.536 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206376.375488, idle connection 145612.000000, request 304999.371290 12/29/2025 02:09:14.648 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206762.194824, idle connection 145623.000000, request 304397.950888 12/29/2025 02:09:14.649 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 12/29/2025 02:09:14.649 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.649 7fe50528ae00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 339 (603.1074523925781 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=817968639, topics=[]) 12/29/2025 02:09:14.649 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 817968639 with 0 response partitions (1 implied) 12/29/2025 02:09:14.649 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207468.190186, idle connection 145867.000000, request 304397.829771 12/29/2025 02:09:14.650 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345 12/29/2025 02:09:14.650 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.650 7fe505cb5b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 345 (602.6444435119629 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529473258, topics=[]) 12/29/2025 02:09:14.650 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529473258 with 0 response partitions (1 implied) 12/29/2025 02:09:14.653 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206063.031250, idle connection 145343.000000, request 304398.699045 12/29/2025 02:09:14.653 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 12/29/2025 02:09:14.653 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.653 7fe50528a680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 330 (601.7811298370361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1509807947, topics=[]) 12/29/2025 02:09:14.654 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1509807947 with 0 response partitions (1 implied) 12/29/2025 02:09:14.735 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 228 12/29/2025 02:09:14.735 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/29/2025 02:09:14.735 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/29/2025 02:09:14.735 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.735 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1688050189, session_epoch=363, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.735 7fe505cb5180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 366 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1688050189, session_epoch=363, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.736 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206640.482422, idle connection 145605.000000, request 304999.949455 12/29/2025 02:09:14.736 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207101.932373, idle connection 145433.000000, request 304395.745039 12/29/2025 02:09:14.736 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207237.457520, idle connection 145489.000000, request 304396.429062 12/29/2025 02:09:14.736 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206071.140137, idle connection 145393.000000, request 304397.031069 12/29/2025 02:09:14.736 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206639.596436, idle connection 145604.000000, request 304999.072313 12/29/2025 02:09:14.737 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 12/29/2025 02:09:14.737 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.737 7fe503c7e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 330 (605.2539348602295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1354335972, topics=[]) 12/29/2025 02:09:14.737 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1354335972 with 0 response partitions (1 implied) 12/29/2025 02:09:14.737 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 12/29/2025 02:09:14.737 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.737 7fe50528a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 338 (604.8660278320312 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=418798700, topics=[]) 12/29/2025 02:09:14.737 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 418798700 with 0 response partitions (1 implied) 12/29/2025 02:09:14.738 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 12/29/2025 02:09:14.738 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.738 7fe503d5e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 330 (604.5911312103271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=759178101, topics=[]) 12/29/2025 02:09:14.738 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 759178101 with 0 response partitions (1 implied) 12/29/2025 02:09:14.745 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205997.664062, idle connection 145199.000000, request 304398.964882 12/29/2025 02:09:14.745 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342 12/29/2025 02:09:14.745 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.745 7fe503fabea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 342 (601.4158725738525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=720032835, topics=[]) 12/29/2025 02:09:14.745 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 720032835 with 0 response partitions (1 implied) 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 213 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=664609216, session_epoch=355, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=664609216, session_epoch=355, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206650.146484, idle connection 145709.000000, request 304999.959230 12/29/2025 02:09:14.746 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206649.814209, idle connection 145709.000000, request 304999.630451 12/29/2025 02:09:14.752 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 184 12/29/2025 02:09:14.752 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/29/2025 02:09:14.752 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 12/29/2025 02:09:14.752 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.752 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=360, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.753 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 363 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=360, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.753 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206723.902832, idle connection 145711.000000, request 304999.882221 12/29/2025 02:09:14.753 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206723.549072, idle connection 145711.000000, request 304999.533892 12/29/2025 02:09:14.753 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207429.448242, idle connection 145597.000000, request 304399.122238 12/29/2025 02:09:14.754 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 363 12/29/2025 02:09:14.754 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.754 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 363 (601.3057231903076 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=234546897, topics=[]) 12/29/2025 02:09:14.754 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 234546897 with 0 response partitions (1 implied) 12/29/2025 02:09:14.826 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206391.981934, idle connection 145433.000000, request 304397.078037 12/29/2025 02:09:14.827 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350 12/29/2025 02:09:14.827 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.827 7fe50528a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 350 (603.6622524261475 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=650727247, topics=[]) 12/29/2025 02:09:14.827 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 650727247 with 0 response partitions (1 implied) 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 177 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876908981, session_epoch=356, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 359 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876908981, session_epoch=356, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.845 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206306.756104, idle connection 145621.000000, request 304999.952078 12/29/2025 02:09:14.846 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206306.281738, idle connection 145620.000000, request 304999.484301 12/29/2025 02:09:14.895 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206860.016846, idle connection 145272.000000, request 304399.036407 12/29/2025 02:09:14.895 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 12/29/2025 02:09:14.895 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.895 7fe503c7e360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 339 (601.5000343322754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1277358227, topics=[]) 12/29/2025 02:09:14.896 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1277358227 with 0 response partitions (1 implied) 12/29/2025 02:09:14.926 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44 12/29/2025 02:09:14.927 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/29/2025 02:09:14.927 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/29/2025 02:09:14.927 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.927 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1166458351, session_epoch=338, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.927 7fe50528ab80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1166458351, session_epoch=338, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.927 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206602.464844, idle connection 145346.000000, request 304999.944448 12/29/2025 02:09:14.928 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206550.887695, idle connection 145080.000000, request 304394.448042 12/29/2025 02:09:14.928 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206595.760742, idle connection 145490.000000, request 304396.176100 12/29/2025 02:09:14.928 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206601.697510, idle connection 145345.000000, request 304999.186993 12/29/2025 02:09:14.928 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 12/29/2025 02:09:14.928 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.928 7fe50528a2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 332 (606.3504219055176 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1923490575, topics=[]) 12/29/2025 02:09:14.929 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1923490575 with 0 response partitions (1 implied) 12/29/2025 02:09:14.929 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 363 12/29/2025 02:09:14.929 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.929 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 363 (605.0496101379395 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=482714367, topics=[]) 12/29/2025 02:09:14.929 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 482714367 with 0 response partitions (1 implied) 12/29/2025 02:09:14.984 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205995.736816, idle connection 144955.000000, request 304398.545265 12/29/2025 02:09:14.984 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:14.984 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:14.984 7fe503fabd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (601.9895076751709 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=510802178, topics=[]) 12/29/2025 02:09:14.984 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 510802178 with 0 response partitions (1 implied) 12/29/2025 02:09:14.988 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4147 12/29/2025 02:09:14.988 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/29/2025 02:09:14.988 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 12/29/2025 02:09:14.988 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:14.988 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=505, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.988 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 508 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=505, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:14.988 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206246.503906, idle connection 144937.000000, request 304999.956846 12/29/2025 02:09:14.989 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206246.081543, idle connection 144936.000000, request 304999.538183 12/29/2025 02:09:15.010 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205977.968506, idle connection 144966.000000, request 304398.171902 12/29/2025 02:09:15.010 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:15.010 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.010 7fe50528a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (602.3812294006348 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1292206838, topics=[]) 12/29/2025 02:09:15.011 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1292206838 with 0 response partitions (1 implied) 12/29/2025 02:09:15.014 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 222 12/29/2025 02:09:15.014 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/29/2025 02:09:15.014 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/29/2025 02:09:15.014 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.014 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1229513059, session_epoch=359, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.014 7fe505cb5cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 362 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1229513059, session_epoch=359, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.015 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206139.736572, idle connection 145500.000000, request 304999.955177 12/29/2025 02:09:15.015 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205974.725342, idle connection 144965.000000, request 304396.846771 12/29/2025 02:09:15.015 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206139.208252, idle connection 145500.000000, request 304999.432325 12/29/2025 02:09:15.015 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:15.015 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.015 7fe50528a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (603.7805080413818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1807681411, topics=[]) 12/29/2025 02:09:15.016 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1807681411 with 0 response partitions (1 implied) 12/29/2025 02:09:15.028 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206084.205078, idle connection 145076.000000, request 304397.696257 12/29/2025 02:09:15.029 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:15.029 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.029 7fe50438fea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (602.8454303741455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=13772558, topics=[]) 12/29/2025 02:09:15.029 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 13772558 with 0 response partitions (1 implied) 12/29/2025 02:09:15.029 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206065.401123, idle connection 145310.000000, request 304397.528172 12/29/2025 02:09:15.029 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 355 12/29/2025 02:09:15.030 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.030 7fe505cb5040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 355 (602.837324142456 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1910242677, topics=[]) 12/29/2025 02:09:15.030 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1910242677 with 0 response partitions (1 implied) 12/29/2025 02:09:15.030 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 168 12/29/2025 02:09:15.030 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 12/29/2025 02:09:15.030 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 12/29/2025 02:09:15.030 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.030 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1456496388, session_epoch=344, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.030 7fe50528acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 347 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1456496388, session_epoch=344, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.031 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206119.569092, idle connection 145299.000000, request 304999.962091 12/29/2025 02:09:15.031 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206119.050049, idle connection 145299.000000, request 304999.442101 12/29/2025 02:09:15.036 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 18 12/29/2025 02:09:15.036 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 12/29/2025 02:09:15.036 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 12/29/2025 02:09:15.036 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.036 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062959213, session_epoch=332, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.037 7fe50434b900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 335 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2062959213, session_epoch=332, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.037 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206658.000488, idle connection 145185.000000, request 304999.940157 12/29/2025 02:09:15.037 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206657.559570, idle connection 145184.000000, request 304999.506712 12/29/2025 02:09:15.092 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206056.822754, idle connection 145031.000000, request 304396.842480 12/29/2025 02:09:15.092 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 12/29/2025 02:09:15.092 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.093 7fe503d5e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 329 (604.0036678314209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=376128818, topics=[]) 12/29/2025 02:09:15.093 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 376128818 with 0 response partitions (1 implied) 12/29/2025 02:09:15.093 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206705.134766, idle connection 145130.000000, request 304396.102428 12/29/2025 02:09:15.094 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206740.775635, idle connection 145071.000000, request 304396.630049 12/29/2025 02:09:15.094 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 12/29/2025 02:09:15.094 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.094 7fe50528a7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 340 (604.8259735107422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=29253219, topics=[]) 12/29/2025 02:09:15.095 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 29253219 with 0 response partitions (1 implied) 12/29/2025 02:09:15.095 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 12/29/2025 02:09:15.095 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.095 7fe503c7e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 341 (604.9275398254395 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1796471111, topics=[]) 12/29/2025 02:09:15.095 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1796471111 with 0 response partitions (1 implied) 12/29/2025 02:09:15.137 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205775.764893, idle connection 145011.000000, request 304398.748636 12/29/2025 02:09:15.137 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333 12/29/2025 02:09:15.137 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.138 7fe50432b0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 333 (602.0958423614502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=926551996, topics=[]) 12/29/2025 02:09:15.138 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 926551996 with 0 response partitions (1 implied) 12/29/2025 02:09:15.250 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 31 12/29/2025 02:09:15.250 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 12/29/2025 02:09:15.250 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 12/29/2025 02:09:15.250 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.250 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=817968639, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.250 7fe50528ae00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=817968639, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.251 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206159.612305, idle connection 145021.000000, request 304999.938250 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 117 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529473258, session_epoch=343, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 346 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529473258, session_epoch=343, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.251 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206866.400391, idle connection 145265.000000, request 304999.963999 12/29/2025 02:09:15.252 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206158.584473, idle connection 145020.000000, request 304998.917818 12/29/2025 02:09:15.252 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206865.627686, idle connection 145264.000000, request 304999.193907 12/29/2025 02:09:15.254 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 3 12/29/2025 02:09:15.254 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 12/29/2025 02:09:15.255 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 12/29/2025 02:09:15.255 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.255 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1509807947, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.255 7fe50528a680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1509807947, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.255 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205460.832031, idle connection 144741.000000, request 304999.951124 12/29/2025 02:09:15.256 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205460.416992, idle connection 144740.000000, request 304999.546528 12/29/2025 02:09:15.337 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 2 12/29/2025 02:09:15.337 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 12/29/2025 02:09:15.337 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 12/29/2025 02:09:15.338 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.338 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1354335972, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.338 7fe503c7e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1354335972, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.338 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206499.758057, idle connection 144830.000000, request 304999.946594 12/29/2025 02:09:15.338 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 40 12/29/2025 02:09:15.338 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/29/2025 02:09:15.338 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/29/2025 02:09:15.338 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.339 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=418798700, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.339 7fe50528a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=418798700, session_epoch=336, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.339 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206634.663330, idle connection 144886.000000, request 304999.962807 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 4 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=759178101, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=759178101, session_epoch=328, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.339 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205467.881104, idle connection 144790.000000, request 304999.967098 12/29/2025 02:09:15.340 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206036.319092, idle connection 145001.000000, request 304395.792484 12/29/2025 02:09:15.340 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206497.609863, idle connection 144828.000000, request 304997.809410 12/29/2025 02:09:15.340 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 366 12/29/2025 02:09:15.340 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.340 7fe505cb5180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 366 (605.0131320953369 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1688050189, topics=[]) 12/29/2025 02:09:15.341 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1688050189 with 0 response partitions (1 implied) 12/29/2025 02:09:15.341 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206632.406982, idle connection 144884.000000, request 304997.709751 12/29/2025 02:09:15.341 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205465.902832, idle connection 144788.000000, request 304997.990847 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 66 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=720032835, session_epoch=340, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 343 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=720032835, session_epoch=340, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.346 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205396.174316, idle connection 144597.000000, request 304999.961853 12/29/2025 02:09:15.347 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205395.850098, idle connection 144597.000000, request 304999.641657 12/29/2025 02:09:15.347 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206049.476562, idle connection 145109.000000, request 304399.292946 12/29/2025 02:09:15.347 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358 12/29/2025 02:09:15.347 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.347 7fe505cb5900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 358 (601.2449264526367 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=664609216, topics=[]) 12/29/2025 02:09:15.348 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 664609216 with 0 response partitions (1 implied) 12/29/2025 02:09:15.354 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206123.122070, idle connection 145111.000000, request 304399.100780 12/29/2025 02:09:15.354 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 363 12/29/2025 02:09:15.354 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.354 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 363 (601.3145446777344 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=961776489, topics=[]) 12/29/2025 02:09:15.354 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 961776489 with 0 response partitions (1 implied) 12/29/2025 02:09:15.354 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 226 12/29/2025 02:09:15.354 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 12/29/2025 02:09:15.355 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 12/29/2025 02:09:15.355 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.355 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=361, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.355 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234546897, session_epoch=361, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.355 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206828.018555, idle connection 144996.000000, request 304999.962568 12/29/2025 02:09:15.355 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206827.485107, idle connection 144995.000000, request 304999.427080 12/29/2025 02:09:15.428 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 81 12/29/2025 02:09:15.428 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 12/29/2025 02:09:15.428 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 12/29/2025 02:09:15.428 7fe50528a860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.428 7fe50528a860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650727247, session_epoch=348, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.429 7fe50528a860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=650727247, session_epoch=348, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.429 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205789.299805, idle connection 144830.000000, request 304999.944448 12/29/2025 02:09:15.429 7fe50528a860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205788.761475, idle connection 144829.000000, request 304999.411345 12/29/2025 02:09:15.446 7fe505cb5860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205705.822754, idle connection 145020.000000, request 304399.016619 12/29/2025 02:09:15.447 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 359 12/29/2025 02:09:15.447 7fe505cb5860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.447 7fe505cb5860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 359 (601.5129089355469 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876908981, topics=[]) 12/29/2025 02:09:15.447 7fe505cb5860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876908981 with 0 response partitions (1 implied) 12/29/2025 02:09:15.496 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 37 12/29/2025 02:09:15.496 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 12/29/2025 02:09:15.496 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 12/29/2025 02:09:15.496 7fe503c7e360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.497 7fe503c7e360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277358227, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.497 7fe503c7e360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1277358227, session_epoch=337, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.497 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206257.824219, idle connection 144669.000000, request 304999.930859 12/29/2025 02:09:15.498 7fe503c7e360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206257.256836, idle connection 144669.000000, request 304999.373674 12/29/2025 02:09:15.529 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 7 12/29/2025 02:09:15.530 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/29/2025 02:09:15.530 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/29/2025 02:09:15.530 7fe50528a2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.530 7fe50528a2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1923490575, session_epoch=330, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.530 7fe50528a2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1923490575, session_epoch=330, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.530 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205948.291992, idle connection 144478.000000, request 304999.948502 12/29/2025 02:09:15.530 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 237 12/29/2025 02:09:15.531 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/29/2025 02:09:15.531 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/29/2025 02:09:15.531 7fe505cb5720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.531 7fe505cb5720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=361, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.531 7fe505cb5720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=482714367, session_epoch=361, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.531 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205992.453857, idle connection 144887.000000, request 304999.959707 12/29/2025 02:09:15.531 7fe50528ab80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205998.492188, idle connection 144742.000000, request 304395.980835 12/29/2025 02:09:15.532 7fe50528a2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205946.822266, idle connection 144476.000000, request 304998.488665 12/29/2025 02:09:15.532 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341 12/29/2025 02:09:15.532 7fe50528ab80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.532 7fe50528ab80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 341 (604.8681735992432 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1166458351, topics=[]) 12/29/2025 02:09:15.532 7fe50528ab80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1166458351 with 0 response partitions (1 implied) 12/29/2025 02:09:15.533 7fe505cb5720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205990.854736, idle connection 144885.000000, request 304998.363495 12/29/2025 02:09:15.585 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 12/29/2025 02:09:15.585 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 12/29/2025 02:09:15.585 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 12/29/2025 02:09:15.585 7fe503fabd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.585 7fe503fabd60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=510802178, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.585 7fe503fabd60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=510802178, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.586 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205393.853760, idle connection 144353.000000, request 304999.863625 12/29/2025 02:09:15.586 7fe503fabd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205393.220703, idle connection 144353.000000, request 304999.237299 12/29/2025 02:09:15.589 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205645.555908, idle connection 144336.000000, request 304399.007082 12/29/2025 02:09:15.590 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 508 12/29/2025 02:09:15.590 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.590 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 508 (601.6278266906738 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=209132245, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4149, last_stable_offset=4149, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x103\x00\x00\x00\xf8\x00\x00\x00\x00\x02\xb7x\xa5\x86\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\x8a\x03\x00\x00\x00\xcc\x02ObjectBgpRouter:cn-jenkins-deplo...')])]) 12/29/2025 02:09:15.590 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 209132245 with 1 response partitions (0 implied) 12/29/2025 02:09:15.590 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 532 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4147 12/29/2025 02:09:15.591 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4147 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 12/29/2025 02:09:15.591 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4149 (leader epoch 0) 12/29/2025 02:09:15.611 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 12/29/2025 02:09:15.611 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 12/29/2025 02:09:15.611 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 12/29/2025 02:09:15.611 7fe50528a400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.611 7fe50528a400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292206838, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.612 7fe50528a400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1292206838, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.612 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205375.990723, idle connection 144364.000000, request 304999.924898 12/29/2025 02:09:15.612 7fe50528a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205375.470703, idle connection 144363.000000, request 304999.415398 12/29/2025 02:09:15.616 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0 12/29/2025 02:09:15.616 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 12/29/2025 02:09:15.616 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 12/29/2025 02:09:15.616 7fe50528a4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.616 7fe50528a4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807681411, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.616 7fe50528a4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1807681411, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.617 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205372.937988, idle connection 144364.000000, request 304999.952555 12/29/2025 02:09:15.617 7fe505cb5cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205537.475342, idle connection 144898.000000, request 304397.697210 12/29/2025 02:09:15.617 7fe50528a4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205372.379150, idle connection 144363.000000, request 304999.399424 12/29/2025 02:09:15.617 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362 12/29/2025 02:09:15.617 7fe505cb5cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.618 7fe505cb5cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 362 (603.0123233795166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1229513059, topics=[]) 12/29/2025 02:09:15.618 7fe505cb5cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1229513059 with 0 response partitions (1 implied) 12/29/2025 02:09:15.629 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 12/29/2025 02:09:15.630 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 12/29/2025 02:09:15.630 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 12/29/2025 02:09:15.630 7fe50438fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.630 7fe50438fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=13772558, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.630 7fe50438fea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=13772558, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.630 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205482.397461, idle connection 144474.000000, request 304999.951363 12/29/2025 02:09:15.630 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 136 12/29/2025 02:09:15.630 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/29/2025 02:09:15.630 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/29/2025 02:09:15.630 7fe505cb5040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.631 7fe505cb5040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1910242677, session_epoch=353, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.631 7fe505cb5040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1910242677, session_epoch=353, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.631 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205463.849121, idle connection 144708.000000, request 304999.964952 12/29/2025 02:09:15.631 7fe50438fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205481.308594, idle connection 144473.000000, request 304998.869181 12/29/2025 02:09:15.631 7fe505cb5040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205463.127441, idle connection 144707.000000, request 304999.246597 12/29/2025 02:09:15.632 7fe50528acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205518.426025, idle connection 144698.000000, request 304398.821831 12/29/2025 02:09:15.632 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 347 12/29/2025 02:09:15.632 7fe50528acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.632 7fe50528acc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 347 (601.7076969146729 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1456496388, topics=[]) 12/29/2025 02:09:15.632 7fe50528acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1456496388 with 0 response partitions (1 implied) 12/29/2025 02:09:15.638 7fe50434b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206056.662109, idle connection 144583.000000, request 304398.602009 12/29/2025 02:09:15.638 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 335 12/29/2025 02:09:15.638 7fe50434b900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.639 7fe50434b900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 335 (601.8407344818115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2062959213, topics=[]) 12/29/2025 02:09:15.639 7fe50434b900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2062959213 with 0 response partitions (1 implied) 12/29/2025 02:09:15.692 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4149 12/29/2025 02:09:15.692 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 12/29/2025 02:09:15.692 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 12/29/2025 02:09:15.692 7fe503caac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.692 7fe503caac20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=506, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4149, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:15.693 7fe503caac20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 509 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=209132245, session_epoch=506, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4149, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 12/29/2025 02:09:15.693 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205542.115479, idle connection 144232.000000, request 304999.933720 12/29/2025 02:09:15.693 7fe503caac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205541.683350, idle connection 144232.000000, request 304999.514341 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=376128818, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=376128818, session_epoch=327, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205454.545654, idle connection 144429.000000, request 304999.963760 12/29/2025 02:09:15.694 7fe503d5e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205454.250977, idle connection 144428.000000, request 304999.671936 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 43 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29253219, session_epoch=338, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29253219, session_epoch=338, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.695 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206103.040527, idle connection 144528.000000, request 304999.967098 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 43 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1796471111, session_epoch=339, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1796471111, session_epoch=339, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.696 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206138.076416, idle connection 144469.000000, request 304999.963284 12/29/2025 02:09:15.697 7fe50528a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206101.936523, idle connection 144527.000000, request 304998.864889 12/29/2025 02:09:15.697 7fe503c7e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206137.225342, idle connection 144468.000000, request 304999.114037 12/29/2025 02:09:15.738 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 6 12/29/2025 02:09:15.738 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 12/29/2025 02:09:15.738 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 12/29/2025 02:09:15.738 7fe50432b0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.739 7fe50432b0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=926551996, session_epoch=331, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.739 7fe50432b0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=926551996, session_epoch=331, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.739 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205173.532715, idle connection 144409.000000, request 304999.952555 12/29/2025 02:09:15.739 7fe50432b0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205172.977295, idle connection 144409.000000, request 304999.402523 12/29/2025 02:09:15.853 7fe50528ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205557.714844, idle connection 144419.000000, request 304398.035765 12/29/2025 02:09:15.853 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340 12/29/2025 02:09:15.853 7fe50528ae00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.853 7fe50528ae00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 340 (602.6499271392822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=817968639, topics=[]) 12/29/2025 02:09:15.853 7fe50528ae00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 817968639 with 0 response partitions (1 implied) 12/29/2025 02:09:15.854 7fe505cb5b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206264.081787, idle connection 144663.000000, request 304397.646189 12/29/2025 02:09:15.854 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 346 12/29/2025 02:09:15.854 7fe505cb5b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.854 7fe505cb5b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 346 (602.6554107666016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529473258, topics=[]) 12/29/2025 02:09:15.854 7fe505cb5b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529473258 with 0 response partitions (1 implied) 12/29/2025 02:09:15.856 7fe50528a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204859.791260, idle connection 144140.000000, request 304398.918152 12/29/2025 02:09:15.857 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 12/29/2025 02:09:15.857 7fe50528a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.857 7fe50528a680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 331 (601.6616821289062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1509807947, topics=[]) 12/29/2025 02:09:15.857 7fe50528a680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1509807947 with 0 response partitions (1 implied) 12/29/2025 02:09:15.941 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 228 12/29/2025 02:09:15.941 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/29/2025 02:09:15.941 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/29/2025 02:09:15.941 7fe505cb5180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.942 7fe505cb5180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1688050189, session_epoch=364, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.942 7fe505cb5180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 367 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1688050189, session_epoch=364, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.942 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205434.106934, idle connection 144399.000000, request 304999.935627 12/29/2025 02:09:15.942 7fe503c7e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205895.541260, idle connection 144226.000000, request 304395.740032 12/29/2025 02:09:15.942 7fe50528a9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206031.096191, idle connection 144283.000000, request 304396.399498 12/29/2025 02:09:15.942 7fe503d5e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204864.793213, idle connection 144186.000000, request 304396.881819 12/29/2025 02:09:15.943 7fe505cb5180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205433.223389, idle connection 144398.000000, request 304999.063969 12/29/2025 02:09:15.943 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 12/29/2025 02:09:15.943 7fe503c7e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.943 7fe503c7e2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 331 (605.3516864776611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1354335972, topics=[]) 12/29/2025 02:09:15.943 7fe503c7e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1354335972 with 0 response partitions (1 implied) 12/29/2025 02:09:15.944 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339 12/29/2025 02:09:15.944 7fe50528a9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.944 7fe50528a9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 339 (605.3013801574707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=418798700, topics=[]) 12/29/2025 02:09:15.944 7fe50528a9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 418798700 with 0 response partitions (1 implied) 12/29/2025 02:09:15.944 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 12/29/2025 02:09:15.945 7fe503d5e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.945 7fe503d5e720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 331 (605.3524017333984 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=759178101, topics=[]) 12/29/2025 02:09:15.945 7fe503d5e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 759178101 with 0 response partitions (1 implied) 12/29/2025 02:09:15.947 7fe503fabea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204795.105713, idle connection 143996.000000, request 304398.893356 12/29/2025 02:09:15.948 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 343 12/29/2025 02:09:15.948 7fe503fabea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.948 7fe503fabea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 343 (601.4835834503174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=720032835, topics=[]) 12/29/2025 02:09:15.948 7fe503fabea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 720032835 with 0 response partitions (1 implied) 12/29/2025 02:09:15.948 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 213 12/29/2025 02:09:15.948 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 12/29/2025 02:09:15.948 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 12/29/2025 02:09:15.948 7fe505cb5900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.948 7fe505cb5900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=664609216, session_epoch=356, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.948 7fe505cb5900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 359 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=664609216, session_epoch=356, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.949 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205447.743408, idle connection 144507.000000, request 304999.951363 12/29/2025 02:09:15.949 7fe505cb5900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205447.393799, idle connection 144507.000000, request 304999.602556 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 184 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=361, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Request 364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=961776489, session_epoch=361, topics=[], forgotten_topics_data=[]) 12/29/2025 02:09:15.955 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205521.452148, idle connection 144509.000000, request 304999.957561 12/29/2025 02:09:15.956 7fe505cb5540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205521.118652, idle connection 144509.000000, request 304999.627829 12/29/2025 02:09:15.956 7fe505cb52c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206227.055176, idle connection 144395.000000, request 304399.001837 12/29/2025 02:09:15.956 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 364 12/29/2025 02:09:15.956 7fe505cb52c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/29/2025 02:09:15.956 7fe505cb52c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.57', 9092)]>: Response 364 (601.356029510498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=234546897, topics=[]) 12/29/2025 02:09:15.957 7fe505cb52c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 234546897 with 0 response partitions (1 implied)