08/24/2026 05:13:13.245 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89491.545654, idle connection 28575.000000, request 304999.924183 08/24/2026 05:13:13.248 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89686.282227, idle connection 28268.000000, request 304995.847225 08/24/2026 05:13:13.248 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89488.177490, idle connection 28571.000000, request 304996.561289 08/24/2026 05:13:13.305 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:13.305 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:13.306 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:13.306 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:13.306 7faa60327220 [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=818598925, session_epoch=8254, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.306 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8266 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8254, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.306 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90640.902588, idle connection 29007.000000, request 304999.916553 08/24/2026 05:13:13.307 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:13.307 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:13.307 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:13.307 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:13.307 7faa5ef6d220 [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=1674212408, session_epoch=8225, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.307 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8234 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8225, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.308 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91915.873535, idle connection 30598.000000, request 304999.933481 08/24/2026 05:13:13.308 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90639.133545, idle connection 29005.000000, request 304998.161077 08/24/2026 05:13:13.309 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91914.840332, idle connection 30597.000000, request 304998.910189 08/24/2026 05:13:13.433 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91369.103516, idle connection 29902.000000, request 304397.907972 08/24/2026 05:13:13.434 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8148 08/24/2026 05:13:13.434 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:13.434 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8148 (603.0228137969971 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:13.435 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:13.435 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90165.523926, idle connection 28694.000000, request 304397.012711 08/24/2026 05:13:13.435 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8203 08/24/2026 05:13:13.435 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:13.436 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8203 (603.5110950469971 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:13.436 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:13.473 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3484 08/24/2026 05:13:13.474 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:13.474 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:13.474 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:13.474 7faa5ef6dcc0 [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=1101268060, session_epoch=8710, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.474 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8721 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8710, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.474 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85059.680664, idle connection 24013.000000, request 304999.938488 08/24/2026 05:13:13.475 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85059.126953, idle connection 24012.000000, request 304999.394417 08/24/2026 05:13:13.573 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4163 08/24/2026 05:13:13.573 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:13.573 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:13.573 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:13.573 7faa5ef6dc20 [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=301296110, session_epoch=8767, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.574 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8781 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8767, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.574 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90540.197998, idle connection 29298.000000, request 304999.929428 08/24/2026 05:13:13.574 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5218 08/24/2026 05:13:13.574 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:13.574 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:13.574 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:13.574 7faa5ef6d5e0 [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=792964362, session_epoch=8786, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.574 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8806 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8786, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.575 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82197.001465, idle connection 20499.000000, request 304999.915361 08/24/2026 05:13:13.575 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90538.892334, idle connection 29297.000000, request 304998.641729 08/24/2026 05:13:13.575 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82196.112061, idle connection 20498.000000, request 304999.073744 08/24/2026 05:13:13.641 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:13.641 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:13.642 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:13.642 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:13.642 7faa5ef6d860 [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=224826165, session_epoch=8780, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.642 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8800 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8780, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.642 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87112.620605, idle connection 25082.000000, request 304999.918222 08/24/2026 05:13:13.643 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87111.834961, idle connection 25081.000000, request 304999.146223 08/24/2026 05:13:13.673 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:13.673 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:13.673 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:13.673 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:13.674 7faa60327040 [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=140424269, session_epoch=8222, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.674 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8231 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8222, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.674 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86056.421387, idle connection 24784.000000, request 304999.922752 08/24/2026 05:13:13.674 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86055.805176, idle connection 24783.000000, request 304999.320984 08/24/2026 05:13:13.727 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:13.728 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:13.728 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:13.728 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:13.728 7faa5ef6d680 [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=1113797485, session_epoch=8399, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.728 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8416 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8399, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:13.728 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88269.501953, idle connection 328267.000000, request 304999.940634 08/24/2026 05:13:13.729 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88269.010742, idle connection 328267.000000, request 304999.459743 08/24/2026 05:13:13.849 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89085.192627, idle connection 27666.000000, request 304394.745588 08/24/2026 05:13:13.849 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8662 08/24/2026 05:13:13.850 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:13.850 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8662 (606.1701774597168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:13.850 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:13.850 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88886.003174, idle connection 27969.000000, request 304394.382954 08/24/2026 05:13:13.851 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8231 08/24/2026 05:13:13.851 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:13.851 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8231 (606.0793399810791 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:13.851 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:13.909 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90038.008545, idle connection 28404.000000, request 304397.028923 08/24/2026 05:13:13.910 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8266 08/24/2026 05:13:13.910 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:13.910 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8266 (603.6548614501953 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:13.910 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:13.910 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 91313.024414, idle connection 29995.000000, request 304397.089958 08/24/2026 05:13:13.911 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8234 08/24/2026 05:13:13.911 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:13.911 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8234 (603.3170223236084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:13.911 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:14.036 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:14.036 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:14.036 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:14.036 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:14.036 7faa5e5b22c0 [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=1952320670, session_epoch=8141, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.036 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8149 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8141, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.037 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90765.931641, idle connection 29299.000000, request 304999.922752 08/24/2026 05:13:14.037 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:14.037 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:14.037 7faa5e597cc0 [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)]) 08/24/2026 05:13:14.037 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:14.037 7faa5e597cc0 [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=307140566, session_epoch=8191, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.037 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8204 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8191, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.038 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89562.947998, idle connection 28092.000000, request 304999.953032 08/24/2026 05:13:14.038 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90764.418457, idle connection 29298.000000, request 304998.425722 08/24/2026 05:13:14.038 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89562.096680, idle connection 28091.000000, request 304999.105930 08/24/2026 05:13:14.076 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84458.473389, idle connection 23412.000000, request 304398.723125 08/24/2026 05:13:14.076 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8721 08/24/2026 05:13:14.076 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.076 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8721 (602.0452976226807 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[]) 08/24/2026 05:13:14.077 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 0 response partitions (1 implied) 08/24/2026 05:13:14.176 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89937.617676, idle connection 28695.000000, request 304397.351742 08/24/2026 05:13:14.177 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8781 08/24/2026 05:13:14.177 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.177 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8781 (603.4317016601562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=4165, last_stable_offset=4165, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10C\x00\x00\x01\xc5\x00\x00\x00\x00\x02x\x13]\x9d\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\x90\x03\x00\x00\x00\xd2\x02ObjectVNTable:default-domain:def...')])]) 08/24/2026 05:13:14.177 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 1 response partitions (0 implied) 08/24/2026 05:13:14.178 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 465 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 4163 08/24/2026 05:13:14.178 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4163 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 08/24/2026 05:13:14.178 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 4165 (leader epoch 0) 08/24/2026 05:13:14.178 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81593.182129, idle connection 19896.000000, request 304396.136284 08/24/2026 05:13:14.179 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8806 08/24/2026 05:13:14.179 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.179 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8806 (604.4347286224365 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[]) 08/24/2026 05:13:14.179 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 0 response partitions (1 implied) 08/24/2026 05:13:14.245 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86510.328857, idle connection 24480.000000, request 304397.624493 08/24/2026 05:13:14.245 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8800 08/24/2026 05:13:14.245 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.245 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8800 (603.1012535095215 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:14.246 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:14.275 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85455.107422, idle connection 24182.000000, request 304398.612976 08/24/2026 05:13:14.276 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8231 08/24/2026 05:13:14.276 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.276 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8231 (602.0753383636475 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:14.276 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:14.279 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4165 08/24/2026 05:13:14.279 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:14.279 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:14.279 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:14.279 7faa5ef6dc20 [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=301296110, session_epoch=8768, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4165, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:14.279 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8782 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8768, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4165, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:14.280 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89834.307861, idle connection 28592.000000, request 304999.872446 08/24/2026 05:13:14.280 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89833.588623, idle connection 28591.000000, request 304999.216080 08/24/2026 05:13:14.330 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87668.340088, idle connection 327666.000000, request 304398.777246 08/24/2026 05:13:14.330 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8416 08/24/2026 05:13:14.330 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.330 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8416 (601.9620895385742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:14.330 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:14.452 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3820 08/24/2026 05:13:14.452 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:14.453 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:14.453 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:14.453 7faa5ef6dea0 [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=1429157710, session_epoch=8647, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.453 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8663 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8647, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.453 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88480.704834, idle connection 27062.000000, request 304999.910831 08/24/2026 05:13:14.453 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:14.454 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:14.454 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:14.454 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:14.454 7faa5ef6d0e0 [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=2114138634, session_epoch=8214, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.454 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8232 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8214, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.454 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88282.278564, idle connection 27365.000000, request 304999.960184 08/24/2026 05:13:14.455 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88479.383789, idle connection 27061.000000, request 304998.558283 08/24/2026 05:13:14.455 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88281.240723, idle connection 27364.000000, request 304998.925686 08/24/2026 05:13:14.455 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8663 08/24/2026 05:13:14.455 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.456 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8663 (2.368927001953125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=3824, last_stable_offset=3824, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xec\x00\x00\x04:\x00\x00\x00\x00\x02\xc4\xc5\x0e\xb2\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\xb0\x05\x00\x00\x00\xf2\x04ObjectBgpPeer:default-domain:def...')])]) 08/24/2026 05:13:14.456 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 1 response partitions (0 implied) 08/24/2026 05:13:14.456 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1369 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 3820 08/24/2026 05:13:14.456 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3820 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) 08/24/2026 05:13:14.457 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 3824 (leader epoch 0) 08/24/2026 05:13:14.511 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:14.511 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:14.512 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:14.512 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:14.512 7faa60327220 [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=818598925, session_epoch=8255, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.512 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8267 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8255, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.512 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89435.141113, idle connection 27801.000000, request 304999.925137 08/24/2026 05:13:14.512 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:14.512 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:14.512 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:14.513 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:14.513 7faa5ef6d220 [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=1674212408, session_epoch=8226, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.513 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8235 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8226, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.513 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90710.481689, idle connection 29392.000000, request 304999.953747 08/24/2026 05:13:14.513 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89433.902588, idle connection 27800.000000, request 304998.698950 08/24/2026 05:13:14.514 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90709.772461, idle connection 29392.000000, request 304999.246359 08/24/2026 05:13:14.558 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3824 08/24/2026 05:13:14.558 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:14.558 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:14.558 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:14.558 7faa5ef6dea0 [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=1429157710, session_epoch=8648, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3824, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:14.558 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8664 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8648, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3824, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:14.558 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88375.616699, idle connection 26957.000000, request 304999.932289 08/24/2026 05:13:14.559 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88374.877197, idle connection 26956.000000, request 304999.207735 08/24/2026 05:13:14.639 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90163.321533, idle connection 28696.000000, request 304397.319794 08/24/2026 05:13:14.640 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8149 08/24/2026 05:13:14.640 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.640 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8149 (603.3165454864502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:14.640 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:14.640 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88960.297607, idle connection 27489.000000, request 304397.305012 08/24/2026 05:13:14.640 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8204 08/24/2026 05:13:14.640 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.641 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8204 (603.001594543457 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:14.641 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:14.679 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3484 08/24/2026 05:13:14.680 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:14.680 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:14.680 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:14.680 7faa5ef6dcc0 [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=1101268060, session_epoch=8711, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.680 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8711, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.680 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83853.541260, idle connection 22807.000000, request 304999.931335 08/24/2026 05:13:14.681 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83853.033203, idle connection 22806.000000, request 304999.437094 08/24/2026 05:13:14.780 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5218 08/24/2026 05:13:14.781 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:14.781 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:14.781 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:14.781 7faa5ef6d5e0 [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=792964362, session_epoch=8787, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.781 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8807 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8787, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.781 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80990.141357, idle connection 19292.000000, request 304999.921560 08/24/2026 05:13:14.782 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80989.396484, idle connection 19292.000000, request 304999.188662 08/24/2026 05:13:14.847 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:14.847 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:14.848 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:14.848 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:14.848 7faa5ef6d860 [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=224826165, session_epoch=8781, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.848 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8801 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8781, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.848 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85906.892578, idle connection 23876.000000, request 304999.925852 08/24/2026 05:13:14.849 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85906.316895, idle connection 23876.000000, request 304999.363899 08/24/2026 05:13:14.878 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:14.878 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:14.878 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:14.878 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:14.878 7faa60327040 [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=140424269, session_epoch=8223, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.878 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8232 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8223, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.878 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84851.946045, idle connection 23579.000000, request 304999.935389 08/24/2026 05:13:14.879 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84851.419189, idle connection 23579.000000, request 304999.419212 08/24/2026 05:13:14.882 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89232.184814, idle connection 27990.000000, request 304397.812843 08/24/2026 05:13:14.882 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8782 08/24/2026 05:13:14.882 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:14.882 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8782 (602.6620864868164 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[]) 08/24/2026 05:13:14.882 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 0 response partitions (1 implied) 08/24/2026 05:13:14.932 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:14.932 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:14.932 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:14.933 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:14.933 7faa5ef6d680 [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=1113797485, session_epoch=8400, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.933 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8417 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8400, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:14.933 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87064.751953, idle connection 327063.000000, request 304999.922514 08/24/2026 05:13:14.934 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87064.211426, idle connection 327062.000000, request 304999.400616 08/24/2026 05:13:15.059 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87677.295654, idle connection 26761.000000, request 304394.970655 08/24/2026 05:13:15.059 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8232 08/24/2026 05:13:15.060 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.060 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8232 (605.661153793335 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:15.060 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:15.114 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88832.985107, idle connection 27199.000000, request 304397.764683 08/24/2026 05:13:15.115 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8267 08/24/2026 05:13:15.115 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.115 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8267 (603.0535697937012 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:15.115 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:15.116 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 90107.885986, idle connection 28790.000000, request 304397.357464 08/24/2026 05:13:15.116 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8235 08/24/2026 05:13:15.116 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.116 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8235 (603.001594543457 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:15.116 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:15.160 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87773.587891, idle connection 26355.000000, request 304397.908211 08/24/2026 05:13:15.161 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8664 08/24/2026 05:13:15.161 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.161 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8664 (602.8182506561279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:15.161 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:15.241 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:15.241 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:15.241 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:15.241 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:15.241 7faa5e5b22c0 [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=1952320670, session_epoch=8142, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.242 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8150 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8142, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.242 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89560.801758, idle connection 28094.000000, request 304999.934196 08/24/2026 05:13:15.242 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:15.242 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:15.242 7faa5e597cc0 [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)]) 08/24/2026 05:13:15.242 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:15.242 7faa5e597cc0 [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=307140566, session_epoch=8192, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.242 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8205 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8192, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.243 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88357.961426, idle connection 26887.000000, request 304999.918461 08/24/2026 05:13:15.243 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89559.277588, idle connection 28092.000000, request 304998.418570 08/24/2026 05:13:15.244 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88356.865967, idle connection 26886.000000, request 304998.829126 08/24/2026 05:13:15.283 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83250.773193, idle connection 22204.000000, request 304397.169828 08/24/2026 05:13:15.284 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8722 08/24/2026 05:13:15.285 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.285 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8722 (604.2866706848145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=3485, last_stable_offset=3485, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\r\x9c\x00\x00\x00\xfe\x00\x00\x00\x00\x02'&\xb4g\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\x96\x03\x00\x00\x00\xd8\x02ObjectVNTable:default-domain:def...")])]) 08/24/2026 05:13:15.285 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 1 response partitions (0 implied) 08/24/2026 05:13:15.285 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 266 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 3484 08/24/2026 05:13:15.285 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3484 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) 08/24/2026 05:13:15.285 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 3485 (leader epoch 0) 08/24/2026 05:13:15.383 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80388.704834, idle connection 18691.000000, request 304398.489237 08/24/2026 05:13:15.384 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8807 08/24/2026 05:13:15.384 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.384 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8807 (602.4253368377686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5220, last_stable_offset=5220, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x14b\x00\x00\x01\xfd\x00\x00\x00\x00\x02\x16\xfd\xafw\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\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 08/24/2026 05:13:15.384 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 1 response partitions (0 implied) 08/24/2026 05:13:15.384 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 521 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5218 08/24/2026 05:13:15.384 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5218 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 08/24/2026 05:13:15.385 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5220 (leader epoch 0) 08/24/2026 05:13:15.386 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3485 08/24/2026 05:13:15.386 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:15.386 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-27', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:15.386 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:15.386 7faa5ef6dcc0 [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=1101268060, session_epoch=8712, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3485, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:15.387 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8723 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8712, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3485, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:15.387 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83147.215332, idle connection 22100.000000, request 304999.943495 08/24/2026 05:13:15.387 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83146.740479, idle connection 22100.000000, request 304999.476433 08/24/2026 05:13:15.450 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85305.356689, idle connection 23275.000000, request 304398.393631 08/24/2026 05:13:15.450 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8801 08/24/2026 05:13:15.450 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.450 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8801 (602.2825241088867 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:15.450 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:15.480 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84250.739990, idle connection 22978.000000, request 304398.723841 08/24/2026 05:13:15.480 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8232 08/24/2026 05:13:15.480 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.480 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8232 (602.0145416259766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:15.481 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:15.483 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4165 08/24/2026 05:13:15.483 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:15.483 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:15.483 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:15.483 7faa5ef6dc20 [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=301296110, session_epoch=8769, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.483 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8783 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8769, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.484 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88630.373779, idle connection 27388.000000, request 304999.930620 08/24/2026 05:13:15.484 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88629.803467, idle connection 27388.000000, request 304999.368191 08/24/2026 05:13:15.485 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5220 08/24/2026 05:13:15.486 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:15.486 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:15.486 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:15.486 7faa5ef6d5e0 [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=792964362, session_epoch=8788, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5220, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:15.486 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8808 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8788, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5220, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:15.486 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80285.237061, idle connection 18588.000000, request 304999.950886 08/24/2026 05:13:15.487 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80284.795166, idle connection 18587.000000, request 304999.513149 08/24/2026 05:13:15.534 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86463.556641, idle connection 326461.000000, request 304398.736000 08/24/2026 05:13:15.535 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8417 08/24/2026 05:13:15.535 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.535 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8417 (602.1413803100586 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:15.535 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:15.661 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:15.662 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:15.662 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:15.662 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:15.662 7faa5ef6d0e0 [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=2114138634, session_epoch=8215, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.662 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8233 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8215, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.662 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87074.029297, idle connection 26157.000000, request 304999.940157 08/24/2026 05:13:15.663 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87073.517822, idle connection 26157.000000, request 304999.437571 08/24/2026 05:13:15.716 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:15.717 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:15.717 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:15.717 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:15.717 7faa60327220 [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=818598925, session_epoch=8256, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.717 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8268 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8256, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.717 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88230.038330, idle connection 26596.000000, request 304999.924421 08/24/2026 05:13:15.717 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:15.718 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:15.718 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:15.718 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:15.718 7faa5ef6d220 [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=1674212408, session_epoch=8227, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.718 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8236 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8227, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.718 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89505.377930, idle connection 28187.000000, request 304999.956369 08/24/2026 05:13:15.718 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88228.745361, idle connection 26594.000000, request 304998.639822 08/24/2026 05:13:15.719 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89504.537354, idle connection 28186.000000, request 304999.120712 08/24/2026 05:13:15.762 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3824 08/24/2026 05:13:15.762 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:15.762 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:15.762 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:15.762 7faa5ef6dea0 [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=1429157710, session_epoch=8649, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.763 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8665 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8649, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:15.763 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87171.138672, idle connection 25752.000000, request 304999.924898 08/24/2026 05:13:15.763 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87170.499756, idle connection 25752.000000, request 304999.303579 08/24/2026 05:13:15.844 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88958.125000, idle connection 27491.000000, request 304397.253275 08/24/2026 05:13:15.845 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8150 08/24/2026 05:13:15.845 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.845 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8150 (603.3763885498047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:15.845 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:15.845 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87755.066650, idle connection 26284.000000, request 304397.026062 08/24/2026 05:13:15.846 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8205 08/24/2026 05:13:15.846 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.846 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8205 (603.3735275268555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:15.846 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:15.988 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82546.235840, idle connection 21499.000000, request 304398.963213 08/24/2026 05:13:15.988 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8723 08/24/2026 05:13:15.988 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:15.988 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8723 (601.7000675201416 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[]) 08/24/2026 05:13:15.989 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 0 response partitions (1 implied) 08/24/2026 05:13:16.052 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:16.052 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:16.052 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:16.053 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:16.053 7faa5ef6d860 [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=224826165, session_epoch=8782, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.053 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8802 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8782, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.053 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84701.997314, idle connection 22672.000000, request 304999.934196 08/24/2026 05:13:16.053 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84701.481445, idle connection 22671.000000, request 304999.430895 08/24/2026 05:13:16.081 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:16.082 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:16.082 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:16.082 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:16.082 7faa60327040 [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=140424269, session_epoch=8224, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.082 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8233 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8224, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.082 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83648.119629, idle connection 22375.000000, request 304999.930143 08/24/2026 05:13:16.083 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83647.575439, idle connection 22375.000000, request 304999.402523 08/24/2026 05:13:16.086 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88028.342773, idle connection 26786.000000, request 304397.908211 08/24/2026 05:13:16.086 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8783 08/24/2026 05:13:16.086 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.086 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8783 (602.5204658508301 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[]) 08/24/2026 05:13:16.086 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 0 response partitions (1 implied) 08/24/2026 05:13:16.088 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79683.738037, idle connection 17986.000000, request 304398.454189 08/24/2026 05:13:16.088 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8808 08/24/2026 05:13:16.088 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.088 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8808 (601.9237041473389 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[]) 08/24/2026 05:13:16.088 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 0 response partitions (1 implied) 08/24/2026 05:13:16.137 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:16.137 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:16.137 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:16.138 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:16.138 7faa5ef6d680 [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=1113797485, session_epoch=8401, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.138 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8418 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8401, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.138 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85859.903320, idle connection 325858.000000, request 304999.937773 08/24/2026 05:13:16.139 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85859.305176, idle connection 325857.000000, request 304999.303818 08/24/2026 05:13:16.263 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86472.851807, idle connection 25556.000000, request 304398.756027 08/24/2026 05:13:16.264 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8233 08/24/2026 05:13:16.264 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.264 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8233 (602.1771430969238 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:16.265 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:16.320 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87627.692627, idle connection 25993.000000, request 304397.578239 08/24/2026 05:13:16.320 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8268 08/24/2026 05:13:16.320 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.320 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8268 (603.2109260559082 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:16.321 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:16.321 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88902.637939, idle connection 27585.000000, request 304397.218227 08/24/2026 05:13:16.321 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8236 08/24/2026 05:13:16.321 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.321 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8236 (603.1498908996582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:16.321 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:16.365 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86569.199219, idle connection 25150.000000, request 304397.989988 08/24/2026 05:13:16.365 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8665 08/24/2026 05:13:16.365 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.365 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8665 (602.6878356933594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:16.366 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:16.447 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:16.447 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:16.447 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:16.447 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:16.447 7faa5e5b22c0 [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=1952320670, session_epoch=8143, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.448 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8151 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8143, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.448 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88354.675049, idle connection 26888.000000, request 304999.915361 08/24/2026 05:13:16.448 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:16.448 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:16.448 7faa5e597cc0 [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)]) 08/24/2026 05:13:16.448 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:16.448 7faa5e597cc0 [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=307140566, session_epoch=8193, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.449 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8206 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8193, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.449 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87151.894043, idle connection 25681.000000, request 304999.956131 08/24/2026 05:13:16.449 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88353.287842, idle connection 26886.000000, request 304998.544693 08/24/2026 05:13:16.450 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87151.001953, idle connection 25680.000000, request 304999.067307 08/24/2026 05:13:16.590 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3485 08/24/2026 05:13:16.590 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:16.590 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:16.591 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:16.591 7faa5ef6dcc0 [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=1101268060, session_epoch=8713, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.591 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8713, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.591 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81942.585693, idle connection 20896.000000, request 304999.909639 08/24/2026 05:13:16.592 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81941.949463, idle connection 20895.000000, request 304999.288559 08/24/2026 05:13:16.654 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84100.504395, idle connection 22070.000000, request 304398.442268 08/24/2026 05:13:16.655 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8802 08/24/2026 05:13:16.655 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.655 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8802 (602.2160053253174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:16.655 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:16.683 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83046.886719, idle connection 21774.000000, request 304398.702383 08/24/2026 05:13:16.684 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8233 08/24/2026 05:13:16.684 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.684 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8233 (601.9377708435059 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:16.684 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:16.687 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4165 08/24/2026 05:13:16.687 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:16.687 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:16.687 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:16.687 7faa5ef6dc20 [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=301296110, session_epoch=8770, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.687 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8784 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8770, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.687 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87426.777344, idle connection 26185.000000, request 304999.946356 08/24/2026 05:13:16.688 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87426.299561, idle connection 26184.000000, request 304999.474049 08/24/2026 05:13:16.689 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5220 08/24/2026 05:13:16.689 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:16.689 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:16.689 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:16.689 7faa5ef6d5e0 [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=792964362, session_epoch=8789, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.689 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8789, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.689 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79082.340576, idle connection 17385.000000, request 304999.956369 08/24/2026 05:13:16.690 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79081.954346, idle connection 17384.000000, request 304999.570847 08/24/2026 05:13:16.739 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85258.582764, idle connection 325256.000000, request 304398.611546 08/24/2026 05:13:16.740 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8418 08/24/2026 05:13:16.740 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:16.740 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8418 (602.1575927734375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:16.740 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:16.867 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:16.867 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:16.867 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:16.868 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:16.868 7faa5ef6d0e0 [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=2114138634, session_epoch=8216, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.868 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8234 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8216, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.868 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85868.239014, idle connection 24951.000000, request 304999.921083 08/24/2026 05:13:16.869 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85867.656006, idle connection 24951.000000, request 304999.352932 08/24/2026 05:13:16.922 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:16.922 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:16.923 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:16.923 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:16.923 7faa60327220 [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=818598925, session_epoch=8257, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.923 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8269 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8257, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.923 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87023.897217, idle connection 25390.000000, request 304999.918222 08/24/2026 05:13:16.924 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:16.924 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:16.924 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:16.924 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:16.924 7faa5ef6d220 [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=1674212408, session_epoch=8228, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.924 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8237 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8228, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.924 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88299.020264, idle connection 26981.000000, request 304999.945641 08/24/2026 05:13:16.925 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87022.269775, idle connection 25388.000000, request 304998.303175 08/24/2026 05:13:16.926 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88297.684570, idle connection 26980.000000, request 304998.610497 08/24/2026 05:13:16.967 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3824 08/24/2026 05:13:16.967 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:16.967 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:16.967 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:16.967 7faa5ef6dea0 [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=1429157710, session_epoch=8650, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.968 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8666 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8650, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:16.968 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85966.204102, idle connection 24547.000000, request 304999.942780 08/24/2026 05:13:16.968 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85965.732666, idle connection 24547.000000, request 304999.480724 08/24/2026 05:13:17.057 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87745.739746, idle connection 26279.000000, request 304390.970230 08/24/2026 05:13:17.057 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86543.336182, idle connection 25072.000000, request 304391.398668 08/24/2026 05:13:17.058 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8151 08/24/2026 05:13:17.058 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.058 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8151 (609.9681854248047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:17.058 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:17.058 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8206 08/24/2026 05:13:17.058 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.058 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8206 (609.70139503479 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:17.058 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:17.193 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81341.109375, idle connection 20294.000000, request 304398.434639 08/24/2026 05:13:17.194 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8724 08/24/2026 05:13:17.194 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.194 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8724 (602.5538444519043 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[]) 08/24/2026 05:13:17.194 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 0 response partitions (1 implied) 08/24/2026 05:13:17.259 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:17.259 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:17.259 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:17.260 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:17.260 7faa5ef6d860 [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=224826165, session_epoch=8783, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.260 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8803 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8783, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.260 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83494.887451, idle connection 21464.000000, request 304999.935150 08/24/2026 05:13:17.261 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83494.382812, idle connection 21464.000000, request 304999.441862 08/24/2026 05:13:17.285 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:17.285 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:17.285 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:17.286 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:17.286 7faa60327040 [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=140424269, session_epoch=8225, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.286 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8234 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8225, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.286 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82444.197021, idle connection 21171.000000, request 304999.935150 08/24/2026 05:13:17.287 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82443.659424, idle connection 21171.000000, request 304999.406815 08/24/2026 05:13:17.288 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86825.570312, idle connection 25583.000000, request 304398.743153 08/24/2026 05:13:17.289 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8784 08/24/2026 05:13:17.289 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.289 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8784 (601.7012596130371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[]) 08/24/2026 05:13:17.289 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 0 response partitions (1 implied) 08/24/2026 05:13:17.291 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78480.852783, idle connection 16783.000000, request 304398.464680 08/24/2026 05:13:17.291 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8809 08/24/2026 05:13:17.291 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.291 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8809 (601.9539833068848 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[]) 08/24/2026 05:13:17.291 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 0 response partitions (1 implied) 08/24/2026 05:13:17.342 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:17.342 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:17.342 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:17.343 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:17.343 7faa5ef6d680 [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=1113797485, session_epoch=8402, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.343 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8419 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8402, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.343 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84654.578125, idle connection 324652.000000, request 304999.924660 08/24/2026 05:13:17.344 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84653.958740, idle connection 324652.000000, request 304999.317646 08/24/2026 05:13:17.469 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85266.993164, idle connection 24350.000000, request 304398.669958 08/24/2026 05:13:17.470 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8234 08/24/2026 05:13:17.470 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.470 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8234 (602.1053791046143 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:17.470 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:17.526 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86420.837158, idle connection 24787.000000, request 304396.864891 08/24/2026 05:13:17.527 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8269 08/24/2026 05:13:17.527 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.527 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8269 (603.938102722168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:17.527 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:17.528 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87695.743652, idle connection 26378.000000, request 304396.667719 08/24/2026 05:13:17.528 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8237 08/24/2026 05:13:17.528 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.528 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8237 (603.8076877593994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:17.528 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:17.572 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85362.307373, idle connection 23944.000000, request 304396.042347 08/24/2026 05:13:17.572 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8666 08/24/2026 05:13:17.572 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.572 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8666 (604.6292781829834 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:17.573 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:17.660 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:17.660 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:17.660 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:17.660 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:17.660 7faa5e5b22c0 [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=1952320670, session_epoch=8144, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.660 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8152 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8144, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.661 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87141.919922, idle connection 25675.000000, request 304999.932051 08/24/2026 05:13:17.661 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87141.340332, idle connection 25674.000000, request 304999.359846 08/24/2026 05:13:17.663 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:17.663 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:17.663 7faa5e597cc0 [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)]) 08/24/2026 05:13:17.663 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:17.663 7faa5e597cc0 [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=307140566, session_epoch=8194, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.663 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8207 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8194, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.664 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85936.920898, idle connection 24466.000000, request 304999.925852 08/24/2026 05:13:17.664 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85936.339600, idle connection 24465.000000, request 304999.323368 08/24/2026 05:13:17.795 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3485 08/24/2026 05:13:17.795 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:17.795 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:17.795 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:17.795 7faa5ef6dcc0 [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=1101268060, session_epoch=8714, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.796 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8725 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8714, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.796 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80738.207520, idle connection 19691.000000, request 304999.921322 08/24/2026 05:13:17.796 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80737.660645, idle connection 19691.000000, request 304999.384880 08/24/2026 05:13:17.862 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82893.217773, idle connection 20863.000000, request 304398.264408 08/24/2026 05:13:17.862 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8803 08/24/2026 05:13:17.862 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.862 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8803 (602.39577293396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:17.863 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:17.887 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81842.935303, idle connection 20570.000000, request 304398.671150 08/24/2026 05:13:17.888 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8234 08/24/2026 05:13:17.888 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.888 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8234 (601.9570827484131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:17.888 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:17.889 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4165 08/24/2026 05:13:17.889 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:17.889 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:17.890 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:17.890 7faa5ef6dc20 [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=301296110, session_epoch=8771, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.890 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8771, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.890 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86223.960205, idle connection 24982.000000, request 304999.952078 08/24/2026 05:13:17.890 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86223.516846, idle connection 24981.000000, request 304999.513865 08/24/2026 05:13:17.892 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5220 08/24/2026 05:13:17.892 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:17.892 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:17.892 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:17.892 7faa5ef6d5e0 [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=792964362, session_epoch=8790, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.892 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8810 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8790, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:17.892 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77879.097168, idle connection 16181.000000, request 304999.953270 08/24/2026 05:13:17.893 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77878.694092, idle connection 16181.000000, request 304999.554157 08/24/2026 05:13:17.945 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84053.221924, idle connection 324051.000000, request 304398.570061 08/24/2026 05:13:17.945 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8419 08/24/2026 05:13:17.945 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:17.945 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8419 (602.1549701690674 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:17.946 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:18.072 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:18.072 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:18.072 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:18.072 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:18.072 7faa5ef6d0e0 [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=2114138634, session_epoch=8217, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.072 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8235 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8217, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.072 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84663.792969, idle connection 23747.000000, request 304999.938726 08/24/2026 05:13:18.073 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84663.277100, idle connection 23746.000000, request 304999.434233 08/24/2026 05:13:18.129 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:18.129 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:18.129 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:18.129 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:18.129 7faa60327220 [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=818598925, session_epoch=8258, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.129 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8270 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8258, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.129 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85817.805908, idle connection 24183.000000, request 304999.939203 08/24/2026 05:13:18.130 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:18.130 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:18.130 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:18.130 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:18.130 7faa5ef6d220 [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=1674212408, session_epoch=8229, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.130 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8238 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8229, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.130 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87093.206787, idle connection 25775.000000, request 304999.958754 08/24/2026 05:13:18.131 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85816.640869, idle connection 24182.000000, request 304998.773098 08/24/2026 05:13:18.131 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87092.401367, idle connection 25774.000000, request 304999.155760 08/24/2026 05:13:18.174 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3824 08/24/2026 05:13:18.174 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:18.174 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:18.174 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:18.175 7faa5ef6dea0 [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=1429157710, session_epoch=8651, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.175 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8667 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8651, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.175 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84759.075195, idle connection 23340.000000, request 304999.932528 08/24/2026 05:13:18.175 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84758.566406, idle connection 23340.000000, request 304999.439001 08/24/2026 05:13:18.263 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86539.982178, idle connection 25073.000000, request 304397.995949 08/24/2026 05:13:18.263 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8152 08/24/2026 05:13:18.263 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.263 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8152 (602.6461124420166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:18.263 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:18.265 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85335.860596, idle connection 23865.000000, request 304398.872852 08/24/2026 05:13:18.265 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8207 08/24/2026 05:13:18.265 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.265 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8207 (601.4316082000732 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:18.265 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:18.397 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80137.096680, idle connection 19090.000000, request 304398.810148 08/24/2026 05:13:18.397 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8725 08/24/2026 05:13:18.397 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.398 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8725 (601.844310760498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[]) 08/24/2026 05:13:18.398 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 0 response partitions (1 implied) 08/24/2026 05:13:18.464 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:18.464 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:18.465 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:18.465 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:18.465 7faa5ef6d860 [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=224826165, session_epoch=8784, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.465 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8804 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8784, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.465 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82289.945312, idle connection 20260.000000, request 304999.923229 08/24/2026 05:13:18.466 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82289.449463, idle connection 20259.000000, request 304999.456167 08/24/2026 05:13:18.490 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:18.490 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:18.490 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:18.490 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:18.490 7faa60327040 [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=140424269, session_epoch=8226, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.490 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8235 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8226, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.490 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81239.938965, idle connection 19967.000000, request 304999.944210 08/24/2026 05:13:18.491 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81239.491943, idle connection 19967.000000, request 304999.505281 08/24/2026 05:13:18.492 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85622.175537, idle connection 24380.000000, request 304398.172855 08/24/2026 05:13:18.492 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8785 08/24/2026 05:13:18.492 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.492 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8785 (602.2045612335205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[]) 08/24/2026 05:13:18.492 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 0 response partitions (1 implied) 08/24/2026 05:13:18.494 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77277.628906, idle connection 15580.000000, request 304398.487806 08/24/2026 05:13:18.494 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8810 08/24/2026 05:13:18.494 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.494 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8810 (601.8486022949219 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[]) 08/24/2026 05:13:18.494 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 0 response partitions (1 implied) 08/24/2026 05:13:18.547 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:18.547 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:18.547 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:18.548 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:18.548 7faa5ef6d680 [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=1113797485, session_epoch=8403, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.548 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8420 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8403, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.548 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83449.888916, idle connection 323448.000000, request 304999.935865 08/24/2026 05:13:18.549 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83449.359375, idle connection 323447.000000, request 304999.416351 08/24/2026 05:13:18.674 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84062.621094, idle connection 23146.000000, request 304398.756742 08/24/2026 05:13:18.674 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8235 08/24/2026 05:13:18.674 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.675 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8235 (602.1466255187988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:18.675 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:18.732 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85215.599365, idle connection 23581.000000, request 304397.730589 08/24/2026 05:13:18.732 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8270 08/24/2026 05:13:18.732 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.732 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8270 (602.9341220855713 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:18.732 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:18.733 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86490.654785, idle connection 25173.000000, request 304397.406578 08/24/2026 05:13:18.733 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8238 08/24/2026 05:13:18.733 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.733 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8238 (602.9636859893799 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:18.733 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:18.777 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84157.212646, idle connection 22738.000000, request 304398.071051 08/24/2026 05:13:18.777 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8667 08/24/2026 05:13:18.777 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:18.777 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8667 (602.6501655578613 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:18.778 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:18.865 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:18.865 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:18.865 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:18.865 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:18.865 7faa5e5b22c0 [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=1952320670, session_epoch=8145, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.866 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8153 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8145, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.866 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85936.776123, idle connection 24470.000000, request 304999.939442 08/24/2026 05:13:18.866 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:18.866 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:18.866 7faa5e597cc0 [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)]) 08/24/2026 05:13:18.866 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:18.866 7faa5e597cc0 [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=307140566, session_epoch=8195, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.866 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8208 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8195, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:18.866 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84734.048584, idle connection 23263.000000, request 304999.957323 08/24/2026 05:13:18.867 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85935.553223, idle connection 24469.000000, request 304998.728037 08/24/2026 05:13:18.867 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84733.204834, idle connection 23262.000000, request 304999.117136 08/24/2026 05:13:18.999 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3485 08/24/2026 05:13:19.000 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:19.000 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:19.001 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:19.001 7faa5ef6dcc0 [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=1101268060, session_epoch=8715, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.001 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8726 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8715, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.001 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79532.698730, idle connection 18486.000000, request 304999.930620 08/24/2026 05:13:19.002 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79532.201904, idle connection 18485.000000, request 304999.445200 08/24/2026 05:13:19.066 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81688.725342, idle connection 19658.000000, request 304398.722172 08/24/2026 05:13:19.067 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8804 08/24/2026 05:13:19.067 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.067 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8804 (601.9399166107178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:19.067 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:19.093 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80637.536865, idle connection 19365.000000, request 304397.537947 08/24/2026 05:13:19.093 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8235 08/24/2026 05:13:19.093 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.094 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8235 (603.1723022460938 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:19.094 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:19.094 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4165 08/24/2026 05:13:19.094 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:19.094 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:19.094 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:19.094 7faa5ef6dc20 [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=301296110, session_epoch=8772, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.094 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8786 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8772, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.095 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85019.283936, idle connection 23777.000000, request 304999.911308 08/24/2026 05:13:19.095 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5220 08/24/2026 05:13:19.095 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:19.095 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:19.095 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:19.095 7faa5ef6d5e0 [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=792964362, session_epoch=8791, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.095 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8811 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8791, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.095 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 76676.084961, idle connection 14978.000000, request 304999.953270 08/24/2026 05:13:19.096 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85018.047119, idle connection 23776.000000, request 304998.684406 08/24/2026 05:13:19.096 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 76675.339355, idle connection 14978.000000, request 304999.216080 08/24/2026 05:13:19.149 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82848.609619, idle connection 322846.000000, request 304398.641348 08/24/2026 05:13:19.150 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8420 08/24/2026 05:13:19.150 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.150 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8420 (602.3423671722412 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:19.150 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:19.276 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:19.277 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:19.277 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:19.277 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:19.277 7faa5ef6d0e0 [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=2114138634, session_epoch=8218, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.277 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8236 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8218, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.277 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83459.081543, idle connection 22542.000000, request 304999.933720 08/24/2026 05:13:19.278 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83458.560059, idle connection 22542.000000, request 304999.422073 08/24/2026 05:13:19.334 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:19.334 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:19.334 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:19.335 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:19.335 7faa60327220 [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=818598925, session_epoch=8259, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.335 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8271 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8259, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.335 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84612.146729, idle connection 22978.000000, request 304999.923229 08/24/2026 05:13:19.335 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:19.335 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:19.336 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:19.336 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:19.336 7faa5ef6d220 [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=1674212408, session_epoch=8230, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.336 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8239 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8230, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.336 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85887.428223, idle connection 24569.000000, request 304999.957323 08/24/2026 05:13:19.336 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84610.822998, idle connection 22977.000000, request 304998.611927 08/24/2026 05:13:19.337 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85886.516357, idle connection 24568.000000, request 304999.049664 08/24/2026 05:13:19.379 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3824 08/24/2026 05:13:19.380 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:19.380 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:19.380 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:19.380 7faa5ef6dea0 [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=1429157710, session_epoch=8652, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.380 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8668 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8652, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.380 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83553.646240, idle connection 22135.000000, request 304999.941349 08/24/2026 05:13:19.381 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83553.124512, idle connection 22134.000000, request 304999.418020 08/24/2026 05:13:19.468 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85334.519287, idle connection 23868.000000, request 304397.680521 08/24/2026 05:13:19.468 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8153 08/24/2026 05:13:19.469 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.469 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8153 (603.0013561248779 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:19.469 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:19.469 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84131.393311, idle connection 22660.000000, request 304397.302628 08/24/2026 05:13:19.469 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8208 08/24/2026 05:13:19.469 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.469 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8208 (603.0206680297852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:19.470 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:19.603 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78931.510742, idle connection 17885.000000, request 304398.734093 08/24/2026 05:13:19.603 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8726 08/24/2026 05:13:19.604 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.604 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8726 (602.5159358978271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[]) 08/24/2026 05:13:19.604 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 0 response partitions (1 implied) 08/24/2026 05:13:19.668 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:19.668 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:19.668 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:19.669 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:19.669 7faa5ef6d860 [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=224826165, session_epoch=8785, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.669 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8805 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8785, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.669 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81086.036133, idle connection 19056.000000, request 304999.940872 08/24/2026 05:13:19.670 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81085.428711, idle connection 19055.000000, request 304999.341965 08/24/2026 05:13:19.694 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:19.695 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:19.695 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:19.695 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:19.695 7faa60327040 [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=140424269, session_epoch=8227, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.695 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8236 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8227, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.695 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80035.072998, idle connection 18762.000000, request 304999.925375 08/24/2026 05:13:19.696 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80034.587646, idle connection 18762.000000, request 304999.454737 08/24/2026 05:13:19.698 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84416.304199, idle connection 23174.000000, request 304396.938324 08/24/2026 05:13:19.698 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8786 08/24/2026 05:13:19.698 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.698 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8786 (603.5504341125488 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=4167, last_stable_offset=4167, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10E\x00\x00\x01\xc5\x00\x00\x00\x00\x02\x90\x9e\x7fZ\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\x90\x03\x00\x00\x00\xd2\x02ObjectVNTable:default-domain:def...')])]) 08/24/2026 05:13:19.698 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 1 response partitions (0 implied) 08/24/2026 05:13:19.698 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 465 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 4165 08/24/2026 05:13:19.699 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4165 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) 08/24/2026 05:13:19.699 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 4167 (leader epoch 0) 08/24/2026 05:13:19.699 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 76072.416504, idle connection 14375.000000, request 304396.288395 08/24/2026 05:13:19.699 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8811 08/24/2026 05:13:19.699 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.700 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8811 (604.1176319122314 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5222, last_stable_offset=5222, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x14d\x00\x00\x01\xd8\x00\x00\x00\x00\x02\xba\x1c\x04\x99\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\xa6\x03\x00\x00\x00\xe8\x02ObjectXmppPeerInfo:cn-jenkins-de...')])]) 08/24/2026 05:13:19.700 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 1 response partitions (0 implied) 08/24/2026 05:13:19.700 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 484 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5220 08/24/2026 05:13:19.700 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5220 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 08/24/2026 05:13:19.700 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5222 (leader epoch 0) 08/24/2026 05:13:19.752 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:19.752 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:19.753 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:19.753 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:19.753 7faa5ef6d680 [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=1113797485, session_epoch=8404, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.753 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8421 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8404, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:19.753 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82244.647461, idle connection 322242.000000, request 304999.908924 08/24/2026 05:13:19.754 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82244.047119, idle connection 322242.000000, request 304999.326706 08/24/2026 05:13:19.800 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4167 08/24/2026 05:13:19.800 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:19.800 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:19.800 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:19.800 7faa5ef6dc20 [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=301296110, session_epoch=8773, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4167, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:19.800 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8787 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8773, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4167, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:19.800 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84313.443604, idle connection 23071.000000, request 304999.942303 08/24/2026 05:13:19.801 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5222 08/24/2026 05:13:19.801 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:19.801 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:19.801 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:19.801 7faa5ef6d5e0 [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=792964362, session_epoch=8792, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5222, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:19.801 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8812 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8792, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5222, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:19.802 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 75969.902344, idle connection 14272.000000, request 304999.950647 08/24/2026 05:13:19.802 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84311.798340, idle connection 23070.000000, request 304998.306513 08/24/2026 05:13:19.802 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 75969.093994, idle connection 14271.000000, request 304999.150038 08/24/2026 05:13:19.878 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82857.934814, idle connection 21941.000000, request 304398.781776 08/24/2026 05:13:19.879 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8236 08/24/2026 05:13:19.879 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.879 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8236 (601.8505096435547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:19.879 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:19.938 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84009.672363, idle connection 22375.000000, request 304397.449255 08/24/2026 05:13:19.938 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8271 08/24/2026 05:13:19.938 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.938 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8271 (603.3251285552979 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:19.939 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:19.939 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85284.458252, idle connection 23966.000000, request 304396.987915 08/24/2026 05:13:19.939 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8239 08/24/2026 05:13:19.939 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.939 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8239 (603.4953594207764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:19.940 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:19.982 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82951.565430, idle connection 21533.000000, request 304397.859097 08/24/2026 05:13:19.983 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8668 08/24/2026 05:13:19.983 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:19.983 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8668 (602.8578281402588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=3825, last_stable_offset=3825, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xf0\x00\x00\x01\x07\x00\x00\x00\x00\x02\xbe\x1a:\x85\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\xa8\x03\x00\x00\x00\xea\x02ObjectVNTable:default-domain:def...')])]) 08/24/2026 05:13:19.983 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 1 response partitions (0 implied) 08/24/2026 05:13:19.983 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 275 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 3824 08/24/2026 05:13:19.984 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3824 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) 08/24/2026 05:13:19.984 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 3825 (leader epoch 0) 08/24/2026 05:13:20.070 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:20.070 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:20.070 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:20.070 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:20.070 7faa5e5b22c0 [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=1952320670, session_epoch=8146, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.071 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8154 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8146, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.071 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84731.573975, idle connection 23265.000000, request 304999.913216 08/24/2026 05:13:20.071 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:20.071 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:20.072 7faa5e597cc0 [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)]) 08/24/2026 05:13:20.072 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:20.072 7faa5e597cc0 [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=307140566, session_epoch=8196, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.072 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8209 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8196, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.072 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83528.523682, idle connection 22057.000000, request 304999.946356 08/24/2026 05:13:20.072 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84730.061279, idle connection 23263.000000, request 304998.420238 08/24/2026 05:13:20.073 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83527.822266, idle connection 22056.000000, request 304999.261141 08/24/2026 05:13:20.085 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3825 08/24/2026 05:13:20.085 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:20.085 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:20.085 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:20.085 7faa5ef6dea0 [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=1429157710, session_epoch=8653, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3825, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:20.085 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8669 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8653, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3825, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:20.086 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82848.449951, idle connection 21430.000000, request 304999.922514 08/24/2026 05:13:20.086 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82847.930176, idle connection 21429.000000, request 304999.413490 08/24/2026 05:13:20.205 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3485 08/24/2026 05:13:20.205 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:20.205 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:20.205 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:20.205 7faa5ef6dcc0 [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=1101268060, session_epoch=8716, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.205 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8727 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8716, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.206 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78328.394775, idle connection 17281.000000, request 304999.936342 08/24/2026 05:13:20.206 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78327.887939, idle connection 17281.000000, request 304999.440670 08/24/2026 05:13:20.270 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80484.712158, idle connection 18454.000000, request 304398.613214 08/24/2026 05:13:20.271 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8805 08/24/2026 05:13:20.271 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.271 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8805 (602.048397064209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:20.271 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:20.297 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79432.994385, idle connection 18160.000000, request 304397.855043 08/24/2026 05:13:20.298 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8236 08/24/2026 05:13:20.299 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.299 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8236 (603.4858226776123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:20.299 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:20.355 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81643.330566, idle connection 321641.000000, request 304398.593426 08/24/2026 05:13:20.355 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8421 08/24/2026 05:13:20.355 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.355 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8421 (602.1785736083984 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:20.356 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:20.403 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83710.808350, idle connection 22469.000000, request 304397.299528 08/24/2026 05:13:20.404 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8787 08/24/2026 05:13:20.404 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.404 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8787 (603.4431457519531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[]) 08/24/2026 05:13:20.404 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 0 response partitions (1 implied) 08/24/2026 05:13:20.404 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 75367.129150, idle connection 13669.000000, request 304397.177935 08/24/2026 05:13:20.405 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8812 08/24/2026 05:13:20.405 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.405 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8812 (603.2869815826416 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[]) 08/24/2026 05:13:20.405 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 0 response partitions (1 implied) 08/24/2026 05:13:20.480 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:20.480 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:20.480 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:20.480 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:20.480 7faa5ef6d0e0 [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=2114138634, session_epoch=8219, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.480 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8237 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8219, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.480 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82255.806152, idle connection 21339.000000, request 304999.937773 08/24/2026 05:13:20.481 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82255.302490, idle connection 21339.000000, request 304999.445677 08/24/2026 05:13:20.539 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:20.540 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:20.540 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:20.540 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:20.540 7faa60327220 [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=818598925, session_epoch=8260, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.540 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8272 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8260, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.540 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83406.921875, idle connection 21773.000000, request 304999.941587 08/24/2026 05:13:20.541 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:20.541 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:20.541 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:20.541 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:20.541 7faa5ef6d220 [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=1674212408, session_epoch=8231, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.541 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8240 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8231, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.541 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84682.187012, idle connection 23364.000000, request 304999.958754 08/24/2026 05:13:20.542 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83405.515625, idle connection 21771.000000, request 304998.543978 08/24/2026 05:13:20.542 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84681.291260, idle connection 23363.000000, request 304999.068022 08/24/2026 05:13:20.673 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84129.063721, idle connection 22662.000000, request 304397.407293 08/24/2026 05:13:20.674 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8154 08/24/2026 05:13:20.674 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.674 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8154 (603.2958030700684 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:20.674 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:20.675 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82925.967773, idle connection 21455.000000, request 304397.401571 08/24/2026 05:13:20.675 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8209 08/24/2026 05:13:20.675 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.675 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8209 (602.9095649719238 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:20.675 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:20.687 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82247.236328, idle connection 20828.000000, request 304398.706675 08/24/2026 05:13:20.687 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8669 08/24/2026 05:13:20.687 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.687 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8669 (602.0083427429199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:20.688 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:20.807 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77727.314697, idle connection 16680.000000, request 304398.854256 08/24/2026 05:13:20.807 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8727 08/24/2026 05:13:20.807 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:20.807 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8727 (601.8667221069336 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=3486, last_stable_offset=3486, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\r\x9d\x00\x00\x00\xfe\x00\x00\x00\x00\x02\xd5=\xf8\xfe\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\x96\x03\x00\x00\x00\xd8\x02ObjectVNTable:default-domain:def...')])]) 08/24/2026 05:13:20.808 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 1 response partitions (0 implied) 08/24/2026 05:13:20.808 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 266 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 3485 08/24/2026 05:13:20.808 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3485 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) 08/24/2026 05:13:20.808 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 3486 (leader epoch 0) 08/24/2026 05:13:20.872 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:20.872 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:20.872 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:20.872 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:20.872 7faa5ef6d860 [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=224826165, session_epoch=8786, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.873 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8806 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8786, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.873 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79882.110596, idle connection 17852.000000, request 304999.920130 08/24/2026 05:13:20.874 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79881.448975, idle connection 17851.000000, request 304999.269724 08/24/2026 05:13:20.901 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:20.901 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:20.901 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:20.902 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:20.902 7faa60327040 [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=140424269, session_epoch=8228, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.902 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8237 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8228, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.902 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78828.374268, idle connection 17556.000000, request 304999.938250 08/24/2026 05:13:20.902 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78827.910645, idle connection 17555.000000, request 304999.485970 08/24/2026 05:13:20.909 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3486 08/24/2026 05:13:20.909 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:20.909 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-27', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:20.910 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:20.910 7faa5ef6dcc0 [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=1101268060, session_epoch=8717, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3486, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:20.910 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8728 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8717, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3486, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 08/24/2026 05:13:20.910 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77623.967773, idle connection 16577.000000, request 304999.942303 08/24/2026 05:13:20.910 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77623.529541, idle connection 16577.000000, request 304999.513865 08/24/2026 05:13:20.957 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:20.957 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:20.957 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:20.958 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:20.958 7faa5ef6d680 [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=1113797485, session_epoch=8405, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.958 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8422 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8405, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:20.958 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81039.893799, idle connection 321038.000000, request 304999.937057 08/24/2026 05:13:20.958 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81039.401855, idle connection 321037.000000, request 304999.455214 08/24/2026 05:13:21.005 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4167 08/24/2026 05:13:21.005 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:21.005 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:21.005 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:21.005 7faa5ef6dc20 [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=301296110, session_epoch=8774, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.005 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8788 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8774, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.006 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83108.417236, idle connection 21866.000000, request 304999.935150 08/24/2026 05:13:21.006 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5222 08/24/2026 05:13:21.006 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:21.006 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:21.006 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:21.006 7faa5ef6d5e0 [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=792964362, session_epoch=8793, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.006 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8813 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8793, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.006 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74765.295410, idle connection 13068.000000, request 304999.959469 08/24/2026 05:13:21.007 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83107.209473, idle connection 21865.000000, request 304998.739481 08/24/2026 05:13:21.007 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74764.500000, idle connection 13067.000000, request 304999.169111 08/24/2026 05:13:21.082 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81654.517334, idle connection 20738.000000, request 304398.641586 08/24/2026 05:13:21.082 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8237 08/24/2026 05:13:21.082 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.083 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8237 (602.0786762237549 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:21.083 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:21.143 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82804.446289, idle connection 21170.000000, request 304397.460938 08/24/2026 05:13:21.143 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8272 08/24/2026 05:13:21.143 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.143 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8272 (603.1904220581055 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[]) 08/24/2026 05:13:21.144 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 818598925 with 0 response partitions (1 implied) 08/24/2026 05:13:21.144 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84079.541504, idle connection 22761.000000, request 304397.314072 08/24/2026 05:13:21.144 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8240 08/24/2026 05:13:21.144 7faa5ef6d220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.144 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8240 (603.0077934265137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674212408, topics=[]) 08/24/2026 05:13:21.144 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1674212408 with 0 response partitions (1 implied) 08/24/2026 05:13:21.275 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 08/24/2026 05:13:21.275 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 08/24/2026 05:13:21.276 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 08/24/2026 05:13:21.276 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:21.276 7faa5e5b22c0 [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=1952320670, session_epoch=8147, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.276 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8155 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1952320670, session_epoch=8147, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.276 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83526.442627, idle connection 22060.000000, request 304999.931335 08/24/2026 05:13:21.276 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 200 08/24/2026 05:13:21.276 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 08/24/2026 05:13:21.276 7faa5e597cc0 [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)]) 08/24/2026 05:13:21.277 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:21.277 7faa5e597cc0 [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=307140566, session_epoch=8197, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.277 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8210 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=307140566, session_epoch=8197, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.277 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82323.759277, idle connection 20852.000000, request 304999.962091 08/24/2026 05:13:21.277 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83525.305664, idle connection 22058.000000, request 304998.805285 08/24/2026 05:13:21.277 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82323.058838, idle connection 20852.000000, request 304999.264717 08/24/2026 05:13:21.289 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3825 08/24/2026 05:13:21.289 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 08/24/2026 05:13:21.289 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 08/24/2026 05:13:21.289 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:21.289 7faa5ef6dea0 [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=1429157710, session_epoch=8654, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.289 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8670 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1429157710, session_epoch=8654, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.290 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81644.392578, idle connection 20226.000000, request 304999.938250 08/24/2026 05:13:21.291 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81643.139648, idle connection 20224.000000, request 304998.698235 08/24/2026 05:13:21.475 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79279.693359, idle connection 17249.000000, request 304397.513151 08/24/2026 05:13:21.476 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8806 08/24/2026 05:13:21.476 7faa5ef6d860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.476 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8806 (603.2834053039551 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=224826165, topics=[]) 08/24/2026 05:13:21.476 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 224826165 with 0 response partitions (1 implied) 08/24/2026 05:13:21.503 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78227.215576, idle connection 16954.000000, request 304398.777008 08/24/2026 05:13:21.504 7faa60327040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8237 08/24/2026 05:13:21.504 7faa60327040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.504 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8237 (601.891279220581 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=140424269, topics=[]) 08/24/2026 05:13:21.504 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 140424269 with 0 response partitions (1 implied) 08/24/2026 05:13:21.511 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77022.920654, idle connection 15976.000000, request 304398.885489 08/24/2026 05:13:21.512 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8728 08/24/2026 05:13:21.512 7faa5ef6dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.512 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8728 (601.8667221069336 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1101268060, topics=[]) 08/24/2026 05:13:21.512 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1101268060 with 0 response partitions (1 implied) 08/24/2026 05:13:21.559 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80438.699463, idle connection 320437.000000, request 304398.739815 08/24/2026 05:13:21.560 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8422 08/24/2026 05:13:21.560 7faa5ef6d680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.560 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8422 (602.1316051483154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1113797485, topics=[]) 08/24/2026 05:13:21.560 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1113797485 with 0 response partitions (1 implied) 08/24/2026 05:13:21.608 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82506.215332, idle connection 21264.000000, request 304397.725344 08/24/2026 05:13:21.608 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8788 08/24/2026 05:13:21.608 7faa5ef6dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.609 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8788 (603.0759811401367 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=301296110, topics=[]) 08/24/2026 05:13:21.609 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 301296110 with 0 response partitions (1 implied) 08/24/2026 05:13:21.609 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74162.555908, idle connection 12465.000000, request 304397.216082 08/24/2026 05:13:21.609 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8813 08/24/2026 05:13:21.609 7faa5ef6d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.609 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8813 (603.2161712646484 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=792964362, topics=[]) 08/24/2026 05:13:21.610 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 792964362 with 0 response partitions (1 implied) 08/24/2026 05:13:21.685 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 372 08/24/2026 05:13:21.685 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 08/24/2026 05:13:21.685 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 08/24/2026 05:13:21.685 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:21.685 7faa5ef6d0e0 [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=2114138634, session_epoch=8220, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.685 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8238 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2114138634, session_epoch=8220, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.686 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81050.535889, idle connection 20134.000000, request 304999.920368 08/24/2026 05:13:21.686 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81049.873779, idle connection 20133.000000, request 304999.276161 08/24/2026 05:13:21.744 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 450 08/24/2026 05:13:21.745 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 08/24/2026 05:13:21.745 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 08/24/2026 05:13:21.745 7faa60327220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:21.745 7faa60327220 [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=818598925, session_epoch=8261, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.745 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8273 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=818598925, session_epoch=8261, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.745 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82201.918945, idle connection 20568.000000, request 304999.937057 08/24/2026 05:13:21.746 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82201.426514, idle connection 20567.000000, request 304999.454737 08/24/2026 05:13:21.746 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 298 08/24/2026 05:13:21.746 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 08/24/2026 05:13:21.746 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 08/24/2026 05:13:21.746 7faa5ef6d220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:21.746 7faa5ef6d220 [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=1674212408, session_epoch=8232, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.746 7faa5ef6d220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8241 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674212408, session_epoch=8232, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:21.747 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83476.880371, idle connection 22159.000000, request 304999.961615 08/24/2026 05:13:21.747 7faa5ef6d220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83476.452881, idle connection 22158.000000, request 304999.536991 08/24/2026 05:13:21.878 7faa5e5b22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82924.345459, idle connection 21457.000000, request 304397.829533 08/24/2026 05:13:21.879 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8155 08/24/2026 05:13:21.879 7faa5e5b22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.879 7faa5e5b22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8155 (602.8313636779785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1952320670, topics=[]) 08/24/2026 05:13:21.879 7faa5e5b22c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1952320670 with 0 response partitions (1 implied) 08/24/2026 05:13:21.879 7faa5e597cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81721.268555, idle connection 20250.000000, request 304397.470951 08/24/2026 05:13:21.879 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8210 08/24/2026 05:13:21.880 7faa5e597cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.880 7faa5e597cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Response 8210 (602.8430461883545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=307140566, topics=[]) 08/24/2026 05:13:21.880 7faa5e597cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 307140566 with 0 response partitions (1 implied) 08/24/2026 05:13:21.893 7faa5ef6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81041.465088, idle connection 19623.000000, request 304397.014380 08/24/2026 05:13:21.893 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8670 08/24/2026 05:13:21.893 7faa5ef6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:21.893 7faa5ef6dea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8670 (603.541374206543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1429157710, topics=[]) 08/24/2026 05:13:21.893 7faa5ef6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1429157710 with 0 response partitions (1 implied) 08/24/2026 05:13:22.077 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 3638 08/24/2026 05:13:22.078 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 08/24/2026 05:13:22.078 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 08/24/2026 05:13:22.078 7faa5ef6d860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:22.078 7faa5ef6d860 [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=224826165, session_epoch=8787, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.078 7faa5ef6d860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8807 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=224826165, session_epoch=8787, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.078 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78676.589355, idle connection 16646.000000, request 304999.922037 08/24/2026 05:13:22.079 7faa5ef6d860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 78676.007080, idle connection 16646.000000, request 304999.363661 08/24/2026 05:13:22.106 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 323 08/24/2026 05:13:22.106 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 08/24/2026 05:13:22.106 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 08/24/2026 05:13:22.106 7faa60327040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:22.106 7faa60327040 [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=140424269, session_epoch=8229, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.107 7faa60327040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8238 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=140424269, session_epoch=8229, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.107 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77623.450684, idle connection 16351.000000, request 304999.922276 08/24/2026 05:13:22.108 7faa60327040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 77622.804443, idle connection 16350.000000, request 304999.287605 08/24/2026 05:13:22.114 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3486 08/24/2026 05:13:22.114 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 08/24/2026 05:13:22.114 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 08/24/2026 05:13:22.115 7faa5ef6dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 08/24/2026 05:13:22.115 7faa5ef6dcc0 [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=1101268060, session_epoch=8718, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.115 7faa5ef6dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Request 8729 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1101268060, session_epoch=8718, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.115 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 76418.737549, idle connection 15372.000000, request 304999.914408 08/24/2026 05:13:22.116 7faa5ef6dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 76418.114746, idle connection 15371.000000, request 304999.304295 08/24/2026 05:13:22.162 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 1126 08/24/2026 05:13:22.163 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 08/24/2026 05:13:22.163 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 08/24/2026 05:13:22.163 7faa5ef6d680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:22.163 7faa5ef6d680 [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=1113797485, session_epoch=8406, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.163 7faa5ef6d680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8423 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1113797485, session_epoch=8406, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.163 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79834.461426, idle connection 319832.000000, request 304999.940157 08/24/2026 05:13:22.164 7faa5ef6d680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79833.934326, idle connection 319832.000000, request 304999.420166 08/24/2026 05:13:22.210 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4167 08/24/2026 05:13:22.211 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 08/24/2026 05:13:22.211 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 08/24/2026 05:13:22.211 7faa5ef6dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 08/24/2026 05:13:22.211 7faa5ef6dc20 [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=301296110, session_epoch=8775, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.211 7faa5ef6dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Request 8789 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=301296110, session_epoch=8775, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.211 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81902.500488, idle connection 20660.000000, request 304999.924183 08/24/2026 05:13:22.212 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5222 08/24/2026 05:13:22.212 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 08/24/2026 05:13:22.212 7faa5ef6d5e0 [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)]) 08/24/2026 05:13:22.212 7faa5ef6d5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 08/24/2026 05:13:22.212 7faa5ef6d5e0 [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=792964362, session_epoch=8794, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.212 7faa5ef6d5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.50', 9092)]>: Request 8814 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=792964362, session_epoch=8794, topics=[], forgotten_topics_data=[]) 08/24/2026 05:13:22.212 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73559.073486, idle connection 11861.000000, request 304999.941111 08/24/2026 05:13:22.213 7faa5ef6dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81900.844727, idle connection 20659.000000, request 304998.281717 08/24/2026 05:13:22.213 7faa5ef6d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73558.057861, idle connection 11860.000000, request 304998.931885 08/24/2026 05:13:22.288 7faa5ef6d0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80448.600342, idle connection 19532.000000, request 304397.942305 08/24/2026 05:13:22.288 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8238 08/24/2026 05:13:22.288 7faa5ef6d0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:22.288 7faa5ef6d0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.190', 9092)]>: Response 8238 (602.5946140289307 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2114138634, topics=[]) 08/24/2026 05:13:22.288 7faa5ef6d0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2114138634 with 0 response partitions (1 implied) 08/24/2026 05:13:22.347 7faa60327220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81600.069580, idle connection 19966.000000, request 304398.089409 08/24/2026 05:13:22.348 7faa60327220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8273 08/24/2026 05:13:22.348 7faa60327220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 08/24/2026 05:13:22.348 7faa60327220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.191', 9092)]>: Response 8273 (602.4823188781738 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=818598925, topics=[])