04/20/2026 04:38:21.204 7fc43ce94cc0 [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=1061022208, session_epoch=7583, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.204 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7603 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7583, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.205 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41001.359619, idle connection 280999.000000, request 304999.946117 04/20/2026 04:38:21.205 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41000.975830, idle connection 280999.000000, request 304999.571085 04/20/2026 04:38:21.230 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:21.231 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:21.231 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:21.231 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:21.231 7fc43eb74400 [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=579651175, session_epoch=8021, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.231 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8035 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8021, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.231 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41957.062012, idle connection 281955.000000, request 304999.952793 04/20/2026 04:38:21.232 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41956.698730, idle connection 281955.000000, request 304999.595165 04/20/2026 04:38:21.244 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40503.229492, idle connection 519821.000000, request 304397.847414 04/20/2026 04:38:21.244 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8010 04/20/2026 04:38:21.244 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.244 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8010 (602.5316715240479 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=3921, last_stable_offset=3921, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0fN\x00\x00\x047\x00\x00\x00\x00\x02\xf7\xf5\xd6r\x00\x00\x00\x00\x00\x02\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x03\xae\x05\x00\x00\x00\xf0\x04ObjectBgpPeer:default-domain:def...')])]) 04/20/2026 04:38:21.244 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 1 response partitions (0 implied) 04/20/2026 04:38:21.244 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1091 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 3918 04/20/2026 04:38:21.245 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3918 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 04/20/2026 04:38:21.245 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 3921 (leader epoch 0) 04/20/2026 04:38:21.248 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42963.715088, idle connection 282961.000000, request 304399.089336 04/20/2026 04:38:21.248 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8011 04/20/2026 04:38:21.248 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.249 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8011 (601.2630462646484 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:21.249 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:21.346 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:21.346 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:21.346 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-23', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:21.346 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:21.346 7fc43eb74540 [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=1563294869, session_epoch=7999, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3921, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:21.346 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8011 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=7999, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3921, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:21.346 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40400.506592, idle connection 519718.000000, request 304999.923706 04/20/2026 04:38:21.347 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40400.033691, idle connection 519717.000000, request 304999.461651 04/20/2026 04:38:21.385 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39890.182861, idle connection 279888.000000, request 304398.393154 04/20/2026 04:38:21.386 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7520 04/20/2026 04:38:21.386 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.386 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7520 (602.1592617034912 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:21.386 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:21.416 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4465 04/20/2026 04:38:21.416 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:21.416 7fc43eb74b80 [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)]) 04/20/2026 04:38:21.416 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:21.416 7fc43eb74b80 [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=1217890698, session_epoch=8327, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.416 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8327, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.416 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38761.679199, idle connection 456001.000000, request 304999.950409 04/20/2026 04:38:21.417 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38761.231689, idle connection 456000.000000, request 304999.509335 04/20/2026 04:38:21.681 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41186.508545, idle connection 281184.000000, request 304399.074554 04/20/2026 04:38:21.681 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7550 04/20/2026 04:38:21.681 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.681 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7550 (601.4182567596436 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:21.682 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:21.806 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40400.404297, idle connection 280398.000000, request 304398.991585 04/20/2026 04:38:21.806 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7603 04/20/2026 04:38:21.806 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.806 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7603 (601.6497611999512 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:21.806 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:21.832 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41356.179443, idle connection 281354.000000, request 304399.067879 04/20/2026 04:38:21.832 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8035 04/20/2026 04:38:21.833 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.833 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8035 (601.4416217803955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:21.833 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:21.849 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:21.849 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:21.849 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:21.849 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:21.850 7fc43eb747c0 [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=846222568, session_epoch=8003, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.850 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8012 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8003, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.850 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42361.578125, idle connection 282359.000000, request 304999.947786 04/20/2026 04:38:21.851 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42361.203613, idle connection 282359.000000, request 304999.579668 04/20/2026 04:38:21.948 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39798.545410, idle connection 519116.000000, request 304397.958994 04/20/2026 04:38:21.949 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8011 04/20/2026 04:38:21.949 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:21.949 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8011 (602.5667190551758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:21.949 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:21.987 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:21.987 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:21.987 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:21.987 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:21.987 7fc43ce94ea0 [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=685664860, session_epoch=7503, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.987 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7521 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7503, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:21.987 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39288.299561, idle connection 279286.000000, request 304999.951839 04/20/2026 04:38:21.988 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39287.916260, idle connection 279286.000000, request 304999.575138 04/20/2026 04:38:22.018 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38160.101807, idle connection 455399.000000, request 304398.373127 04/20/2026 04:38:22.018 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8349 04/20/2026 04:38:22.018 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:22.018 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8349 (602.1027565002441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:22.019 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied) 04/20/2026 04:38:22.283 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:22.283 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:22.283 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:22.283 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:22.283 7fc43eb74180 [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=1132301505, session_epoch=7536, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.283 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7551 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7536, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.283 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40584.079346, idle connection 280582.000000, request 304999.950886 04/20/2026 04:38:22.284 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40583.652588, idle connection 280582.000000, request 304999.530315 04/20/2026 04:38:22.407 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 610 04/20/2026 04:38:22.407 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:22.407 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:22.407 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:22.407 7fc43ce94cc0 [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=1061022208, session_epoch=7584, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.407 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7604 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7584, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.408 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39798.361572, idle connection 279796.000000, request 304999.912977 04/20/2026 04:38:22.408 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39797.959961, idle connection 279796.000000, request 304999.520063 04/20/2026 04:38:22.433 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:22.433 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:22.433 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:22.433 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:22.434 7fc43eb74400 [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=579651175, session_epoch=8022, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.434 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8036 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8022, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.434 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40754.500977, idle connection 280752.000000, request 304999.953508 04/20/2026 04:38:22.434 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40754.147949, idle connection 280752.000000, request 304999.605417 04/20/2026 04:38:22.451 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41760.755615, idle connection 281759.000000, request 304399.125338 04/20/2026 04:38:22.452 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8012 04/20/2026 04:38:22.452 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:22.452 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8012 (601.3970375061035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:22.452 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:22.550 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:22.550 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:22.550 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:22.550 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:22.550 7fc43eb74540 [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=1563294869, session_epoch=8000, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.551 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8012 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8000, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.551 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39196.291992, idle connection 518514.000000, request 304999.950409 04/20/2026 04:38:22.551 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39195.931641, idle connection 518513.000000, request 304999.597311 04/20/2026 04:38:22.588 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38687.328857, idle connection 278685.000000, request 304398.979187 04/20/2026 04:38:22.589 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7521 04/20/2026 04:38:22.589 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:22.589 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7521 (601.7570495605469 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:22.589 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:22.620 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4465 04/20/2026 04:38:22.620 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:22.620 7fc43eb74b80 [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)]) 04/20/2026 04:38:22.620 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:22.620 7fc43eb74b80 [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=1217890698, session_epoch=8328, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.620 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8328, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:22.621 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37557.403320, idle connection 454796.000000, request 304999.947548 04/20/2026 04:38:22.621 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37557.021240, idle connection 454796.000000, request 304999.574661 04/20/2026 04:38:22.884 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39983.097168, idle connection 279981.000000, request 304398.968220 04/20/2026 04:38:22.885 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7551 04/20/2026 04:38:22.885 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:22.885 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7551 (601.6168594360352 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:22.885 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:23.008 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39197.482666, idle connection 279195.000000, request 304399.032116 04/20/2026 04:38:23.009 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7604 04/20/2026 04:38:23.009 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:23.009 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7604 (601.4916896820068 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:23.009 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:23.035 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40153.601562, idle connection 280152.000000, request 304399.050713 04/20/2026 04:38:23.035 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8036 04/20/2026 04:38:23.035 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:23.035 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8036 (601.4227867126465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:23.035 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:23.052 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:23.052 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:23.052 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:23.053 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:23.053 7fc43eb747c0 [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=846222568, session_epoch=8004, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.053 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8013 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8004, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.053 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41159.002930, idle connection 281157.000000, request 304999.943018 04/20/2026 04:38:23.053 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41158.555420, idle connection 281156.000000, request 304999.503136 04/20/2026 04:38:23.152 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38595.106445, idle connection 517912.000000, request 304398.765326 04/20/2026 04:38:23.152 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8012 04/20/2026 04:38:23.152 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:23.152 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8012 (601.7394065856934 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:23.153 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:23.190 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:23.190 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:23.190 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:23.190 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:23.191 7fc43ce94ea0 [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=685664860, session_epoch=7504, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.191 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7522 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7504, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.191 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38084.759033, idle connection 278083.000000, request 304999.953508 04/20/2026 04:38:23.191 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38084.390137, idle connection 278082.000000, request 304999.590874 04/20/2026 04:38:23.223 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36955.475098, idle connection 454195.000000, request 304398.019552 04/20/2026 04:38:23.223 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8350 04/20/2026 04:38:23.223 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:23.223 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8350 (602.4825572967529 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:23.223 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied) 04/20/2026 04:38:23.486 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:23.487 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:23.488 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:23.488 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:23.488 7fc43eb74180 [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=1132301505, session_epoch=7537, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.488 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7552 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7537, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.488 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39379.421875, idle connection 279377.000000, request 304999.946833 04/20/2026 04:38:23.488 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39379.038574, idle connection 279377.000000, request 304999.572039 04/20/2026 04:38:23.609 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 610 04/20/2026 04:38:23.610 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:23.610 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:23.610 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:23.610 7fc43ce94cc0 [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=1061022208, session_epoch=7585, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.610 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7605 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7585, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.610 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38595.709473, idle connection 278594.000000, request 304999.948263 04/20/2026 04:38:23.611 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38595.310791, idle connection 278593.000000, request 304999.557972 04/20/2026 04:38:23.636 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:23.636 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:23.636 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:23.636 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:23.636 7fc43eb74400 [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=579651175, session_epoch=8023, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.636 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8037 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8023, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.636 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39552.047119, idle connection 279550.000000, request 304999.953508 04/20/2026 04:38:23.637 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39551.691162, idle connection 279550.000000, request 304999.587774 04/20/2026 04:38:23.654 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 40558.067139, idle connection 280556.000000, request 304399.008989 04/20/2026 04:38:23.654 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8013 04/20/2026 04:38:23.654 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:23.654 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8013 (601.4547348022461 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:23.654 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:23.754 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:23.754 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:23.754 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:23.754 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:23.754 7fc43eb74540 [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=1563294869, session_epoch=8001, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.754 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8013 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8001, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.754 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37992.525635, idle connection 517310.000000, request 304999.940157 04/20/2026 04:38:23.755 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37992.090088, idle connection 517309.000000, request 304999.511242 04/20/2026 04:38:23.792 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37483.610107, idle connection 277482.000000, request 304398.803711 04/20/2026 04:38:23.792 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7522 04/20/2026 04:38:23.792 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:23.792 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7522 (601.6581058502197 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:23.793 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:23.825 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4465 04/20/2026 04:38:23.825 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:23.825 7fc43eb74b80 [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)]) 04/20/2026 04:38:23.825 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:23.825 7fc43eb74b80 [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=1217890698, session_epoch=8329, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.825 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8329, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:23.826 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36352.388672, idle connection 453591.000000, request 304999.951124 04/20/2026 04:38:23.826 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36352.002197, idle connection 453591.000000, request 304999.570608 04/20/2026 04:38:24.089 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38778.559326, idle connection 278777.000000, request 304399.085283 04/20/2026 04:38:24.089 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7552 04/20/2026 04:38:24.089 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.089 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7552 (601.4342308044434 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:24.090 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:24.211 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37994.838135, idle connection 277993.000000, request 304399.077892 04/20/2026 04:38:24.211 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7605 04/20/2026 04:38:24.212 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.212 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7605 (601.4604568481445 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:24.212 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:24.237 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38951.234375, idle connection 278949.000000, request 304399.138451 04/20/2026 04:38:24.237 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8037 04/20/2026 04:38:24.238 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.238 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8037 (601.3658046722412 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:24.238 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:24.255 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:24.255 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:24.255 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:24.256 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:24.256 7fc43eb747c0 [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=846222568, session_epoch=8005, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.256 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8014 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8005, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.256 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39955.916016, idle connection 279954.000000, request 304999.949694 04/20/2026 04:38:24.256 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39955.455078, idle connection 279953.000000, request 304999.496698 04/20/2026 04:38:24.356 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37391.412598, idle connection 516709.000000, request 304398.826361 04/20/2026 04:38:24.356 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8013 04/20/2026 04:38:24.356 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.356 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8013 (601.7513275146484 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:24.356 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:24.394 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:24.394 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:24.394 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:24.394 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:24.394 7fc43ce94ea0 [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=685664860, session_epoch=7505, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.394 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7523 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7505, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.394 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36881.210938, idle connection 276879.000000, request 304999.951601 04/20/2026 04:38:24.395 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36880.827637, idle connection 276879.000000, request 304999.574423 04/20/2026 04:38:24.427 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35750.677002, idle connection 452990.000000, request 304398.239374 04/20/2026 04:38:24.428 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8351 04/20/2026 04:38:24.428 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.428 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8351 (602.2696495056152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:24.428 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied) 04/20/2026 04:38:24.690 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:24.690 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:24.690 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:24.691 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:24.691 7fc43eb74180 [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=1132301505, session_epoch=7538, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.691 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7553 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7538, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.691 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38176.544922, idle connection 278175.000000, request 304999.946356 04/20/2026 04:38:24.691 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38176.155273, idle connection 278174.000000, request 304999.566317 04/20/2026 04:38:24.812 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 610 04/20/2026 04:38:24.812 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:24.812 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:24.812 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:24.813 7fc43ce94cc0 [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=1061022208, session_epoch=7586, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.813 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7606 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7586, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.813 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37393.061035, idle connection 277391.000000, request 304999.949455 04/20/2026 04:38:24.813 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37392.687744, idle connection 277391.000000, request 304999.584913 04/20/2026 04:38:24.838 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:24.838 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:24.838 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:24.838 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:24.839 7fc43eb74400 [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=579651175, session_epoch=8024, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.839 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8038 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8024, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.839 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38349.532715, idle connection 278348.000000, request 304999.954939 04/20/2026 04:38:24.839 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38349.174805, idle connection 278347.000000, request 304999.603033 04/20/2026 04:38:24.857 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39355.065918, idle connection 279353.000000, request 304399.103880 04/20/2026 04:38:24.857 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8014 04/20/2026 04:38:24.857 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.857 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8014 (601.306676864624 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:24.857 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:24.957 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:24.958 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:24.958 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:24.958 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:24.958 7fc43eb74540 [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=1563294869, session_epoch=8002, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.958 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8014 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8002, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:24.958 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36788.710938, idle connection 516106.000000, request 304999.950409 04/20/2026 04:38:24.959 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36788.243164, idle connection 516106.000000, request 304999.490261 04/20/2026 04:38:24.996 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36279.690186, idle connection 276278.000000, request 304398.431063 04/20/2026 04:38:24.996 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7523 04/20/2026 04:38:24.996 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:24.996 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7523 (601.9852161407471 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:24.996 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:25.030 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4465 04/20/2026 04:38:25.030 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:25.030 7fc43eb74b80 [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)]) 04/20/2026 04:38:25.030 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:25.030 7fc43eb74b80 [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=1217890698, session_epoch=8330, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.030 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8352 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8330, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.030 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35147.523682, idle connection 452387.000000, request 304999.936342 04/20/2026 04:38:25.031 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35147.145752, idle connection 452386.000000, request 304999.565840 04/20/2026 04:38:25.292 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37575.652832, idle connection 277574.000000, request 304399.054289 04/20/2026 04:38:25.292 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7553 04/20/2026 04:38:25.292 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:25.292 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7553 (601.4738082885742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:25.292 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:25.414 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36792.151367, idle connection 276790.000000, request 304399.039745 04/20/2026 04:38:25.414 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7606 04/20/2026 04:38:25.414 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:25.415 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7606 (601.6902923583984 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:25.415 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:25.440 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37748.672607, idle connection 277747.000000, request 304399.090767 04/20/2026 04:38:25.440 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8038 04/20/2026 04:38:25.440 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:25.440 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8038 (601.3977527618408 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:25.440 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:25.459 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:25.459 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:25.459 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:25.459 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:25.459 7fc43eb747c0 [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=846222568, session_epoch=8006, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.459 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8015 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8006, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.459 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38752.710693, idle connection 278750.000000, request 304999.953985 04/20/2026 04:38:25.460 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38752.317871, idle connection 278750.000000, request 304999.566555 04/20/2026 04:38:25.559 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36187.589600, idle connection 515505.000000, request 304398.828983 04/20/2026 04:38:25.560 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8014 04/20/2026 04:38:25.560 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:25.560 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8014 (601.8450260162354 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:25.560 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:25.598 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:25.598 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:25.598 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:25.598 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:25.598 7fc43ce94ea0 [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=685664860, session_epoch=7506, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.598 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7524 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7506, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.598 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35677.189697, idle connection 275675.000000, request 304999.950409 04/20/2026 04:38:25.599 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35676.783691, idle connection 275675.000000, request 304999.552011 04/20/2026 04:38:25.632 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34546.196289, idle connection 451785.000000, request 304398.610115 04/20/2026 04:38:25.632 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8352 04/20/2026 04:38:25.632 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:25.632 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8352 (601.8171310424805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=4466, last_stable_offset=4466, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11q\x00\x00\x01O\x00\x00\x00\x00\x02P\xa88P\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\xb8\x04\x00\x00\x00\xfa\x03ObjectVNTable:default-domain:cte...')])]) 04/20/2026 04:38:25.632 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 1 response partitions (0 implied) 04/20/2026 04:38:25.633 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 347 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 4465 04/20/2026 04:38:25.633 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4465 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 04/20/2026 04:38:25.633 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 4466 (leader epoch 0) 04/20/2026 04:38:25.734 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4466 04/20/2026 04:38:25.734 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:25.734 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 04/20/2026 04:38:25.734 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:25.734 7fc43eb74b80 [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=1217890698, session_epoch=8331, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4466, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:25.735 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8353 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8331, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4466, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:25.735 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34443.309570, idle connection 451682.000000, request 304999.952793 04/20/2026 04:38:25.735 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34442.920654, idle connection 451682.000000, request 304999.569893 04/20/2026 04:38:25.893 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:25.893 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:25.893 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:25.893 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:25.893 7fc43eb74180 [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=1132301505, session_epoch=7539, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.893 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7554 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7539, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:25.894 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36973.857422, idle connection 276972.000000, request 304999.951363 04/20/2026 04:38:25.894 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36973.479980, idle connection 276971.000000, request 304999.582052 04/20/2026 04:38:26.016 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 610 04/20/2026 04:38:26.016 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:26.016 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:26.016 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:26.016 7fc43ce94cc0 [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=1061022208, session_epoch=7587, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.017 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7607 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7587, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.017 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36189.193848, idle connection 276187.000000, request 304999.948740 04/20/2026 04:38:26.017 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36188.810791, idle connection 276187.000000, request 304999.573231 04/20/2026 04:38:26.041 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:26.041 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:26.041 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:26.041 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:26.041 7fc43eb74400 [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=579651175, session_epoch=8025, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.041 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8039 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8025, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.041 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37147.065186, idle connection 277145.000000, request 304999.956131 04/20/2026 04:38:26.042 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37146.710205, idle connection 277145.000000, request 304999.605656 04/20/2026 04:38:26.061 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38151.269531, idle connection 278149.000000, request 304398.513794 04/20/2026 04:38:26.061 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8015 04/20/2026 04:38:26.061 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.061 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8015 (601.9425392150879 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:26.061 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:26.161 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:26.161 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:26.162 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:26.162 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:26.162 7fc43eb74540 [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=1563294869, session_epoch=8003, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.162 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8015 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8003, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.162 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35584.982666, idle connection 514902.000000, request 304999.950409 04/20/2026 04:38:26.162 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35584.543457, idle connection 514902.000000, request 304999.498844 04/20/2026 04:38:26.200 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35075.994873, idle connection 275074.000000, request 304398.756981 04/20/2026 04:38:26.200 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7524 04/20/2026 04:38:26.200 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.200 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7524 (601.7100811004639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:26.200 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:26.336 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33842.381104, idle connection 451081.000000, request 304399.016619 04/20/2026 04:38:26.336 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8353 04/20/2026 04:38:26.336 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.336 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8353 (601.6647815704346 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=4469, last_stable_offset=4469, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11r\x00\x00\x01O\x00\x00\x00\x00\x02\xb0\xd0\xa9\xc8\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\xb8\x04\x00\x00\x00\xfa\x03ObjectVNTable:default-domain:cte...')])]) 04/20/2026 04:38:26.337 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 1 response partitions (0 implied) 04/20/2026 04:38:26.337 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 890 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 4466 04/20/2026 04:38:26.337 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4466 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 04/20/2026 04:38:26.337 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 4469 (leader epoch 0) 04/20/2026 04:38:26.438 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4469 04/20/2026 04:38:26.438 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:26.438 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 04/20/2026 04:38:26.438 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:26.439 7fc43eb74b80 [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=1217890698, session_epoch=8332, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4469, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:26.439 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8354 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8332, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4469, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:26.439 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33739.141846, idle connection 450978.000000, request 304999.952078 04/20/2026 04:38:26.439 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33738.763428, idle connection 450978.000000, request 304999.579191 04/20/2026 04:38:26.495 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36372.798340, idle connection 276371.000000, request 304398.892403 04/20/2026 04:38:26.495 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7554 04/20/2026 04:38:26.495 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.495 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7554 (601.6638278961182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:26.496 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:26.618 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35588.345947, idle connection 275586.000000, request 304399.101496 04/20/2026 04:38:26.618 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7607 04/20/2026 04:38:26.618 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.618 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7607 (601.5610694885254 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[(topics='-uve-topic-11', partitions=[(partition=0, error_code=0, highwater_offset=611, last_stable_offset=611, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x02b\x00\x00\x00\xf8\x00\x00\x00\x00\x02\xb2\x94\xf3\xf1\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x8a\x03\x00\x00\x00\xcc\x02ObjectVMTable:ffd90e11-aa76-49ed...')])]) 04/20/2026 04:38:26.618 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 1 response partitions (0 implied) 04/20/2026 04:38:26.619 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 260 bytes of data for partition TopicPartition(topic='-uve-topic-11', partition=0) with offset 610 04/20/2026 04:38:26.619 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 610 for assigned partition TopicPartition(topic='-uve-topic-11', partition=0) 04/20/2026 04:38:26.619 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-11', partition=0) to 611 (leader epoch 0) 04/20/2026 04:38:26.642 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36546.340088, idle connection 276544.000000, request 304399.230957 04/20/2026 04:38:26.642 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8039 04/20/2026 04:38:26.642 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.643 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8039 (601.3617515563965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:26.643 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:26.663 7fc43eb747c0 [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=846222568, session_epoch=8007, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8016 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8007, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37548.791748, idle connection 277547.000000, request 304999.954700 04/20/2026 04:38:26.663 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37548.447266, idle connection 277546.000000, request 304999.614716 04/20/2026 04:38:26.719 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 611 04/20/2026 04:38:26.720 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:26.720 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-11', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:26.720 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:26.720 7fc43ce94cc0 [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=1061022208, session_epoch=7588, topics=[(topic='-uve-topic-11', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=611, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:26.720 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7608 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7588, topics=[(topic='-uve-topic-11', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=611, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:26.721 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35485.366943, idle connection 275483.000000, request 304999.947786 04/20/2026 04:38:26.721 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35485.012695, idle connection 275483.000000, request 304999.601364 04/20/2026 04:38:26.763 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34984.030518, idle connection 514301.000000, request 304398.998737 04/20/2026 04:38:26.763 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8015 04/20/2026 04:38:26.763 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:26.763 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8015 (601.4611721038818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:26.764 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:26.801 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:26.801 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:26.801 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:26.801 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:26.801 7fc43ce94ea0 [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=685664860, session_epoch=7507, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.802 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7525 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7507, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:26.802 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34473.860352, idle connection 274472.000000, request 304999.949932 04/20/2026 04:38:26.802 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34473.458740, idle connection 274471.000000, request 304999.555111 04/20/2026 04:38:27.040 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33138.263428, idle connection 450377.000000, request 304399.070501 04/20/2026 04:38:27.040 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8354 04/20/2026 04:38:27.040 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.040 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8354 (601.433277130127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:27.040 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied) 04/20/2026 04:38:27.098 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:27.098 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:27.098 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:27.098 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:27.098 7fc43eb74180 [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=1132301505, session_epoch=7540, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.098 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7555 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7540, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.099 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35768.930176, idle connection 275767.000000, request 304999.945641 04/20/2026 04:38:27.099 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35768.542969, idle connection 275767.000000, request 304999.567032 04/20/2026 04:38:27.243 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:27.243 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:27.243 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:27.243 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:27.244 7fc43eb74400 [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=579651175, session_epoch=8026, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.244 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8040 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8026, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.244 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35944.430664, idle connection 275942.000000, request 304999.948502 04/20/2026 04:38:27.244 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35944.049072, idle connection 275942.000000, request 304999.573946 04/20/2026 04:38:27.264 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36947.978271, idle connection 276946.000000, request 304399.140120 04/20/2026 04:38:27.264 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8016 04/20/2026 04:38:27.264 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.264 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8016 (601.3002395629883 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:27.265 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:27.322 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34884.199707, idle connection 274882.000000, request 304398.779869 04/20/2026 04:38:27.322 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7608 04/20/2026 04:38:27.322 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.322 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7608 (601.7155647277832 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:27.322 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:27.365 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:27.365 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:27.365 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:27.365 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:27.366 7fc43eb74540 [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=1563294869, session_epoch=8004, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.366 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8016 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8004, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.366 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34380.939697, idle connection 513698.000000, request 304999.927998 04/20/2026 04:38:27.367 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34380.371338, idle connection 513698.000000, request 304999.367714 04/20/2026 04:38:27.403 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33872.341553, idle connection 273870.000000, request 304398.430109 04/20/2026 04:38:27.404 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7525 04/20/2026 04:38:27.404 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.404 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7525 (602.0944118499756 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:27.404 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:27.641 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4469 04/20/2026 04:38:27.642 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:27.642 7fc43eb74b80 [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)]) 04/20/2026 04:38:27.642 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:27.642 7fc43eb74b80 [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=1217890698, session_epoch=8333, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.642 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8333, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.642 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32535.951904, idle connection 449775.000000, request 304999.950171 04/20/2026 04:38:27.642 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32535.595947, idle connection 449775.000000, request 304999.601603 04/20/2026 04:38:27.699 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35168.072754, idle connection 275166.000000, request 304399.089336 04/20/2026 04:38:27.700 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7555 04/20/2026 04:38:27.700 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.700 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7555 (601.4184951782227 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:27.700 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:27.845 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35343.580566, idle connection 275342.000000, request 304399.099112 04/20/2026 04:38:27.845 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8040 04/20/2026 04:38:27.845 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.845 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8040 (601.4082431793213 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:27.845 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:27.866 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:27.866 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:27.866 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:27.866 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:27.866 7fc43eb747c0 [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=846222568, session_epoch=8008, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.866 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8017 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8008, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.866 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36345.550781, idle connection 276343.000000, request 304999.953032 04/20/2026 04:38:27.867 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36345.168213, idle connection 276343.000000, request 304999.576807 04/20/2026 04:38:27.923 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 611 04/20/2026 04:38:27.924 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:27.924 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:27.924 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:27.924 7fc43ce94cc0 [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=1061022208, session_epoch=7589, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.924 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7609 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7589, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:27.924 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34281.597412, idle connection 274279.000000, request 304999.949455 04/20/2026 04:38:27.925 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34281.219482, idle connection 274279.000000, request 304999.578953 04/20/2026 04:38:27.968 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33779.299561, idle connection 513097.000000, request 304398.295164 04/20/2026 04:38:27.968 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8016 04/20/2026 04:38:27.968 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:27.968 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8016 (602.1716594696045 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:27.968 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:28.006 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:28.006 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:28.006 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:28.006 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:28.006 7fc43ce94ea0 [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=685664860, session_epoch=7508, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.007 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7526 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7508, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.007 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33268.889893, idle connection 273267.000000, request 304999.944448 04/20/2026 04:38:28.007 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33268.474365, idle connection 273266.000000, request 304999.538660 04/20/2026 04:38:28.244 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31934.121582, idle connection 449173.000000, request 304398.118734 04/20/2026 04:38:28.244 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8355 04/20/2026 04:38:28.244 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:28.244 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8355 (602.398157119751 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:28.245 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied) 04/20/2026 04:38:28.301 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:28.301 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:28.301 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:28.301 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:28.301 7fc43eb74180 [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=1132301505, session_epoch=7541, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.302 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7556 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7541, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.302 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34565.713135, idle connection 274564.000000, request 304999.948502 04/20/2026 04:38:28.302 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34565.323242, idle connection 274563.000000, request 304999.566555 04/20/2026 04:38:28.446 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:28.446 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:28.446 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:28.446 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:28.447 7fc43eb74400 [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=579651175, session_epoch=8027, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.447 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8041 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8027, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.447 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34741.132080, idle connection 274739.000000, request 304999.920845 04/20/2026 04:38:28.448 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34740.595947, idle connection 274739.000000, request 304999.397755 04/20/2026 04:38:28.467 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35744.692871, idle connection 275742.000000, request 304399.090528 04/20/2026 04:38:28.468 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8017 04/20/2026 04:38:28.468 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:28.468 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8017 (601.6054153442383 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:28.468 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:28.526 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33680.164551, idle connection 273678.000000, request 304398.514032 04/20/2026 04:38:28.526 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7609 04/20/2026 04:38:28.526 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:28.526 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7609 (602.0431518554688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:28.526 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:28.569 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3921 04/20/2026 04:38:28.569 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:28.569 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:28.569 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:28.569 7fc43eb74540 [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=1563294869, session_epoch=8005, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.569 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8017 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8005, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.570 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33177.405518, idle connection 512495.000000, request 304999.949455 04/20/2026 04:38:28.570 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33176.982422, idle connection 512494.000000, request 304999.533653 04/20/2026 04:38:28.608 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32667.387207, idle connection 272665.000000, request 304398.445606 04/20/2026 04:38:28.609 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7526 04/20/2026 04:38:28.609 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:28.609 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7526 (602.2424697875977 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:28.609 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:28.846 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4469 04/20/2026 04:38:28.846 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:28.846 7fc43eb74b80 [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)]) 04/20/2026 04:38:28.846 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:28.846 7fc43eb74b80 [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=1217890698, session_epoch=8334, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.846 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8334, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:28.846 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31331.532959, idle connection 448571.000000, request 304999.939203 04/20/2026 04:38:28.847 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31331.115479, idle connection 448570.000000, request 304999.526262 04/20/2026 04:38:28.903 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33964.765625, idle connection 273963.000000, request 304398.998260 04/20/2026 04:38:28.903 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7556 04/20/2026 04:38:28.903 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:28.903 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7556 (601.5775203704834 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:28.903 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:29.048 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34140.082764, idle connection 274138.000000, request 304398.880720 04/20/2026 04:38:29.049 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8041 04/20/2026 04:38:29.049 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.049 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8041 (601.6290187835693 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:29.049 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:29.069 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3945 04/20/2026 04:38:29.069 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:29.069 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:29.069 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:29.069 7fc43eb747c0 [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=846222568, session_epoch=8009, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.069 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8018 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8009, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.069 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35142.771729, idle connection 275141.000000, request 304999.952793 04/20/2026 04:38:29.070 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35142.391113, idle connection 275140.000000, request 304999.577761 04/20/2026 04:38:29.127 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 611 04/20/2026 04:38:29.127 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:29.127 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:29.127 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:29.127 7fc43ce94cc0 [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=1061022208, session_epoch=7590, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.127 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7610 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7590, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.128 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33078.350342, idle connection 273076.000000, request 304999.934196 04/20/2026 04:38:29.128 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33077.963623, idle connection 273076.000000, request 304999.556065 04/20/2026 04:38:29.171 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32576.424316, idle connection 511894.000000, request 304398.969412 04/20/2026 04:38:29.171 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8017 04/20/2026 04:38:29.171 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.171 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8017 (601.5944480895996 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=3923, last_stable_offset=3923, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0fQ\x00\x00\x02\x0f\x00\x00\x00\x00\x02i\x97\x80\xa2\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/20/2026 04:38:29.171 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 1 response partitions (0 implied) 04/20/2026 04:38:29.171 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 539 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 3921 04/20/2026 04:38:29.172 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3921 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 04/20/2026 04:38:29.172 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 3923 (leader epoch 0) 04/20/2026 04:38:29.209 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:29.210 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:29.210 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:29.210 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:29.210 7fc43ce94ea0 [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=685664860, session_epoch=7509, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.210 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7527 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7509, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.210 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32065.438965, idle connection 272063.000000, request 304999.946833 04/20/2026 04:38:29.210 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32065.058105, idle connection 272063.000000, request 304999.573946 04/20/2026 04:38:29.272 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3923 04/20/2026 04:38:29.273 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:29.273 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-23', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:29.273 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:29.273 7fc43eb74540 [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=1563294869, session_epoch=8006, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3923, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:29.273 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8018 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8006, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3923, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:29.273 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32473.859863, idle connection 511791.000000, request 304999.950886 04/20/2026 04:38:29.273 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32473.485840, idle connection 511791.000000, request 304999.583483 04/20/2026 04:38:29.447 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 30730.534180, idle connection 447970.000000, request 304398.940325 04/20/2026 04:38:29.448 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8356 04/20/2026 04:38:29.448 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.448 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8356 (601.7186641693115 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:29.448 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied) 04/20/2026 04:38:29.504 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 661 04/20/2026 04:38:29.504 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 04/20/2026 04:38:29.504 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 04/20/2026 04:38:29.504 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:29.504 7fc43eb74180 [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=1132301505, session_epoch=7542, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.504 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7557 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1132301505, session_epoch=7542, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.505 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33362.792236, idle connection 273361.000000, request 304999.938250 04/20/2026 04:38:29.505 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33362.388916, idle connection 273360.000000, request 304999.543428 04/20/2026 04:38:29.649 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4398 04/20/2026 04:38:29.649 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 04/20/2026 04:38:29.649 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 04/20/2026 04:38:29.649 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:29.650 7fc43eb74400 [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=579651175, session_epoch=8028, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.650 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8042 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=579651175, session_epoch=8028, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:29.650 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33538.472168, idle connection 273536.000000, request 304999.951363 04/20/2026 04:38:29.650 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33538.117920, idle connection 273536.000000, request 304999.604225 04/20/2026 04:38:29.670 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34541.958252, idle connection 274540.000000, request 304399.140596 04/20/2026 04:38:29.670 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8018 04/20/2026 04:38:29.670 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.670 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8018 (601.3169288635254 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=3947, last_stable_offset=3947, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0fi\x00\x00\x02\x0f\x00\x00\x00\x00\x02\xc3\x9c\xfc\x1e\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 04/20/2026 04:38:29.671 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 1 response partitions (0 implied) 04/20/2026 04:38:29.671 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 539 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 3945 04/20/2026 04:38:29.671 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3945 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) 04/20/2026 04:38:29.671 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 3947 (leader epoch 0) 04/20/2026 04:38:29.728 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32477.495361, idle connection 272475.000000, request 304399.080992 04/20/2026 04:38:29.729 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7610 04/20/2026 04:38:29.729 7fc43ce94cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.729 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7610 (601.405143737793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1061022208, topics=[]) 04/20/2026 04:38:29.729 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1061022208 with 0 response partitions (1 implied) 04/20/2026 04:38:29.772 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3947 04/20/2026 04:38:29.772 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 04/20/2026 04:38:29.772 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 04/20/2026 04:38:29.772 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 04/20/2026 04:38:29.772 7fc43eb747c0 [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=846222568, session_epoch=8010, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3947, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:29.772 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8019 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=846222568, session_epoch=8010, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3947, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 04/20/2026 04:38:29.772 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34439.622559, idle connection 274437.000000, request 304999.950171 04/20/2026 04:38:29.773 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34439.232422, idle connection 274437.000000, request 304999.567270 04/20/2026 04:38:29.811 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31464.573975, idle connection 271462.000000, request 304399.077892 04/20/2026 04:38:29.811 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7527 04/20/2026 04:38:29.812 7fc43ce94ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.812 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7527 (601.6392707824707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=685664860, topics=[]) 04/20/2026 04:38:29.812 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 685664860 with 0 response partitions (1 implied) 04/20/2026 04:38:29.874 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31873.009521, idle connection 511190.000000, request 304399.101257 04/20/2026 04:38:29.874 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8018 04/20/2026 04:38:29.874 7fc43eb74540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:29.874 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8018 (601.3877391815186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563294869, topics=[]) 04/20/2026 04:38:29.875 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1563294869 with 0 response partitions (1 implied) 04/20/2026 04:38:30.049 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 4469 04/20/2026 04:38:30.049 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 04/20/2026 04:38:30.049 7fc43eb74b80 [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)]) 04/20/2026 04:38:30.049 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 04/20/2026 04:38:30.049 7fc43eb74b80 [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=1217890698, session_epoch=8335, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.049 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1217890698, session_epoch=8335, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.049 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 30128.569824, idle connection 447368.000000, request 304999.951124 04/20/2026 04:38:30.050 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 30128.157471, idle connection 447367.000000, request 304999.545574 04/20/2026 04:38:30.106 7fc43eb74180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32761.871826, idle connection 272760.000000, request 304399.019003 04/20/2026 04:38:30.106 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7557 04/20/2026 04:38:30.106 7fc43eb74180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:30.106 7fc43eb74180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7557 (601.4885902404785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1132301505, topics=[]) 04/20/2026 04:38:30.106 7fc43eb74180 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1132301505 with 0 response partitions (1 implied) 04/20/2026 04:38:30.251 7fc43eb74400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 32937.653320, idle connection 272936.000000, request 304399.130344 04/20/2026 04:38:30.251 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8042 04/20/2026 04:38:30.251 7fc43eb74400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:30.251 7fc43eb74400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8042 (601.3867855072021 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=579651175, topics=[]) 04/20/2026 04:38:30.251 7fc43eb74400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 579651175 with 0 response partitions (1 implied) 04/20/2026 04:38:30.329 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 611 04/20/2026 04:38:30.330 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 04/20/2026 04:38:30.330 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 04/20/2026 04:38:30.330 7fc43ce94cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:30.330 7fc43ce94cc0 [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=1061022208, session_epoch=7591, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.330 7fc43ce94cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7611 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1061022208, session_epoch=7591, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.330 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31875.775146, idle connection 271874.000000, request 304999.951363 04/20/2026 04:38:30.331 7fc43ce94cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31875.366211, idle connection 271873.000000, request 304999.550104 04/20/2026 04:38:30.373 7fc43eb747c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 33838.760986, idle connection 273837.000000, request 304399.082899 04/20/2026 04:38:30.373 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8019 04/20/2026 04:38:30.374 7fc43eb747c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:30.374 7fc43eb747c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8019 (601.4153957366943 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=846222568, topics=[]) 04/20/2026 04:38:30.374 7fc43eb747c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 846222568 with 0 response partitions (1 implied) 04/20/2026 04:38:30.414 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 274 04/20/2026 04:38:30.414 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 04/20/2026 04:38:30.414 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 04/20/2026 04:38:30.415 7fc43ce94ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:30.415 7fc43ce94ea0 [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=685664860, session_epoch=7510, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.415 7fc43ce94ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7528 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=685664860, session_epoch=7510, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.415 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 30860.651855, idle connection 270859.000000, request 304999.952078 04/20/2026 04:38:30.415 7fc43ce94ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 30860.247559, idle connection 270858.000000, request 304999.554396 04/20/2026 04:38:30.476 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 3923 04/20/2026 04:38:30.476 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 04/20/2026 04:38:30.476 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 04/20/2026 04:38:30.477 7fc43eb74540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 04/20/2026 04:38:30.477 7fc43eb74540 [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=1563294869, session_epoch=8007, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.478 7fc43eb74540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8019 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563294869, session_epoch=8007, topics=[], forgotten_topics_data=[]) 04/20/2026 04:38:30.478 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31268.620850, idle connection 510586.000000, request 304999.819517 04/20/2026 04:38:30.479 7fc43eb74540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 31268.204834, idle connection 510586.000000, request 304999.413967 04/20/2026 04:38:30.651 7fc43eb74b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 29527.236084, idle connection 446766.000000, request 304398.618221 04/20/2026 04:38:30.651 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8357 04/20/2026 04:38:30.651 7fc43eb74b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 04/20/2026 04:38:30.651 7fc43eb74b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8357 (601.7858982086182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1217890698, topics=[]) 04/20/2026 04:38:30.651 7fc43eb74b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1217890698 with 0 response partitions (1 implied)