09/07/2026 05:11:08.554 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:08.556 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:08.556 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:08.556 7faf2fc47540 [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=543640748, session_epoch=8414, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.556 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8439 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8414, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.556 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184999.428467, idle connection 123787.000000, request 304999.941587 09/07/2026 05:11:08.557 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184998.930420, idle connection 123786.000000, request 304999.452353 09/07/2026 05:11:08.675 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4481 09/07/2026 05:11:08.675 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:08.675 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:08.675 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:08.675 7faf32415220 [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=933867180, session_epoch=8975, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.675 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8990 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8975, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.676 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183014.583008, idle connection 122092.000000, request 304999.935627 09/07/2026 05:11:08.676 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183014.062256, idle connection 122091.000000, request 304999.425173 09/07/2026 05:11:08.686 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182152.126953, idle connection 120802.000000, request 304398.758411 09/07/2026 05:11:08.687 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9190 09/07/2026 05:11:08.687 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:08.687 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9190 (602.0321846008301 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5765, last_stable_offset=5765, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x16\x84\x00\x00\x01!\x00\x00\x00\x00\x02{z\xf1\x13\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xdc\x03\x00\x00\x00\x9e\x03ObjectGeneratorInfo:an-jenkins-d...')])]) 09/07/2026 05:11:08.687 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 1 response partitions (0 implied) 09/07/2026 05:11:08.688 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 301 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5764 09/07/2026 05:11:08.688 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5764 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 09/07/2026 05:11:08.688 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5765 (leader epoch 0) 09/07/2026 05:11:08.770 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:08.770 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:08.770 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:08.770 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:08.770 7faf2fc47680 [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=1136012074, session_epoch=8382, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.770 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8397 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8382, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.771 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183713.760254, idle connection 58757.000000, request 304999.922276 09/07/2026 05:11:08.771 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183713.280029, idle connection 58757.000000, request 304999.453545 09/07/2026 05:11:08.789 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5765 09/07/2026 05:11:08.789 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:08.789 7faf324155e0 [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)]) 09/07/2026 05:11:08.789 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:08.789 7faf324155e0 [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=1341819554, session_epoch=9179, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5765, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:08.789 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9191 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9179, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5765, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:08.790 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182048.677002, idle connection 120698.000000, request 304999.939680 09/07/2026 05:11:08.790 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182048.198486, idle connection 120698.000000, request 304999.471188 09/07/2026 05:11:08.880 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:08.880 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:08.880 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:08.880 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:08.880 7faf2fc47cc0 [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=983615111, session_epoch=8538, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.880 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8560 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8538, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:08.881 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182745.184082, idle connection 298297.000000, request 304999.938726 09/07/2026 05:11:08.881 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182744.729736, idle connection 298297.000000, request 304999.495506 09/07/2026 05:11:08.973 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184322.670898, idle connection 252.000000, request 304398.481607 09/07/2026 05:11:08.974 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8423 09/07/2026 05:11:08.974 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:08.974 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8423 (602.4284362792969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:08.974 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:09.073 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180654.635254, idle connection 119514.000000, request 304396.761179 09/07/2026 05:11:09.074 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9150 09/07/2026 05:11:09.074 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.074 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9150 (603.9013862609863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=5234, last_stable_offset=5234, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x14q\x00\x00\x013\x00\x00\x00\x00\x02\xda\xb0p\xd0\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x80\x04\x00\x00\x00\xc2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:09.074 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 1 response partitions (0 implied) 09/07/2026 05:11:09.075 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 319 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 5233 09/07/2026 05:11:09.075 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5233 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 09/07/2026 05:11:09.075 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 5234 (leader epoch 0) 09/07/2026 05:11:09.075 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 186121.667969, idle connection 61564.000000, request 304396.232128 09/07/2026 05:11:09.075 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8677 09/07/2026 05:11:09.075 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.076 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8677 (604.2068004608154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:09.076 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:09.157 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184398.302246, idle connection 123186.000000, request 304398.811102 09/07/2026 05:11:09.158 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8439 09/07/2026 05:11:09.158 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.158 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8439 (601.8226146697998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:09.158 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:09.176 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5234 09/07/2026 05:11:09.176 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:09.176 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:09.176 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:09.176 7faf32415c20 [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=1459767967, session_epoch=9131, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5234, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.176 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9151 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9131, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5234, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.176 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180551.721680, idle connection 119411.000000, request 304999.936819 09/07/2026 05:11:09.177 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180551.144287, idle connection 119410.000000, request 304999.371529 09/07/2026 05:11:09.277 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182413.433105, idle connection 121491.000000, request 304398.786068 09/07/2026 05:11:09.277 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8990 09/07/2026 05:11:09.277 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.277 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8990 (601.923942565918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=4483, last_stable_offset=4483, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11\x81\x00\x00\x023\x00\x00\x00\x00\x02R\xcb\xb2\xf5\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\x80\x04\x00\x00\x00\xc2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:09.278 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 1 response partitions (0 implied) 09/07/2026 05:11:09.278 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 575 bytes of data for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 4481 09/07/2026 05:11:09.278 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4481 for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) 09/07/2026 05:11:09.278 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) to 4483 (leader epoch 0) 09/07/2026 05:11:09.372 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183112.631836, idle connection 58156.000000, request 304398.792028 09/07/2026 05:11:09.372 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8397 09/07/2026 05:11:09.372 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.372 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8397 (601.881742477417 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:09.373 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:09.379 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4483 09/07/2026 05:11:09.379 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:09.379 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-20', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:09.379 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:09.379 7faf32415220 [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=933867180, session_epoch=8976, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4483, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.379 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8991 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8976, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4483, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.380 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182310.549561, idle connection 121388.000000, request 304999.941111 09/07/2026 05:11:09.380 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182310.094727, idle connection 121387.000000, request 304999.492884 09/07/2026 05:11:09.391 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181447.708496, idle connection 120097.000000, request 304398.976803 09/07/2026 05:11:09.391 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9191 09/07/2026 05:11:09.391 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.391 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9191 (601.5293598175049 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5766, last_stable_offset=5766, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x16\x85\x00\x00\x013\x00\x00\x00\x00\x02\x04\xc9O8\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x80\x04\x00\x00\x00\xc2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:09.391 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 1 response partitions (0 implied) 09/07/2026 05:11:09.391 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 319 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5765 09/07/2026 05:11:09.391 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5765 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 09/07/2026 05:11:09.392 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5766 (leader epoch 0) 09/07/2026 05:11:09.482 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182144.223633, idle connection 297696.000000, request 304398.977995 09/07/2026 05:11:09.482 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8560 09/07/2026 05:11:09.482 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.482 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8560 (601.6190052032471 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:09.482 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:09.492 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5766 09/07/2026 05:11:09.492 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:09.493 7faf324155e0 [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)]) 09/07/2026 05:11:09.493 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:09.493 7faf324155e0 [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=1341819554, session_epoch=9180, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5766, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.493 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9192 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9180, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5766, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.493 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181345.154297, idle connection 119995.000000, request 304999.943733 09/07/2026 05:11:09.494 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181344.657471, idle connection 119994.000000, request 304999.453545 09/07/2026 05:11:09.575 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:09.576 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:09.576 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:09.576 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:09.576 7faf324150e0 [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=1706742470, session_epoch=8404, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.576 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8424 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8404, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.576 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183719.347168, idle connection 0.000000, request 304999.917746 09/07/2026 05:11:09.577 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183718.851318, idle connection 539396.000000, request 304999.433994 09/07/2026 05:11:09.677 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:09.677 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:09.677 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:09.677 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:09.677 7faf3027fc20 [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=1427528239, session_epoch=8661, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.678 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8678 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8661, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.678 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 185519.122070, idle connection 60961.000000, request 304999.941349 09/07/2026 05:11:09.678 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 185518.533936, idle connection 60961.000000, request 304999.363422 09/07/2026 05:11:09.759 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:09.759 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:09.759 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:09.759 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:09.759 7faf2fc47540 [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=543640748, session_epoch=8415, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.759 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8440 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8415, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.760 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183796.120361, idle connection 122584.000000, request 304999.936342 09/07/2026 05:11:09.760 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183795.648926, idle connection 122583.000000, request 304999.476433 09/07/2026 05:11:09.779 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179949.269531, idle connection 118808.000000, request 304397.489786 09/07/2026 05:11:09.779 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9151 09/07/2026 05:11:09.779 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.779 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9151 (603.1298637390137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=5236, last_stable_offset=5236, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x14r\x00\x00\x01 \x00\x00\x00\x00\x02`\xf5\xd9\xe2\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:09.780 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 1 response partitions (0 implied) 09/07/2026 05:11:09.780 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 602 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 5234 09/07/2026 05:11:09.780 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5234 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 09/07/2026 05:11:09.780 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 5236 (leader epoch 0) 09/07/2026 05:11:09.881 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5236 09/07/2026 05:11:09.881 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:09.882 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:09.882 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:09.882 7faf32415c20 [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=1459767967, session_epoch=9132, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5236, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.882 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9152 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9132, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5236, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:09.882 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179845.897705, idle connection 118705.000000, request 304999.925375 09/07/2026 05:11:09.883 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179845.265869, idle connection 118704.000000, request 304999.306202 09/07/2026 05:11:09.973 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:09.973 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:09.973 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:09.974 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:09.974 7faf2fc47680 [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=1136012074, session_epoch=8383, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.974 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8398 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8383, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:09.974 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182510.403809, idle connection 57554.000000, request 304999.938250 09/07/2026 05:11:09.974 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182509.936035, idle connection 57554.000000, request 304999.480963 09/07/2026 05:11:09.980 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181709.726807, idle connection 120787.000000, request 304399.124146 09/07/2026 05:11:09.981 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8991 09/07/2026 05:11:09.981 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:09.981 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8991 (601.3755798339844 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=4487, last_stable_offset=4487, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11\x83\x00\x00\x02\x1b\x00\x00\x00\x00\x02Z\xbbft\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\x82\x04\x00\x00\x00\xc4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:09.981 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 1 response partitions (0 implied) 09/07/2026 05:11:09.981 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1099 bytes of data for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 4483 09/07/2026 05:11:09.981 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4483 for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) 09/07/2026 05:11:09.982 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) to 4487 (leader epoch 0) 09/07/2026 05:11:10.083 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4487 09/07/2026 05:11:10.083 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:10.083 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-20', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:10.083 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:10.083 7faf32415220 [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=933867180, session_epoch=8977, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4487, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.084 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8992 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8977, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4487, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.084 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181606.321533, idle connection 120683.000000, request 304999.909878 09/07/2026 05:11:10.084 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:10.084 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:10.084 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:10.085 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:10.085 7faf2fc47cc0 [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=983615111, session_epoch=8539, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.085 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8561 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8539, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.085 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181540.912354, idle connection 297093.000000, request 304999.941111 09/07/2026 05:11:10.085 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181604.817627, idle connection 120682.000000, request 304998.425245 09/07/2026 05:11:10.086 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181540.107422, idle connection 297092.000000, request 304999.146223 09/07/2026 05:11:10.094 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180744.282471, idle connection 119394.000000, request 304399.078369 09/07/2026 05:11:10.094 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9192 09/07/2026 05:11:10.094 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.094 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9192 (601.3741493225098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5768, last_stable_offset=5768, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x16\x86\x00\x00\x01"\x00\x00\x00\x00\x02x1~Q\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\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:an-jenkins-d...')])]) 09/07/2026 05:11:10.095 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 1 response partitions (0 implied) 09/07/2026 05:11:10.095 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 611 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5766 09/07/2026 05:11:10.095 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5766 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 09/07/2026 05:11:10.095 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5768 (leader epoch 0) 09/07/2026 05:11:10.178 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183117.462891, idle connection 538795.000000, request 304398.033857 09/07/2026 05:11:10.179 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8424 09/07/2026 05:11:10.179 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.179 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8424 (602.7977466583252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:10.179 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:10.196 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5768 09/07/2026 05:11:10.196 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:10.196 7faf324155e0 [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)]) 09/07/2026 05:11:10.196 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:10.196 7faf324155e0 [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=1341819554, session_epoch=9181, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5768, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.197 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9193 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9181, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5768, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.197 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180641.367676, idle connection 119291.000000, request 304999.926567 09/07/2026 05:11:10.197 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180640.870605, idle connection 119290.000000, request 304999.442101 09/07/2026 05:11:10.279 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184917.933594, idle connection 60360.000000, request 304398.753166 09/07/2026 05:11:10.279 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8678 09/07/2026 05:11:10.279 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.280 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8678 (601.9880771636963 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:10.280 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:10.361 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183194.974609, idle connection 121982.000000, request 304398.788929 09/07/2026 05:11:10.361 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8440 09/07/2026 05:11:10.361 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.361 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8440 (601.841926574707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:10.361 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:10.483 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179244.655029, idle connection 118104.000000, request 304398.685694 09/07/2026 05:11:10.484 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9152 09/07/2026 05:11:10.484 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.484 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9152 (601.9752025604248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=5237, last_stable_offset=5237, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x14t\x00\x00\x01*\x00\x00\x00\x00\x02\xb8k\xb9\xc3\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xee\x03\x00\x00\x00\xb0\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:10.484 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 1 response partitions (0 implied) 09/07/2026 05:11:10.485 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 310 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 5236 09/07/2026 05:11:10.485 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5236 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 09/07/2026 05:11:10.485 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 5237 (leader epoch 0) 09/07/2026 05:11:10.575 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181909.245605, idle connection 56953.000000, request 304398.779154 09/07/2026 05:11:10.576 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8398 09/07/2026 05:11:10.576 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.576 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8398 (601.8400192260742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:10.576 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:10.586 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5237 09/07/2026 05:11:10.586 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:10.586 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:10.586 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:10.586 7faf32415c20 [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=1459767967, session_epoch=9133, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5237, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.586 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9153 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9133, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5237, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.586 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179141.866211, idle connection 118001.000000, request 304999.943495 09/07/2026 05:11:10.587 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179141.360107, idle connection 118000.000000, request 304999.442339 09/07/2026 05:11:10.686 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181003.969482, idle connection 120081.000000, request 304397.563934 09/07/2026 05:11:10.687 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8992 09/07/2026 05:11:10.687 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.687 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8992 (603.1556129455566 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=4490, last_stable_offset=4490, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11\x87\x00\x00\x01\x18\x00\x00\x00\x00\x02\xbd\x1f3I\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\xca\x03\x00\x00\x00\x8c\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:10.687 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 1 response partitions (0 implied) 09/07/2026 05:11:10.687 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 880 bytes of data for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 4487 09/07/2026 05:11:10.687 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4487 for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) 09/07/2026 05:11:10.688 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) to 4490 (leader epoch 0) 09/07/2026 05:11:10.688 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180937.768066, idle connection 296490.000000, request 304396.802425 09/07/2026 05:11:10.688 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8561 09/07/2026 05:11:10.688 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.689 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8561 (603.6427021026611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:10.689 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:10.780 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:10.781 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:10.781 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:10.781 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:10.781 7faf324150e0 [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=1706742470, session_epoch=8405, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.781 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8425 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8405, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.781 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182514.241699, idle connection 538192.000000, request 304999.922037 09/07/2026 05:11:10.782 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182513.690918, idle connection 538191.000000, request 304999.382019 09/07/2026 05:11:10.788 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4490 09/07/2026 05:11:10.789 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:10.789 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-20', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:10.789 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:10.789 7faf32415220 [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=933867180, session_epoch=8978, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4490, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.789 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8993 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8978, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4490, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.789 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180900.880127, idle connection 119978.000000, request 304999.923229 09/07/2026 05:11:10.790 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180900.301025, idle connection 119977.000000, request 304999.346972 09/07/2026 05:11:10.798 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180040.336426, idle connection 118690.000000, request 304398.904085 09/07/2026 05:11:10.798 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9193 09/07/2026 05:11:10.798 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:10.799 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9193 (601.707935333252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5775, last_stable_offset=5775, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x16\x88\x00\x00\x01"\x00\x00\x00\x00\x02D\xea\x15\x9e\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\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:an-jenkins-d...')])]) 09/07/2026 05:11:10.799 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 1 response partitions (0 implied) 09/07/2026 05:11:10.799 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 2050 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5768 09/07/2026 05:11:10.799 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5768 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 09/07/2026 05:11:10.800 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5775 (leader epoch 0) 09/07/2026 05:11:10.881 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:10.882 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:10.882 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:10.882 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:10.882 7faf3027fc20 [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=1427528239, session_epoch=8662, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.882 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8679 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8662, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.882 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184314.698730, idle connection 59757.000000, request 304999.938250 09/07/2026 05:11:10.883 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 184314.058594, idle connection 59756.000000, request 304999.308825 09/07/2026 05:11:10.901 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5775 09/07/2026 05:11:10.901 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:10.901 7faf324155e0 [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)]) 09/07/2026 05:11:10.901 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:10.901 7faf324155e0 [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=1341819554, session_epoch=9182, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5775, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.902 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9194 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9182, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5775, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:10.902 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179936.498779, idle connection 118586.000000, request 304999.943256 09/07/2026 05:11:10.902 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179936.025146, idle connection 118585.000000, request 304999.476433 09/07/2026 05:11:10.963 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:10.963 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:10.963 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:10.963 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:10.963 7faf2fc47540 [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=543640748, session_epoch=8416, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.964 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8441 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8416, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:10.964 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182591.887451, idle connection 121379.000000, request 304999.933720 09/07/2026 05:11:10.964 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182591.382080, idle connection 121379.000000, request 304999.438047 09/07/2026 05:11:11.176 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:11.177 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:11.177 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:11.177 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:11.177 7faf2fc47680 [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=1136012074, session_epoch=8384, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.177 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8399 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8384, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.177 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181307.067627, idle connection 56351.000000, request 304999.940157 09/07/2026 05:11:11.178 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181306.596436, idle connection 56350.000000, request 304999.478817 09/07/2026 05:11:11.188 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178539.712891, idle connection 117399.000000, request 304397.789478 09/07/2026 05:11:11.189 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9153 09/07/2026 05:11:11.189 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.189 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9153 (602.724552154541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:11.189 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:11.290 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:11.290 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:11.290 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:11.290 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:11.290 7faf2fc47cc0 [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=983615111, session_epoch=8540, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.290 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8562 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8540, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.290 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180335.330078, idle connection 295887.000000, request 304999.935865 09/07/2026 05:11:11.291 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180334.860840, idle connection 295887.000000, request 304999.479294 09/07/2026 05:11:11.383 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181913.004150, idle connection 537590.000000, request 304398.684025 09/07/2026 05:11:11.383 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8425 09/07/2026 05:11:11.383 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.383 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8425 (602.0140647888184 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:11.384 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:11.391 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180298.775391, idle connection 119376.000000, request 304397.818565 09/07/2026 05:11:11.392 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8993 09/07/2026 05:11:11.392 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.392 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8993 (602.5948524475098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:11.392 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:11.484 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183712.704590, idle connection 59155.000000, request 304397.942543 09/07/2026 05:11:11.485 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8679 09/07/2026 05:11:11.485 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.485 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8679 (602.7019023895264 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:11.485 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:11.503 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179334.950928, idle connection 117984.000000, request 304398.386955 09/07/2026 05:11:11.504 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9194 09/07/2026 05:11:11.504 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.504 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9194 (602.2164821624756 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:11.504 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:11.566 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181989.974121, idle connection 120777.000000, request 304398.019791 09/07/2026 05:11:11.566 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8441 09/07/2026 05:11:11.566 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.566 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8441 (602.6561260223389 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:11.567 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:11.779 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180705.209473, idle connection 55749.000000, request 304398.080349 09/07/2026 05:11:11.780 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8399 09/07/2026 05:11:11.780 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.780 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8399 (602.5769710540771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:11.780 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:11.790 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5237 09/07/2026 05:11:11.791 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:11.791 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:11.791 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:11.791 7faf32415c20 [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=1459767967, session_epoch=9134, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.791 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9154 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9134, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.791 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177937.054932, idle connection 116796.000000, request 304999.942541 09/07/2026 05:11:11.792 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177936.528809, idle connection 116796.000000, request 304999.424934 09/07/2026 05:11:11.891 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179734.357666, idle connection 295286.000000, request 304398.967743 09/07/2026 05:11:11.892 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8562 09/07/2026 05:11:11.892 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:11.892 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8562 (601.6006469726562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:11.892 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:11.984 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:11.984 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:11.984 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:11.984 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:11.984 7faf324150e0 [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=1706742470, session_epoch=8406, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.985 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8426 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8406, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.985 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181310.927002, idle connection 536988.000000, request 304999.941587 09/07/2026 05:11:11.985 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181310.501465, idle connection 536988.000000, request 304999.523878 09/07/2026 05:11:11.992 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4490 09/07/2026 05:11:11.992 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:11.992 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:11.993 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:11.993 7faf32415220 [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=933867180, session_epoch=8979, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.993 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8994 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8979, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:11.993 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179697.267578, idle connection 118774.000000, request 304999.952555 09/07/2026 05:11:11.993 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179696.810547, idle connection 118774.000000, request 304999.498606 09/07/2026 05:11:12.086 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:12.086 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:12.086 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:12.087 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:12.087 7faf3027fc20 [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=1427528239, session_epoch=8663, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.087 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8663, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.087 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183109.906250, idle connection 58552.000000, request 304999.942780 09/07/2026 05:11:12.087 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 183109.493408, idle connection 58552.000000, request 304999.537230 09/07/2026 05:11:12.105 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5775 09/07/2026 05:11:12.106 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:12.106 7faf324155e0 [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)]) 09/07/2026 05:11:12.106 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:12.106 7faf324155e0 [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=1341819554, session_epoch=9183, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.106 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9195 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9183, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.106 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178732.113770, idle connection 117382.000000, request 304999.946117 09/07/2026 05:11:12.107 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178731.714600, idle connection 117381.000000, request 304999.552250 09/07/2026 05:11:12.168 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:12.168 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:12.168 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:12.168 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:12.168 7faf2fc47540 [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=543640748, session_epoch=8417, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.168 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8442 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8417, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.168 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181387.143555, idle connection 120175.000000, request 304999.943495 09/07/2026 05:11:12.169 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181386.713379, idle connection 120174.000000, request 304999.520302 09/07/2026 05:11:12.380 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:12.381 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:12.381 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:12.381 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:12.381 7faf2fc47680 [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=1136012074, session_epoch=8385, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.381 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8400 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8385, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.381 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180103.052734, idle connection 55147.000000, request 304999.938726 09/07/2026 05:11:12.382 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180102.566162, idle connection 55146.000000, request 304999.462128 09/07/2026 05:11:12.393 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177335.546631, idle connection 116195.000000, request 304398.440123 09/07/2026 05:11:12.393 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9154 09/07/2026 05:11:12.393 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.393 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9154 (602.0700931549072 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=5240, last_stable_offset=5240, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x14u\x00\x00\x04:\x00\x00\x00\x00\x02\x14?\xd1\x12\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...')])]) 09/07/2026 05:11:12.393 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 1 response partitions (0 implied) 09/07/2026 05:11:12.393 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1094 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 5237 09/07/2026 05:11:12.394 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5237 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 09/07/2026 05:11:12.394 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 5240 (leader epoch 0) 09/07/2026 05:11:12.493 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:12.494 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:12.494 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:12.494 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:12.494 7faf2fc47cc0 [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=983615111, session_epoch=8541, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.494 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8563 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8541, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:12.494 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179131.718750, idle connection 294684.000000, request 304999.937773 09/07/2026 05:11:12.495 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:12.495 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:12.495 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:12.495 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:12.495 7faf32415c20 [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=1459767967, session_epoch=9135, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5240, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:12.495 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9155 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9135, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5240, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:12.495 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177232.812500, idle connection 116092.000000, request 304999.957800 09/07/2026 05:11:12.496 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179130.126709, idle connection 294682.000000, request 304998.358250 09/07/2026 05:11:12.496 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177232.079590, idle connection 116091.000000, request 304999.230385 09/07/2026 05:11:12.586 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180709.909424, idle connection 536387.000000, request 304398.921013 09/07/2026 05:11:12.586 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8426 09/07/2026 05:11:12.586 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.586 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8426 (601.752519607544 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:12.587 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:12.594 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179096.360596, idle connection 118173.000000, request 304399.038553 09/07/2026 05:11:12.594 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8994 09/07/2026 05:11:12.594 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.594 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8994 (601.5157699584961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=4492, last_stable_offset=4492, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11\x8a\x00\x00\x01\x17\x00\x00\x00\x00\x02/\xfeF\xf6\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/07/2026 05:11:12.595 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 1 response partitions (0 implied) 09/07/2026 05:11:12.595 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 582 bytes of data for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 4490 09/07/2026 05:11:12.595 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4490 for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) 09/07/2026 05:11:12.595 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) to 4492 (leader epoch 0) 09/07/2026 05:11:12.688 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 182508.992432, idle connection 57951.000000, request 304399.025440 09/07/2026 05:11:12.688 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8680 09/07/2026 05:11:12.688 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.689 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8680 (601.7341613769531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:12.689 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:12.696 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:12.696 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:12.696 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-20', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:12.696 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:12.696 7faf32415220 [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=933867180, session_epoch=8980, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4492, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:12.696 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8995 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8980, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4492, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:12.697 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178993.675293, idle connection 118071.000000, request 304999.943495 09/07/2026 05:11:12.697 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178993.238525, idle connection 118070.000000, request 304999.513626 09/07/2026 05:11:12.707 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178131.345215, idle connection 116781.000000, request 304399.179697 09/07/2026 05:11:12.707 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9195 09/07/2026 05:11:12.707 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.707 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9195 (601.2849807739258 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=5778, last_stable_offset=5778, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x16\x8f\x00\x00\x00\xfa\x00\x00\x00\x00\x02\xca\xcb;n\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x8e\x03\x00\x00\x00\xd0\x02ObjectVNTable:default-domain:adm...')])]) 09/07/2026 05:11:12.708 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 1 response partitions (0 implied) 09/07/2026 05:11:12.708 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 744 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 5775 09/07/2026 05:11:12.708 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 5775 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 09/07/2026 05:11:12.708 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 5778 (leader epoch 0) 09/07/2026 05:11:12.770 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180786.118164, idle connection 119574.000000, request 304398.911953 09/07/2026 05:11:12.770 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8442 09/07/2026 05:11:12.770 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.770 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8442 (601.6976833343506 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:12.770 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:12.810 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:12.810 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:12.810 7faf324155e0 [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)]) 09/07/2026 05:11:12.810 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:12.810 7faf324155e0 [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=1341819554, session_epoch=9184, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5778, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:12.810 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9196 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9184, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=5778, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/07/2026 05:11:12.810 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178027.984131, idle connection 116677.000000, request 304999.942064 09/07/2026 05:11:12.811 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178027.472900, idle connection 116677.000000, request 304999.439716 09/07/2026 05:11:12.982 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179501.919434, idle connection 54545.000000, request 304398.802996 09/07/2026 05:11:12.983 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8400 09/07/2026 05:11:12.983 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:12.983 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8400 (601.8826961517334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:12.983 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:13.097 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178529.314941, idle connection 294081.000000, request 304397.531509 09/07/2026 05:11:13.097 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8563 09/07/2026 05:11:13.097 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.097 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8563 (603.1045913696289 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:13.097 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:13.098 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176630.532227, idle connection 115490.000000, request 304397.680044 09/07/2026 05:11:13.098 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9155 09/07/2026 05:11:13.098 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.098 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9155 (602.6556491851807 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:13.098 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:13.188 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:13.188 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:13.188 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:13.188 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:13.188 7faf324150e0 [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=1706742470, session_epoch=8407, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.188 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8427 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8407, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.188 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180107.266846, idle connection 535785.000000, request 304999.937057 09/07/2026 05:11:13.189 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180106.781738, idle connection 535784.000000, request 304999.461889 09/07/2026 05:11:13.290 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:13.290 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:13.290 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:13.290 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:13.290 7faf3027fc20 [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=1427528239, session_epoch=8664, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.291 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8664, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.291 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181906.074951, idle connection 57348.000000, request 304999.938726 09/07/2026 05:11:13.291 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181905.609131, idle connection 57348.000000, request 304999.483109 09/07/2026 05:11:13.298 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178392.172852, idle connection 117469.000000, request 304398.447037 09/07/2026 05:11:13.298 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8995 09/07/2026 05:11:13.298 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.298 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8995 (601.9964218139648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:13.299 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:13.371 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:13.372 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:13.372 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:13.372 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:13.372 7faf2fc47540 [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=543640748, session_epoch=8418, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.372 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8443 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8418, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.372 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180183.344727, idle connection 118971.000000, request 304999.928236 09/07/2026 05:11:13.373 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180182.847412, idle connection 118970.000000, request 304999.449968 09/07/2026 05:11:13.411 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177426.926514, idle connection 116076.000000, request 304398.880720 09/07/2026 05:11:13.412 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9196 09/07/2026 05:11:13.412 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.412 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9196 (601.7487049102783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:13.412 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:13.585 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:13.585 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:13.585 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:13.585 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:13.585 7faf2fc47680 [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=1136012074, session_epoch=8386, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.585 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8401 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8386, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.586 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178898.620361, idle connection 53942.000000, request 304999.914646 09/07/2026 05:11:13.586 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178898.032715, idle connection 53942.000000, request 304999.333858 09/07/2026 05:11:13.698 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:13.698 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:13.698 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:13.698 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:13.698 7faf2fc47cc0 [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=983615111, session_epoch=8542, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.698 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8564 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8542, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.699 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177927.153809, idle connection 293479.000000, request 304999.934673 09/07/2026 05:11:13.699 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:13.699 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:13.699 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:13.699 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:13.699 7faf32415c20 [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=1459767967, session_epoch=9136, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.699 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9156 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9136, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.699 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176028.672852, idle connection 114888.000000, request 304999.961138 09/07/2026 05:11:13.700 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177926.012451, idle connection 293478.000000, request 304998.806238 09/07/2026 05:11:13.700 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176027.989746, idle connection 114887.000000, request 304999.282360 09/07/2026 05:11:13.790 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179506.145996, idle connection 535183.000000, request 304398.816109 09/07/2026 05:11:13.790 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8427 09/07/2026 05:11:13.790 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.790 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8427 (601.7863750457764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:13.790 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:13.892 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 181305.046631, idle connection 56747.000000, request 304398.909330 09/07/2026 05:11:13.892 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8681 09/07/2026 05:11:13.892 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.892 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8681 (601.6886234283447 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:13.893 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:13.899 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:13.899 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:13.899 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:13.899 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:13.899 7faf32415220 [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=933867180, session_epoch=8981, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.899 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8996 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8981, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:13.900 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177790.666748, idle connection 116868.000000, request 304999.948263 09/07/2026 05:11:13.900 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177790.249756, idle connection 116867.000000, request 304999.537706 09/07/2026 05:11:13.974 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179581.576904, idle connection 118369.000000, request 304398.172617 09/07/2026 05:11:13.975 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8443 09/07/2026 05:11:13.975 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:13.975 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8443 (602.4601459503174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:13.975 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:14.014 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:14.014 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:14.014 7faf324155e0 [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)]) 09/07/2026 05:11:14.014 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:14.014 7faf324155e0 [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=1341819554, session_epoch=9185, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.014 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9197 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9185, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.014 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176823.943604, idle connection 115473.000000, request 304999.932766 09/07/2026 05:11:14.015 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176823.451660, idle connection 115473.000000, request 304999.460697 09/07/2026 05:11:14.187 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178297.108887, idle connection 53341.000000, request 304398.408890 09/07/2026 05:11:14.188 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8401 09/07/2026 05:11:14.188 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:14.188 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8401 (602.2439002990723 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:14.188 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:14.301 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177325.201172, idle connection 292877.000000, request 304397.980690 09/07/2026 05:11:14.301 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8564 09/07/2026 05:11:14.301 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:14.301 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8564 (602.6673316955566 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:14.301 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:14.302 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175426.372559, idle connection 114285.000000, request 304397.661686 09/07/2026 05:11:14.302 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9156 09/07/2026 05:11:14.302 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:14.302 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9156 (602.6554107666016 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:14.302 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:14.392 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:14.392 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:14.392 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:14.392 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:14.393 7faf324150e0 [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=1706742470, session_epoch=8408, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.393 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8428 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8408, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.393 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178902.661133, idle connection 534580.000000, request 304999.909401 09/07/2026 05:11:14.394 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178901.983887, idle connection 534579.000000, request 304999.247551 09/07/2026 05:11:14.493 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:14.494 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:14.494 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:14.494 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:14.494 7faf3027fc20 [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=1427528239, session_epoch=8665, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.494 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8665, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.494 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180702.541992, idle connection 56145.000000, request 304999.937773 09/07/2026 05:11:14.495 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180701.936768, idle connection 56144.000000, request 304999.343157 09/07/2026 05:11:14.500 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177189.741699, idle connection 116267.000000, request 304399.027348 09/07/2026 05:11:14.501 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8996 09/07/2026 05:11:14.501 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:14.501 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8996 (601.4003753662109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:14.501 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:14.576 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:14.577 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:14.577 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:14.577 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:14.577 7faf2fc47540 [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=543640748, session_epoch=8419, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.577 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8444 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8419, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.577 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178978.355469, idle connection 117766.000000, request 304999.940395 09/07/2026 05:11:14.578 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178977.838867, idle connection 117765.000000, request 304999.432564 09/07/2026 05:11:14.615 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176222.879150, idle connection 114872.000000, request 304398.874998 09/07/2026 05:11:14.616 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9197 09/07/2026 05:11:14.616 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:14.616 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9197 (601.7441749572754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:14.616 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:14.789 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:14.789 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:14.790 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:14.790 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:14.790 7faf2fc47680 [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=1136012074, session_epoch=8387, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.790 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8402 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8387, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.790 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177694.248535, idle connection 52738.000000, request 304999.941349 09/07/2026 05:11:14.791 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177693.417969, idle connection 52737.000000, request 304999.114275 09/07/2026 05:11:14.902 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:14.902 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:14.902 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:14.906 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:14.907 7faf2fc47cc0 [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=983615111, session_epoch=8543, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.907 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8565 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8543, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.907 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176718.836182, idle connection 292271.000000, request 304999.936581 09/07/2026 05:11:14.907 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:14.907 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:14.907 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:14.907 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:14.908 7faf32415c20 [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=1459767967, session_epoch=9137, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.908 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9157 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9137, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:14.908 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174820.320312, idle connection 113679.000000, request 304999.957800 09/07/2026 05:11:14.908 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176717.655273, idle connection 292269.000000, request 304998.768330 09/07/2026 05:11:14.909 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174819.559326, idle connection 113679.000000, request 304999.202967 09/07/2026 05:11:14.995 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178300.858398, idle connection 533978.000000, request 304398.060083 09/07/2026 05:11:14.995 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8428 09/07/2026 05:11:14.995 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:14.996 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8428 (602.5869846343994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:14.996 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:15.095 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 180101.366455, idle connection 55544.000000, request 304398.761749 09/07/2026 05:11:15.096 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8682 09/07/2026 05:11:15.096 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.096 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8682 (601.8149852752686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:15.096 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:15.101 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:15.102 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:15.102 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:15.102 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:15.102 7faf32415220 [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=933867180, session_epoch=8982, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.102 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8997 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8982, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.102 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176588.134521, idle connection 115665.000000, request 304999.942541 09/07/2026 05:11:15.103 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176587.647217, idle connection 115665.000000, request 304999.461651 09/07/2026 05:11:15.179 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178376.741211, idle connection 117164.000000, request 304398.306608 09/07/2026 05:11:15.179 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8444 09/07/2026 05:11:15.180 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.180 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8444 (602.4041175842285 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:15.180 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:15.218 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:15.218 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:15.218 7faf324155e0 [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)]) 09/07/2026 05:11:15.218 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:15.218 7faf324155e0 [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=1341819554, session_epoch=9186, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.218 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9198 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9186, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.219 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175619.619629, idle connection 114269.000000, request 304999.933481 09/07/2026 05:11:15.219 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175619.037354, idle connection 114268.000000, request 304999.359608 09/07/2026 05:11:15.392 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177092.561523, idle connection 52136.000000, request 304398.250580 09/07/2026 05:11:15.392 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8402 09/07/2026 05:11:15.392 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.393 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8402 (602.5300025939941 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:15.393 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:15.509 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176116.697998, idle connection 291669.000000, request 304397.792101 09/07/2026 05:11:15.510 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8565 09/07/2026 05:11:15.510 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.510 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8565 (603.0147075653076 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:15.510 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:15.510 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174217.688721, idle connection 113077.000000, request 304397.325993 09/07/2026 05:11:15.511 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9157 09/07/2026 05:11:15.511 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.511 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9157 (603.1196117401123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:15.511 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:15.598 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:15.598 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:15.598 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:15.598 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:15.598 7faf324150e0 [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=1706742470, session_epoch=8409, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.598 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8429 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8409, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.599 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177697.026611, idle connection 533374.000000, request 304999.926329 09/07/2026 05:11:15.599 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177696.451660, idle connection 533374.000000, request 304999.362707 09/07/2026 05:11:15.697 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:15.698 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:15.698 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:15.698 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:15.698 7faf3027fc20 [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=1427528239, session_epoch=8666, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.698 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8666, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.698 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179498.338623, idle connection 54941.000000, request 304999.930620 09/07/2026 05:11:15.699 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 179497.807861, idle connection 54940.000000, request 304999.407530 09/07/2026 05:11:15.704 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175986.573242, idle connection 115064.000000, request 304398.385525 09/07/2026 05:11:15.704 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8997 09/07/2026 05:11:15.704 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.704 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8997 (602.1339893341064 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:15.704 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:15.781 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:15.781 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:15.781 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:15.782 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:15.782 7faf2fc47540 [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=543640748, session_epoch=8420, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.782 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8445 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8420, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:15.782 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177773.668701, idle connection 116561.000000, request 304999.932766 09/07/2026 05:11:15.783 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177773.055176, idle connection 116561.000000, request 304999.330521 09/07/2026 05:11:15.820 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175018.313721, idle connection 113668.000000, request 304398.625851 09/07/2026 05:11:15.820 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9198 09/07/2026 05:11:15.821 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:15.821 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9198 (602.0724773406982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:15.821 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:15.994 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:16.062 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:16.062 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:16.063 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:16.063 7faf2fc47680 [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=1136012074, session_epoch=8388, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.063 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8403 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8388, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.063 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176421.282227, idle connection 51465.000000, request 304999.927759 09/07/2026 05:11:16.064 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176420.777100, idle connection 51464.000000, request 304999.437809 09/07/2026 05:11:16.111 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:16.111 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:16.111 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:16.111 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:16.111 7faf2fc47cc0 [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=983615111, session_epoch=8544, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.111 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8566 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8544, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.112 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175514.230713, idle connection 291066.000000, request 304999.927998 09/07/2026 05:11:16.112 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:16.112 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:16.112 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:16.112 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:16.112 7faf32415c20 [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=1459767967, session_epoch=9138, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.112 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9158 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9138, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.113 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173615.572021, idle connection 112475.000000, request 304999.954224 09/07/2026 05:11:16.113 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175512.877930, idle connection 291065.000000, request 304998.591661 09/07/2026 05:11:16.113 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173614.769043, idle connection 112474.000000, request 304999.156713 09/07/2026 05:11:16.200 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177095.750000, idle connection 532773.000000, request 304398.655415 09/07/2026 05:11:16.200 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8429 09/07/2026 05:11:16.200 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.201 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8429 (601.9866466522217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:16.201 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:16.300 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178897.080811, idle connection 54339.000000, request 304398.672104 09/07/2026 05:11:16.300 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8683 09/07/2026 05:11:16.300 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.301 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8683 (602.1225452423096 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:16.301 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:16.305 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:16.305 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:16.305 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:16.305 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:16.305 7faf32415220 [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=933867180, session_epoch=8983, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.305 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8998 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8983, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.305 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175384.818115, idle connection 114462.000000, request 304999.947309 09/07/2026 05:11:16.306 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175384.383057, idle connection 114461.000000, request 304999.517918 09/07/2026 05:11:16.384 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177172.149170, idle connection 115960.000000, request 304398.415804 09/07/2026 05:11:16.384 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8445 09/07/2026 05:11:16.384 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.384 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8445 (602.2534370422363 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:16.384 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:16.422 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:16.423 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:16.423 7faf324155e0 [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)]) 09/07/2026 05:11:16.423 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:16.423 7faf324155e0 [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=1341819554, session_epoch=9187, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.423 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9199 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9187, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.423 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174415.006104, idle connection 113064.000000, request 304999.940395 09/07/2026 05:11:16.424 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174414.439941, idle connection 113064.000000, request 304999.382257 09/07/2026 05:11:16.664 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175820.138184, idle connection 50864.000000, request 304398.788691 09/07/2026 05:11:16.665 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8403 09/07/2026 05:11:16.665 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.665 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8403 (601.823091506958 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:16.665 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:16.714 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174911.928467, idle connection 290464.000000, request 304397.631645 09/07/2026 05:11:16.714 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8566 09/07/2026 05:11:16.714 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.715 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8566 (602.9632091522217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:16.715 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:16.715 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173013.187256, idle connection 111872.000000, request 304397.571564 09/07/2026 05:11:16.715 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9158 09/07/2026 05:11:16.715 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.715 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9158 (602.7517318725586 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:16.715 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:16.802 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:16.802 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:16.802 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:16.803 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:16.803 7faf324150e0 [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=1706742470, session_epoch=8410, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.803 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8430 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8410, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.803 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176492.489258, idle connection 532170.000000, request 304999.921799 09/07/2026 05:11:16.804 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176491.983887, idle connection 532169.000000, request 304999.425650 09/07/2026 05:11:16.902 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:16.902 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:16.902 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:16.902 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:16.902 7faf3027fc20 [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=1427528239, session_epoch=8667, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.903 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8667, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.903 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178294.029053, idle connection 53736.000000, request 304999.927521 09/07/2026 05:11:16.903 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 178293.522461, idle connection 53736.000000, request 304999.430895 09/07/2026 05:11:16.907 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174783.070557, idle connection 113860.000000, request 304398.200989 09/07/2026 05:11:16.907 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8998 09/07/2026 05:11:16.907 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:16.908 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8998 (602.2500991821289 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:16.908 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:16.986 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:16.986 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:16.986 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:16.986 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:16.986 7faf2fc47540 [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=543640748, session_epoch=8421, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.986 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8446 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8421, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:16.987 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176569.039795, idle connection 115357.000000, request 304999.938250 09/07/2026 05:11:16.987 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176568.570801, idle connection 115356.000000, request 304999.479294 09/07/2026 05:11:17.025 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173813.151123, idle connection 112463.000000, request 304398.084402 09/07/2026 05:11:17.026 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9199 09/07/2026 05:11:17.026 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.026 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9199 (602.5047302246094 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:17.026 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:17.267 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:17.267 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:17.267 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:17.267 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:17.267 7faf2fc47680 [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=1136012074, session_epoch=8389, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.267 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8404 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8389, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.268 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175216.714844, idle connection 50260.000000, request 304999.938488 09/07/2026 05:11:17.268 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175216.129395, idle connection 50260.000000, request 304999.362230 09/07/2026 05:11:17.315 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:17.316 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:17.316 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:17.316 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:17.316 7faf2fc47cc0 [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=983615111, session_epoch=8545, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.316 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8567 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8545, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.316 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174309.437988, idle connection 289861.000000, request 304999.925137 09/07/2026 05:11:17.317 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:17.317 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:17.317 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:17.317 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:17.317 7faf32415c20 [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=1459767967, session_epoch=9139, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.317 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9159 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9139, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.317 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172410.658691, idle connection 111270.000000, request 304999.944925 09/07/2026 05:11:17.318 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174307.891846, idle connection 289860.000000, request 304998.397827 09/07/2026 05:11:17.318 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172409.753662, idle connection 111269.000000, request 304999.050617 09/07/2026 05:11:17.404 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175891.342041, idle connection 531569.000000, request 304398.773670 09/07/2026 05:11:17.405 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8430 09/07/2026 05:11:17.405 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.405 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8430 (601.8636226654053 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:17.405 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:17.504 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177692.855713, idle connection 53135.000000, request 304398.753405 09/07/2026 05:11:17.504 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8684 09/07/2026 05:11:17.505 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.505 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8684 (601.8834114074707 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:17.505 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:17.508 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:17.508 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:17.508 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:17.508 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:17.508 7faf32415220 [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=933867180, session_epoch=8984, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.509 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8999 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8984, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.509 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174181.537109, idle connection 113259.000000, request 304999.947786 09/07/2026 05:11:17.509 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174181.119385, idle connection 113258.000000, request 304999.535799 09/07/2026 05:11:17.589 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175967.097656, idle connection 114755.000000, request 304397.995472 09/07/2026 05:11:17.589 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8446 09/07/2026 05:11:17.589 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.589 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8446 (602.6301383972168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:17.589 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:17.627 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:17.627 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:17.628 7faf324155e0 [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)]) 09/07/2026 05:11:17.628 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:17.628 7faf324155e0 [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=1341819554, session_epoch=9188, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.628 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9200 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9188, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:17.628 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173210.186279, idle connection 111860.000000, request 304999.936819 09/07/2026 05:11:17.629 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173209.658447, idle connection 111859.000000, request 304999.421120 09/07/2026 05:11:17.869 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174615.398682, idle connection 49659.000000, request 304398.617744 09/07/2026 05:11:17.869 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8404 09/07/2026 05:11:17.870 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.870 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8404 (602.0839214324951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:17.870 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:17.919 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173706.869141, idle connection 289259.000000, request 304397.362709 09/07/2026 05:11:17.919 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8567 09/07/2026 05:11:17.919 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.920 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8567 (603.2726764678955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:17.920 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:17.920 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171808.089355, idle connection 110667.000000, request 304397.383451 09/07/2026 05:11:17.920 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9159 09/07/2026 05:11:17.920 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:17.920 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9159 (602.9365062713623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:17.920 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:18.007 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:18.007 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:18.007 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:18.008 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:18.008 7faf324150e0 [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=1706742470, session_epoch=8411, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.008 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8431 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8411, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.008 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175287.697266, idle connection 530965.000000, request 304999.940157 09/07/2026 05:11:18.008 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175287.206299, idle connection 530965.000000, request 304999.459028 09/07/2026 05:11:18.106 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:18.106 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:18.106 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:18.106 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:18.107 7faf3027fc20 [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=1427528239, session_epoch=8668, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.107 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8668, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.107 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177089.983398, idle connection 52532.000000, request 304999.933958 09/07/2026 05:11:18.107 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177089.513916, idle connection 52532.000000, request 304999.475479 09/07/2026 05:11:18.110 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173580.160400, idle connection 112657.000000, request 304398.575783 09/07/2026 05:11:18.110 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8999 09/07/2026 05:11:18.110 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:18.110 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8999 (601.8249988555908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:18.111 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:18.190 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:18.191 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:18.191 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:18.191 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:18.191 7faf2fc47540 [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=543640748, session_epoch=8422, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.191 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8447 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8422, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.191 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175364.449951, idle connection 114152.000000, request 304999.938011 09/07/2026 05:11:18.192 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175363.952148, idle connection 114151.000000, request 304999.450684 09/07/2026 05:11:18.230 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172608.536377, idle connection 111258.000000, request 304398.288727 09/07/2026 05:11:18.230 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9200 09/07/2026 05:11:18.230 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:18.230 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9200 (602.3204326629639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:18.231 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:18.472 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:18.472 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:18.472 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:18.473 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:18.473 7faf2fc47680 [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=1136012074, session_epoch=8390, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.473 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8405 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8390, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.473 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174011.265625, idle connection 49055.000000, request 304999.918699 09/07/2026 05:11:18.474 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174010.674805, idle connection 49054.000000, request 304999.343395 09/07/2026 05:11:18.520 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:18.521 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:18.521 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:18.521 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:18.521 7faf2fc47cc0 [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=983615111, session_epoch=8546, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.521 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8568 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8546, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.521 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173104.568604, idle connection 288656.000000, request 304999.937773 09/07/2026 05:11:18.522 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:18.522 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:18.522 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:18.522 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:18.522 7faf32415c20 [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=1459767967, session_epoch=9140, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.522 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9160 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9140, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.522 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171205.885254, idle connection 110065.000000, request 304999.947309 09/07/2026 05:11:18.523 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173103.097656, idle connection 288655.000000, request 304998.465538 09/07/2026 05:11:18.524 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171204.262207, idle connection 110063.000000, request 304998.334646 09/07/2026 05:11:18.609 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174686.643311, idle connection 530364.000000, request 304398.887157 09/07/2026 05:11:18.609 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8431 09/07/2026 05:11:18.610 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:18.610 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8431 (601.7217636108398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:18.610 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:18.708 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176488.944580, idle connection 51931.000000, request 304398.896694 09/07/2026 05:11:18.708 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8685 09/07/2026 05:11:18.708 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:18.709 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8685 (601.7987728118896 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:18.709 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:18.711 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:18.711 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:18.711 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:18.711 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:18.711 7faf32415220 [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=933867180, session_epoch=8985, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.711 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9000 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8985, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.711 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172978.707520, idle connection 112056.000000, request 304999.948025 09/07/2026 05:11:18.712 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172978.234863, idle connection 112055.000000, request 304999.478579 09/07/2026 05:11:18.793 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174762.476562, idle connection 113550.000000, request 304397.964478 09/07/2026 05:11:18.794 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8447 09/07/2026 05:11:18.794 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:18.794 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8447 (602.7336120605469 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:18.794 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:18.832 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:18.832 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:18.832 7faf324155e0 [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)]) 09/07/2026 05:11:18.833 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:18.833 7faf324155e0 [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=1341819554, session_epoch=9189, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.833 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9201 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9189, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:18.833 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172005.183105, idle connection 110655.000000, request 304999.937296 09/07/2026 05:11:18.834 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172004.663818, idle connection 110654.000000, request 304999.427557 09/07/2026 05:11:19.074 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173410.057373, idle connection 48454.000000, request 304398.715258 09/07/2026 05:11:19.075 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8405 09/07/2026 05:11:19.075 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.075 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8405 (601.909875869751 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:19.075 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:19.124 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172501.414795, idle connection 288053.000000, request 304396.783829 09/07/2026 05:11:19.125 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8568 09/07/2026 05:11:19.125 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.125 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8568 (603.7805080413818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:19.125 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:19.125 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170602.733398, idle connection 109462.000000, request 304396.803856 09/07/2026 05:11:19.126 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9160 09/07/2026 05:11:19.126 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.126 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9160 (603.5127639770508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:19.126 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:19.210 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:19.211 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:19.211 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:19.211 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:19.211 7faf324150e0 [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=1706742470, session_epoch=8412, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.211 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8432 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8412, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.211 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174084.481689, idle connection 529762.000000, request 304999.942541 09/07/2026 05:11:19.212 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174084.014160, idle connection 529761.000000, request 304999.483824 09/07/2026 05:11:19.310 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:19.310 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:19.310 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:19.310 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:19.310 7faf3027fc20 [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=1427528239, session_epoch=8669, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.310 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8669, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.311 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175886.254883, idle connection 51329.000000, request 304999.920368 09/07/2026 05:11:19.311 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175885.763184, idle connection 51328.000000, request 304999.440670 09/07/2026 05:11:19.313 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172377.412354, idle connection 111455.000000, request 304398.658514 09/07/2026 05:11:19.313 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9000 09/07/2026 05:11:19.313 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.313 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9000 (601.7413139343262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:19.313 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:19.395 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:19.395 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:19.396 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:19.396 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:19.396 7faf2fc47540 [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=543640748, session_epoch=8423, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.396 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8448 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8423, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.396 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174159.592773, idle connection 112947.000000, request 304999.939203 09/07/2026 05:11:19.397 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174159.084717, idle connection 112947.000000, request 304999.442577 09/07/2026 05:11:19.435 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171403.591309, idle connection 110053.000000, request 304398.347378 09/07/2026 05:11:19.435 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9201 09/07/2026 05:11:19.435 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.435 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9201 (602.1959781646729 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:19.435 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:19.678 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:19.678 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:19.678 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:19.678 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:19.678 7faf2fc47680 [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=1136012074, session_epoch=8391, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.679 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8406 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8391, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.679 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172805.504883, idle connection 47849.000000, request 304999.910116 09/07/2026 05:11:19.679 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172804.946533, idle connection 47849.000000, request 304999.371767 09/07/2026 05:11:19.726 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:19.726 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:19.726 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:19.726 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:19.726 7faf2fc47cc0 [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=983615111, session_epoch=8547, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.726 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8569 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8547, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.727 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171899.213135, idle connection 287451.000000, request 304999.936581 09/07/2026 05:11:19.727 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:19.727 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:19.727 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:19.727 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:19.727 7faf32415c20 [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=1459767967, session_epoch=9141, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.727 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9161 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9141, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.727 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170000.677490, idle connection 108860.000000, request 304999.956369 09/07/2026 05:11:19.728 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171898.016357, idle connection 287450.000000, request 304998.751640 09/07/2026 05:11:19.728 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169999.980713, idle connection 108859.000000, request 304999.264717 09/07/2026 05:11:19.812 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173483.417236, idle connection 529161.000000, request 304398.875952 09/07/2026 05:11:19.813 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8432 09/07/2026 05:11:19.813 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.813 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8432 (601.7251014709473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:19.813 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:19.912 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175285.178711, idle connection 50727.000000, request 304398.845911 09/07/2026 05:11:19.912 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8686 09/07/2026 05:11:19.912 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.912 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8686 (601.78542137146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:19.912 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:19.914 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:19.914 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:19.914 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:19.914 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:19.914 7faf32415220 [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=933867180, session_epoch=8986, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.914 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9001 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8986, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:19.914 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171775.980957, idle connection 110853.000000, request 304999.949217 09/07/2026 05:11:19.915 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171775.523926, idle connection 110853.000000, request 304999.497414 09/07/2026 05:11:19.998 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173557.625977, idle connection 112345.000000, request 304397.969723 09/07/2026 05:11:19.999 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8448 09/07/2026 05:11:19.999 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:19.999 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8448 (602.8165817260742 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:19.999 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:20.037 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:20.037 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:20.037 7faf324155e0 [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)]) 09/07/2026 05:11:20.037 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:20.037 7faf324155e0 [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=1341819554, session_epoch=9190, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.037 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9202 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9190, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.037 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170800.882324, idle connection 109450.000000, request 304999.940634 09/07/2026 05:11:20.038 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170800.426025, idle connection 109450.000000, request 304999.493122 09/07/2026 05:11:20.280 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172204.312012, idle connection 47248.000000, request 304398.727417 09/07/2026 05:11:20.280 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8406 09/07/2026 05:11:20.281 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:20.281 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8406 (601.973295211792 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:20.281 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:20.329 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171296.853027, idle connection 286849.000000, request 304397.573471 09/07/2026 05:11:20.329 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8569 09/07/2026 05:11:20.330 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:20.330 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8569 (603.0826568603516 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:20.330 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:20.330 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169398.045654, idle connection 108257.000000, request 304397.326469 09/07/2026 05:11:20.330 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9161 09/07/2026 05:11:20.330 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:20.330 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9161 (603.0070781707764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:20.331 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied) 09/07/2026 05:11:20.414 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 563 09/07/2026 05:11:20.414 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 09/07/2026 05:11:20.414 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 09/07/2026 05:11:20.414 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:20.415 7faf324150e0 [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=1706742470, session_epoch=8413, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.415 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8433 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1706742470, session_epoch=8413, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.415 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172880.865967, idle connection 528558.000000, request 304999.935150 09/07/2026 05:11:20.415 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172880.392090, idle connection 528558.000000, request 304999.466896 09/07/2026 05:11:20.514 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1869 09/07/2026 05:11:20.514 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 09/07/2026 05:11:20.514 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 09/07/2026 05:11:20.515 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/07/2026 05:11:20.515 7faf3027fc20 [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=1427528239, session_epoch=8670, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.515 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Request 8687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1427528239, session_epoch=8670, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.515 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174681.899658, idle connection 50124.000000, request 304999.941111 09/07/2026 05:11:20.515 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174681.422363, idle connection 50124.000000, request 304999.473333 09/07/2026 05:11:20.516 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171174.570801, idle connection 110252.000000, request 304398.543835 09/07/2026 05:11:20.516 7faf32415220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9001 09/07/2026 05:11:20.516 7faf32415220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:20.516 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9001 (602.0095348358154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=933867180, topics=[]) 09/07/2026 05:11:20.516 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 933867180 with 0 response partitions (1 implied) 09/07/2026 05:11:20.601 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 381 09/07/2026 05:11:20.601 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/07/2026 05:11:20.601 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 09/07/2026 05:11:20.601 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:20.601 7faf2fc47540 [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=543640748, session_epoch=8424, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.601 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 8449 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=543640748, session_epoch=8424, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.601 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172954.152588, idle connection 111742.000000, request 304999.934912 09/07/2026 05:11:20.602 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172953.655273, idle connection 111741.000000, request 304999.449492 09/07/2026 05:11:20.639 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170199.293457, idle connection 108849.000000, request 304398.350239 09/07/2026 05:11:20.639 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9202 09/07/2026 05:11:20.639 7faf324155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:20.640 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9202 (602.2250652313232 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1341819554, topics=[]) 09/07/2026 05:11:20.640 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1341819554 with 0 response partitions (1 implied) 09/07/2026 05:11:20.884 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 276 09/07/2026 05:11:20.884 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 09/07/2026 05:11:20.884 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 09/07/2026 05:11:20.884 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:20.884 7faf2fc47680 [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=1136012074, session_epoch=8392, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.885 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8407 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1136012074, session_epoch=8392, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.885 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171599.581787, idle connection 46643.000000, request 304999.938965 09/07/2026 05:11:20.885 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171599.070312, idle connection 46643.000000, request 304999.438286 09/07/2026 05:11:20.930 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 880 09/07/2026 05:11:20.931 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/07/2026 05:11:20.931 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 09/07/2026 05:11:20.931 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 09/07/2026 05:11:20.931 7faf2fc47cc0 [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=983615111, session_epoch=8548, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.931 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Request 8570 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=983615111, session_epoch=8548, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.931 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170694.575684, idle connection 286246.000000, request 304999.939203 09/07/2026 05:11:20.931 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 5240 09/07/2026 05:11:20.932 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/07/2026 05:11:20.932 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/07/2026 05:11:20.932 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:20.932 7faf32415c20 [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=1459767967, session_epoch=9142, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.932 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9162 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459767967, session_epoch=9142, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:20.932 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168796.120605, idle connection 107655.000000, request 304999.962330 09/07/2026 05:11:20.932 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170693.455566, idle connection 286245.000000, request 304998.830557 09/07/2026 05:11:20.933 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168795.430176, idle connection 107654.000000, request 304999.276400 09/07/2026 05:11:21.016 7faf324150e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172279.688721, idle connection 527957.000000, request 304398.759127 09/07/2026 05:11:21.016 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8433 09/07/2026 05:11:21.017 7faf324150e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:21.017 7faf324150e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8433 (601.8490791320801 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1706742470, topics=[]) 09/07/2026 05:11:21.017 7faf324150e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1706742470 with 0 response partitions (1 implied) 09/07/2026 05:11:21.116 7faf3027fc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174080.542969, idle connection 49523.000000, request 304398.583651 09/07/2026 05:11:21.117 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8687 09/07/2026 05:11:21.117 7faf3027fc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:21.117 7faf3027fc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.185', 9092)]>: Response 8687 (602.0734310150146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1427528239, topics=[]) 09/07/2026 05:11:21.117 7faf3027fc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1427528239 with 0 response partitions (1 implied) 09/07/2026 05:11:21.117 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4492 09/07/2026 05:11:21.117 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/07/2026 05:11:21.117 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 09/07/2026 05:11:21.118 7faf32415220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:21.118 7faf32415220 [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=933867180, session_epoch=8987, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:21.118 7faf32415220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9002 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=933867180, session_epoch=8987, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:21.118 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170572.364746, idle connection 109649.000000, request 304999.955416 09/07/2026 05:11:21.119 7faf32415220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170571.689209, idle connection 109649.000000, request 304999.282360 09/07/2026 05:11:21.203 7faf2fc47540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172352.263916, idle connection 111140.000000, request 304398.048162 09/07/2026 05:11:21.204 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8449 09/07/2026 05:11:21.204 7faf2fc47540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:21.204 7faf2fc47540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 8449 (602.5264263153076 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=543640748, topics=[]) 09/07/2026 05:11:21.204 7faf2fc47540 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 543640748 with 0 response partitions (1 implied) 09/07/2026 05:11:21.241 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 5778 09/07/2026 05:11:21.241 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/07/2026 05:11:21.242 7faf324155e0 [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)]) 09/07/2026 05:11:21.242 7faf324155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 09/07/2026 05:11:21.242 7faf324155e0 [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=1341819554, session_epoch=9191, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:21.242 7faf324155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 9203 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1341819554, session_epoch=9191, topics=[], forgotten_topics_data=[]) 09/07/2026 05:11:21.242 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169596.219971, idle connection 108246.000000, request 304999.944687 09/07/2026 05:11:21.243 7faf324155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169595.690674, idle connection 108245.000000, request 304999.419689 09/07/2026 05:11:21.486 7faf2fc47680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170998.437012, idle connection 46042.000000, request 304398.795605 09/07/2026 05:11:21.486 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8407 09/07/2026 05:11:21.486 7faf2fc47680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:21.487 7faf2fc47680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8407 (601.8483638763428 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1136012074, topics=[]) 09/07/2026 05:11:21.487 7faf2fc47680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1136012074 with 0 response partitions (1 implied) 09/07/2026 05:11:21.533 7faf2fc47cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170092.567139, idle connection 285644.000000, request 304397.926807 09/07/2026 05:11:21.534 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8570 09/07/2026 05:11:21.534 7faf2fc47cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:21.534 7faf2fc47cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.186', 9092)]>: Response 8570 (602.771520614624 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=983615111, topics=[]) 09/07/2026 05:11:21.534 7faf2fc47cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 983615111 with 0 response partitions (1 implied) 09/07/2026 05:11:21.534 7faf32415c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168193.650391, idle connection 107053.000000, request 304397.490501 09/07/2026 05:11:21.535 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9162 09/07/2026 05:11:21.535 7faf32415c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/07/2026 05:11:21.535 7faf32415c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 9162 (602.9577255249023 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459767967, topics=[]) 09/07/2026 05:11:21.535 7faf32415c20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1459767967 with 0 response partitions (1 implied)