01/05/2026 04:24:47.224 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2103054568 with 1 response partitions (0 implied) 01/05/2026 04:24:47.225 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 303 bytes of data for partition TopicPartition(topic='-uve-topic-21', partition=0) with offset 2372 01/05/2026 04:24:47.225 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2372 for assigned partition TopicPartition(topic='-uve-topic-21', partition=0) 01/05/2026 04:24:47.225 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-21', partition=0) to 2373 (leader epoch 0) 01/05/2026 04:24:47.326 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2373 01/05/2026 04:24:47.326 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 01/05/2026 04:24:47.326 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-21', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 01/05/2026 04:24:47.326 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:47.326 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2103054568, session_epoch=7295, topics=[(topic='-uve-topic-21', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2373, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.327 7f8c975bc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7308 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2103054568, session_epoch=7295, topics=[(topic='-uve-topic-21', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2373, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.327 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173388.483643, idle connection 112004.000000, request 304999.932766 01/05/2026 04:24:47.327 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173388.022705, idle connection 112003.000000, request 304999.490261 01/05/2026 04:24:47.354 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171153.463379, idle connection 110025.000000, request 304398.986816 01/05/2026 04:24:47.355 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6944 01/05/2026 04:24:47.355 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.355 7f8c962fce00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6944 (601.5174388885498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307827436, topics=[]) 01/05/2026 04:24:47.355 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307827436 with 0 response partitions (1 implied) 01/05/2026 04:24:47.392 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171515.195068, idle connection 401283.000000, request 304398.047924 01/05/2026 04:24:47.392 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7118 01/05/2026 04:24:47.393 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.393 7f8c9676ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7118 (602.4558544158936 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=357506000, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=1591, last_stable_offset=1591, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x063\x00\x00\x03Y\x00\x00\x00\x00\x02\x16\x08B\xa3\x00\x00\x00\x00\x00\x03\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x04\x90\x03\x00\x00\x00\xd2\x02ObjectVRouter:an-jenkins-deploy-...')])]) 01/05/2026 04:24:47.393 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 357506000 with 1 response partitions (0 implied) 01/05/2026 04:24:47.393 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 869 bytes of data for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 1587 01/05/2026 04:24:47.393 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 1587 for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) 01/05/2026 04:24:47.393 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) to 1591 (leader epoch 0) 01/05/2026 04:24:47.394 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173268.558594, idle connection 112534.000000, request 304397.296906 01/05/2026 04:24:47.394 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7047 01/05/2026 04:24:47.394 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.394 7f8c975bc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7047 (603.1787395477295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2009812617, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=922, last_stable_offset=922, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x03\x99\x00\x00\x01\x17\x00\x00\x00\x00\x02\x89\xe0>\x14\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\x03ObjectVMITable:default-global-sy...')])]) 01/05/2026 04:24:47.394 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2009812617 with 1 response partitions (0 implied) 01/05/2026 04:24:47.394 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-18', partition=0) with offset 921 01/05/2026 04:24:47.395 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 921 for assigned partition TopicPartition(topic='-uve-topic-18', partition=0) 01/05/2026 04:24:47.395 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-18', partition=0) to 922 (leader epoch 0) 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170723.866455, idle connection 47341.000000, request 304399.204254 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7584 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7584 (601.1755466461182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=317929160, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=4150, last_stable_offset=4150, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x104\x00\x00\x01)\x00\x00\x00\x00\x02$\xb7\xf2\x83\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\xec\x03\x00\x00\x00\xae\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 317929160 with 1 response partitions (0 implied) 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 612 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 4148 01/05/2026 04:24:47.404 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4148 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) 01/05/2026 04:24:47.405 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 4150 (leader epoch 0) 01/05/2026 04:24:47.421 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171592.747559, idle connection 349036.000000, request 304399.152994 01/05/2026 04:24:47.421 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7863 01/05/2026 04:24:47.421 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.421 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7863 (601.3054847717285 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=248144129, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=4751, last_stable_offset=4751, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x12\x8a\x00\x00\x03\x13\x00\x00\x00\x00\x02g\x10b\xda\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\xfc\x03\x00\x00\x00\xbe\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/05/2026 04:24:47.422 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 248144129 with 1 response partitions (0 implied) 01/05/2026 04:24:47.422 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1420 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 4746 01/05/2026 04:24:47.422 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4746 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 01/05/2026 04:24:47.422 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 4751 (leader epoch 0) 01/05/2026 04:24:47.494 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1591 01/05/2026 04:24:47.494 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 01/05/2026 04:24:47.494 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-2', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 01/05/2026 04:24:47.494 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:47.494 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=357506000, session_epoch=7100, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=1591, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.495 7f8c9676ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=357506000, session_epoch=7100, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=1591, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.495 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171412.493408, idle connection 401180.000000, request 304999.941826 01/05/2026 04:24:47.495 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 922 01/05/2026 04:24:47.495 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/05/2026 04:24:47.495 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-18', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 01/05/2026 04:24:47.495 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/05/2026 04:24:47.496 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2009812617, session_epoch=7032, topics=[(topic='-uve-topic-18', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=922, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.496 7f8c975bc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7048 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2009812617, session_epoch=7032, topics=[(topic='-uve-topic-18', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=922, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.496 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173166.375977, idle connection 112431.000000, request 304999.958038 01/05/2026 04:24:47.496 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171411.095947, idle connection 401179.000000, request 304998.553514 01/05/2026 04:24:47.496 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172217.490723, idle connection 110685.000000, request 304397.911549 01/05/2026 04:24:47.497 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173165.560547, idle connection 112431.000000, request 304999.147415 01/05/2026 04:24:47.497 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7324 01/05/2026 04:24:47.497 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.497 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7324 (602.8289794921875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1343120360, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=2965, last_stable_offset=2965, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0b\x93\x00\x00\x013\x00\x00\x00\x00\x02cP\xbfZ\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...')])]) 01/05/2026 04:24:47.497 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1343120360 with 1 response partitions (0 implied) 01/05/2026 04:24:47.498 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 622 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 2963 01/05/2026 04:24:47.498 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2963 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) 01/05/2026 04:24:47.498 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 2965 (leader epoch 0) 01/05/2026 04:24:47.505 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4150 01/05/2026 04:24:47.505 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/05/2026 04:24:47.505 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 01/05/2026 04:24:47.505 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:47.505 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=317929160, session_epoch=7569, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4150, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.506 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7585 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=317929160, session_epoch=7569, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4150, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.506 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170621.749512, idle connection 47239.000000, request 304999.944448 01/05/2026 04:24:47.506 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170621.399414, idle connection 47238.000000, request 304999.597311 01/05/2026 04:24:47.523 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4751 01/05/2026 04:24:47.523 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/05/2026 04:24:47.523 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 01/05/2026 04:24:47.523 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:47.523 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=248144129, session_epoch=7844, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4751, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.523 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7864 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=248144129, session_epoch=7844, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4751, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.524 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171490.055908, idle connection 348933.000000, request 304999.950886 01/05/2026 04:24:47.524 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171489.673584, idle connection 348933.000000, request 304999.572277 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 245 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867358067, session_epoch=6889, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6905 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867358067, session_epoch=6889, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:47.583 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171727.948975, idle connection 223896.000000, request 304999.951124 01/05/2026 04:24:47.584 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174717.691650, idle connection 352999.000000, request 304397.476912 01/05/2026 04:24:47.584 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171727.392578, idle connection 223895.000000, request 304999.399662 01/05/2026 04:24:47.584 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6946 01/05/2026 04:24:47.584 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.584 7f8c975bc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6946 (603.2283306121826 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1569742206, topics=[]) 01/05/2026 04:24:47.584 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1569742206 with 0 response partitions (1 implied) 01/05/2026 04:24:47.598 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 2965 01/05/2026 04:24:47.598 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 01/05/2026 04:24:47.599 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 01/05/2026 04:24:47.599 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:47.599 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1343120360, session_epoch=7307, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2965, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.599 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7325 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1343120360, session_epoch=7307, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2965, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:47.599 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172114.857178, idle connection 110582.000000, request 304999.953270 01/05/2026 04:24:47.599 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172114.445068, idle connection 110582.000000, request 304999.545097 01/05/2026 04:24:47.744 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173560.348877, idle connection 112511.000000, request 304398.864508 01/05/2026 04:24:47.744 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6901 01/05/2026 04:24:47.744 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.744 7f8c962fc0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6901 (602.0195484161377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=789189458, topics=[]) 01/05/2026 04:24:47.745 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 789189458 with 0 response partitions (1 implied) 01/05/2026 04:24:47.928 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172787.512207, idle connection 111403.000000, request 304398.972034 01/05/2026 04:24:47.928 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7308 01/05/2026 04:24:47.928 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:47.928 7f8c975bc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7308 (601.7258167266846 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2103054568, topics=[(topics='-uve-topic-21', partitions=[(partition=0, error_code=0, highwater_offset=2374, last_stable_offset=2374, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\tE\x00\x00\x013\x00\x00\x00\x00\x02\xe2sy\x89\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...')])]) 01/05/2026 04:24:47.929 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2103054568 with 1 response partitions (0 implied) 01/05/2026 04:24:47.929 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 319 bytes of data for partition TopicPartition(topic='-uve-topic-21', partition=0) with offset 2373 01/05/2026 04:24:47.929 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2373 for assigned partition TopicPartition(topic='-uve-topic-21', partition=0) 01/05/2026 04:24:47.929 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-21', partition=0) to 2374 (leader epoch 0) 01/05/2026 04:24:47.955 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 610 01/05/2026 04:24:47.956 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 01/05/2026 04:24:47.956 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 01/05/2026 04:24:47.956 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:47.956 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307827436, session_epoch=6923, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:47.956 7f8c962fce00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6945 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307827436, session_epoch=6923, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:47.956 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170551.427734, idle connection 109423.000000, request 304999.937296 01/05/2026 04:24:47.957 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170550.862061, idle connection 109423.000000, request 304999.375582 01/05/2026 04:24:48.030 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2374 01/05/2026 04:24:48.030 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 01/05/2026 04:24:48.030 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-21', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 01/05/2026 04:24:48.030 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:48.030 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2103054568, session_epoch=7296, topics=[(topic='-uve-topic-21', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2374, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.031 7f8c975bc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7309 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2103054568, session_epoch=7296, topics=[(topic='-uve-topic-21', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2374, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.031 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172684.503662, idle connection 111300.000000, request 304999.939442 01/05/2026 04:24:48.031 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172684.015625, idle connection 111299.000000, request 304999.459982 01/05/2026 04:24:48.100 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170807.613770, idle connection 400575.000000, request 304395.065069 01/05/2026 04:24:48.100 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172562.325684, idle connection 111827.000000, request 304395.910025 01/05/2026 04:24:48.101 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7119 01/05/2026 04:24:48.101 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.101 7f8c9676ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7119 (606.6513061523438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=357506000, topics=[]) 01/05/2026 04:24:48.102 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 357506000 with 0 response partitions (1 implied) 01/05/2026 04:24:48.102 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7048 01/05/2026 04:24:48.102 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.102 7f8c975bc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7048 (606.2324047088623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2009812617, topics=[]) 01/05/2026 04:24:48.102 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2009812617 with 0 response partitions (1 implied) 01/05/2026 04:24:48.110 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170017.739990, idle connection 46635.000000, request 304395.934105 01/05/2026 04:24:48.120 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7585 01/05/2026 04:24:48.120 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.120 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7585 (614.4843101501465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=317929160, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=4153, last_stable_offset=4153, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x106\x00\x00\x013\x00\x00\x00\x00\x02:\x8a\x10N\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...')])]) 01/05/2026 04:24:48.120 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 317929160 with 1 response partitions (0 implied) 01/05/2026 04:24:48.121 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 938 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 4150 01/05/2026 04:24:48.121 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4150 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) 01/05/2026 04:24:48.121 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 4153 (leader epoch 0) 01/05/2026 04:24:48.127 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170886.382568, idle connection 348329.000000, request 304396.276951 01/05/2026 04:24:48.134 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7864 01/05/2026 04:24:48.135 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.135 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7864 (611.1047267913818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=248144129, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=4753, last_stable_offset=4753, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x12\x8f\x00\x00\x01#\x00\x00\x00\x00\x02\xd0\x92Q?\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\xe0\x03\x00\x00\x00\xa2\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/05/2026 04:24:48.135 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 248144129 with 1 response partitions (0 implied) 01/05/2026 04:24:48.135 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 606 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 4751 01/05/2026 04:24:48.135 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4751 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 01/05/2026 04:24:48.135 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 4753 (leader epoch 0) 01/05/2026 04:24:48.185 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 475 01/05/2026 04:24:48.185 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 01/05/2026 04:24:48.185 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 01/05/2026 04:24:48.185 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:48.185 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569742206, session_epoch=6930, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.185 7f8c975bc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6947 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569742206, session_epoch=6930, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.186 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174115.684814, idle connection 352397.000000, request 304999.947548 01/05/2026 04:24:48.186 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171125.432129, idle connection 223293.000000, request 304397.436857 01/05/2026 04:24:48.186 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174115.047363, idle connection 352396.000000, request 304999.318361 01/05/2026 04:24:48.186 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6905 01/05/2026 04:24:48.187 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.187 7f8c962fcea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6905 (603.320837020874 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=867358067, topics=[]) 01/05/2026 04:24:48.187 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 867358067 with 0 response partitions (1 implied) 01/05/2026 04:24:48.200 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171514.073730, idle connection 109981.000000, request 304399.170876 01/05/2026 04:24:48.200 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7325 01/05/2026 04:24:48.200 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.200 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7325 (601.294755935669 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1343120360, topics=[(topics='-uve-topic-24', partitions=[(partition=0, error_code=0, highwater_offset=2967, last_stable_offset=2967, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0b\x95\x00\x00\x01(\x00\x00\x00\x00\x028I\x85\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\xea\x03\x00\x00\x00\xac\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 01/05/2026 04:24:48.201 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1343120360 with 1 response partitions (0 implied) 01/05/2026 04:24:48.201 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 607 bytes of data for partition TopicPartition(topic='-uve-topic-24', partition=0) with offset 2965 01/05/2026 04:24:48.201 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2965 for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) 01/05/2026 04:24:48.201 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-24', partition=0) to 2967 (leader epoch 0) 01/05/2026 04:24:48.222 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4153 01/05/2026 04:24:48.222 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/05/2026 04:24:48.222 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 01/05/2026 04:24:48.223 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:48.223 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=317929160, session_epoch=7570, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4153, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.223 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7586 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=317929160, session_epoch=7570, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4153, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.223 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169904.493164, idle connection 46522.000000, request 304999.939919 01/05/2026 04:24:48.223 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169904.058594, idle connection 46521.000000, request 304999.516010 01/05/2026 04:24:48.236 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4753 01/05/2026 04:24:48.236 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/05/2026 04:24:48.236 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 01/05/2026 04:24:48.237 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:48.237 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=248144129, session_epoch=7845, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4753, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.237 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7865 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=248144129, session_epoch=7845, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4753, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.237 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170776.669922, idle connection 348220.000000, request 304999.945879 01/05/2026 04:24:48.237 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170776.276367, idle connection 348219.000000, request 304999.557972 01/05/2026 04:24:48.302 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 2967 01/05/2026 04:24:48.302 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 01/05/2026 04:24:48.302 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-24', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 01/05/2026 04:24:48.303 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:48.303 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1343120360, session_epoch=7308, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2967, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.303 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7326 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1343120360, session_epoch=7308, topics=[(topic='-uve-topic-24', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2967, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/05/2026 04:24:48.303 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171410.789795, idle connection 109878.000000, request 304999.941826 01/05/2026 04:24:48.304 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171410.391846, idle connection 109878.000000, request 304999.552250 01/05/2026 04:24:48.345 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 225 01/05/2026 04:24:48.346 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 01/05/2026 04:24:48.346 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 01/05/2026 04:24:48.346 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:48.346 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=789189458, session_epoch=6887, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.346 7f8c962fc0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6902 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=789189458, session_epoch=6887, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.346 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172957.641846, idle connection 111909.000000, request 304999.940395 01/05/2026 04:24:48.347 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172957.210205, idle connection 111908.000000, request 304999.516487 01/05/2026 04:24:48.558 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169950.210205, idle connection 108822.000000, request 304398.717880 01/05/2026 04:24:48.558 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6945 01/05/2026 04:24:48.558 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.558 7f8c962fce00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6945 (601.8893718719482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307827436, topics=[]) 01/05/2026 04:24:48.558 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307827436 with 0 response partitions (1 implied) 01/05/2026 04:24:48.636 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172079.347168, idle connection 110695.000000, request 304394.781828 01/05/2026 04:24:48.636 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7309 01/05/2026 04:24:48.636 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.636 7f8c975bc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7309 (605.7977676391602 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2103054568, topics=[]) 01/05/2026 04:24:48.637 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2103054568 with 0 response partitions (1 implied) 01/05/2026 04:24:48.702 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1591 01/05/2026 04:24:48.703 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 01/05/2026 04:24:48.703 7f8c9676ccc0 [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)]) 01/05/2026 04:24:48.703 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:48.703 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=357506000, session_epoch=7101, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.703 7f8c9676ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=357506000, session_epoch=7101, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.703 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170204.004883, idle connection 399972.000000, request 304999.942780 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 922 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2009812617, session_epoch=7033, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7049 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2009812617, session_epoch=7033, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.704 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171958.084229, idle connection 111223.000000, request 304999.957323 01/05/2026 04:24:48.705 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170202.806885, idle connection 399971.000000, request 304998.753786 01/05/2026 04:24:48.705 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171957.427246, idle connection 111223.000000, request 304999.305248 01/05/2026 04:24:48.787 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 245 01/05/2026 04:24:48.788 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/05/2026 04:24:48.788 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 01/05/2026 04:24:48.788 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:48.788 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867358067, session_epoch=6890, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.788 7f8c962fcea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6906 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867358067, session_epoch=6890, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:48.788 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170523.010254, idle connection 222691.000000, request 304999.943495 01/05/2026 04:24:48.789 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173512.732910, idle connection 351794.000000, request 304397.001743 01/05/2026 04:24:48.789 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170522.390137, idle connection 222690.000000, request 304999.332428 01/05/2026 04:24:48.789 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6947 01/05/2026 04:24:48.789 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.789 7f8c975bc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6947 (603.7838459014893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1569742206, topics=[]) 01/05/2026 04:24:48.789 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1569742206 with 0 response partitions (1 implied) 01/05/2026 04:24:48.824 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169303.432373, idle connection 45921.000000, request 304398.884058 01/05/2026 04:24:48.824 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7586 01/05/2026 04:24:48.824 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.825 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7586 (601.5949249267578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=317929160, topics=[]) 01/05/2026 04:24:48.825 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 317929160 with 0 response partitions (1 implied) 01/05/2026 04:24:48.838 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170175.355957, idle connection 347618.000000, request 304398.631811 01/05/2026 04:24:48.839 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7865 01/05/2026 04:24:48.839 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.839 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7865 (601.8533706665039 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=248144129, topics=[]) 01/05/2026 04:24:48.839 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 248144129 with 0 response partitions (1 implied) 01/05/2026 04:24:48.904 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170809.537598, idle connection 109277.000000, request 304398.690462 01/05/2026 04:24:48.905 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7326 01/05/2026 04:24:48.905 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.905 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7326 (601.8571853637695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1343120360, topics=[]) 01/05/2026 04:24:48.905 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1343120360 with 0 response partitions (1 implied) 01/05/2026 04:24:48.948 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172356.322266, idle connection 111307.000000, request 304398.621321 01/05/2026 04:24:48.948 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6902 01/05/2026 04:24:48.948 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:48.948 7f8c962fc0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6902 (601.9411087036133 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=789189458, topics=[]) 01/05/2026 04:24:48.948 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 789189458 with 0 response partitions (1 implied) 01/05/2026 04:24:49.159 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 610 01/05/2026 04:24:49.160 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 01/05/2026 04:24:49.160 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 01/05/2026 04:24:49.160 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:49.160 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307827436, session_epoch=6924, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.160 7f8c962fce00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6946 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1307827436, session_epoch=6924, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.160 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169347.610596, idle connection 108220.000000, request 304999.942541 01/05/2026 04:24:49.161 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169347.173584, idle connection 108219.000000, request 304999.513865 01/05/2026 04:24:49.237 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2374 01/05/2026 04:24:49.237 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 01/05/2026 04:24:49.237 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 01/05/2026 04:24:49.237 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:49.238 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2103054568, session_epoch=7297, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.238 7f8c975bc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7310 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2103054568, session_epoch=7297, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.238 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171477.264404, idle connection 110093.000000, request 304999.927759 01/05/2026 04:24:49.239 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171476.610596, idle connection 110092.000000, request 304999.281883 01/05/2026 04:24:49.305 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169602.041504, idle connection 399370.000000, request 304397.979736 01/05/2026 04:24:49.306 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7120 01/05/2026 04:24:49.306 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:49.306 7f8c9676ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7120 (602.5776863098145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=357506000, topics=[]) 01/05/2026 04:24:49.306 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 357506000 with 0 response partitions (1 implied) 01/05/2026 04:24:49.306 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171355.978516, idle connection 110621.000000, request 304397.853613 01/05/2026 04:24:49.306 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7049 01/05/2026 04:24:49.307 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:49.307 7f8c975bc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7049 (602.4775505065918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2009812617, topics=[]) 01/05/2026 04:24:49.307 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2009812617 with 0 response partitions (1 implied) 01/05/2026 04:24:49.390 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 475 01/05/2026 04:24:49.390 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 01/05/2026 04:24:49.390 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 01/05/2026 04:24:49.390 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:49.390 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569742206, session_epoch=6931, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.391 7f8c975bc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6948 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1569742206, session_epoch=6931, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.391 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172910.601562, idle connection 351192.000000, request 304999.944210 01/05/2026 04:24:49.391 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169920.347168, idle connection 222088.000000, request 304397.286654 01/05/2026 04:24:49.391 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172909.982422, idle connection 351191.000000, request 304999.333858 01/05/2026 04:24:49.392 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6906 01/05/2026 04:24:49.392 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:49.392 7f8c962fcea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6906 (603.4581661224365 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=867358067, topics=[]) 01/05/2026 04:24:49.392 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 867358067 with 0 response partitions (1 implied) 01/05/2026 04:24:49.426 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4153 01/05/2026 04:24:49.426 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/05/2026 04:24:49.426 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 01/05/2026 04:24:49.426 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:49.426 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=317929160, session_epoch=7571, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.427 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7587 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=317929160, session_epoch=7571, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.427 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168700.838623, idle connection 45318.000000, request 304999.926090 01/05/2026 04:24:49.427 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168700.205566, idle connection 45317.000000, request 304999.304295 01/05/2026 04:24:49.440 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4753 01/05/2026 04:24:49.440 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/05/2026 04:24:49.440 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 01/05/2026 04:24:49.440 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/05/2026 04:24:49.440 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=248144129, session_epoch=7846, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.441 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7866 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=248144129, session_epoch=7846, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.441 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169573.005127, idle connection 347016.000000, request 304999.943018 01/05/2026 04:24:49.441 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169572.515869, idle connection 347015.000000, request 304999.459267 01/05/2026 04:24:49.506 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 2967 01/05/2026 04:24:49.506 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 01/05/2026 04:24:49.507 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 01/05/2026 04:24:49.507 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:49.507 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1343120360, session_epoch=7309, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.507 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7327 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1343120360, session_epoch=7309, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.507 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170206.708252, idle connection 108674.000000, request 304999.928236 01/05/2026 04:24:49.508 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170206.189697, idle connection 108673.000000, request 304999.421358 01/05/2026 04:24:49.550 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 225 01/05/2026 04:24:49.550 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 01/05/2026 04:24:49.550 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 01/05/2026 04:24:49.550 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:49.551 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=789189458, session_epoch=6888, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.551 7f8c962fc0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6903 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=789189458, session_epoch=6888, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.551 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171752.980957, idle connection 110704.000000, request 304999.927282 01/05/2026 04:24:49.552 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171752.362549, idle connection 110703.000000, request 304999.320030 01/05/2026 04:24:49.761 7f8c962fce00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168746.619629, idle connection 107619.000000, request 304398.950577 01/05/2026 04:24:49.762 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6946 01/05/2026 04:24:49.762 7f8c962fce00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:49.762 7f8c962fce00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6946 (601.6855239868164 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1307827436, topics=[]) 01/05/2026 04:24:49.762 7f8c962fce00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1307827436 with 0 response partitions (1 implied) 01/05/2026 04:24:49.839 7f8c975bc400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170876.007324, idle connection 109491.000000, request 304398.669720 01/05/2026 04:24:49.840 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7310 01/05/2026 04:24:49.840 7f8c975bc400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:49.840 7f8c975bc400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7310 (601.8712520599365 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2103054568, topics=[]) 01/05/2026 04:24:49.840 7f8c975bc400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2103054568 with 0 response partitions (1 implied) 01/05/2026 04:24:49.907 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1591 01/05/2026 04:24:49.908 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 01/05/2026 04:24:49.908 7f8c9676ccc0 [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)]) 01/05/2026 04:24:49.908 7f8c9676ccc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:49.908 7f8c9676ccc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=357506000, session_epoch=7102, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.908 7f8c9676ccc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7121 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=357506000, session_epoch=7102, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.908 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168999.077148, idle connection 398767.000000, request 304999.942780 01/05/2026 04:24:49.908 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 922 01/05/2026 04:24:49.909 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/05/2026 04:24:49.909 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 01/05/2026 04:24:49.909 7f8c975bc2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/05/2026 04:24:49.909 7f8c975bc2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2009812617, session_epoch=7034, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.909 7f8c975bc2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7050 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2009812617, session_epoch=7034, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.909 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170753.204590, idle connection 110018.000000, request 304999.960661 01/05/2026 04:24:49.909 7f8c9676ccc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168997.923340, idle connection 398766.000000, request 304998.798132 01/05/2026 04:24:49.910 7f8c975bc2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 170752.538574, idle connection 110018.000000, request 304999.298811 01/05/2026 04:24:49.993 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 245 01/05/2026 04:24:49.993 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/05/2026 04:24:49.993 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 01/05/2026 04:24:49.993 7f8c962fcea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/05/2026 04:24:49.993 7f8c962fcea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867358067, session_epoch=6891, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.994 7f8c962fcea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6907 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867358067, session_epoch=6891, topics=[], forgotten_topics_data=[]) 01/05/2026 04:24:49.994 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169317.441650, idle connection 221485.000000, request 304999.923706 01/05/2026 04:24:49.994 7f8c975bc040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172307.067627, idle connection 350588.000000, request 304396.415234 01/05/2026 04:24:49.995 7f8c962fcea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169316.656250, idle connection 221485.000000, request 304999.147177 01/05/2026 04:24:49.995 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6948 01/05/2026 04:24:49.995 7f8c975bc040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:49.995 7f8c975bc040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6948 (604.6020984649658 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1569742206, topics=[]) 01/05/2026 04:24:49.995 7f8c975bc040 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1569742206 with 0 response partitions (1 implied) 01/05/2026 04:24:50.028 7f8c975bc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168099.084717, idle connection 44716.000000, request 304398.181200 01/05/2026 04:24:50.029 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7587 01/05/2026 04:24:50.029 7f8c975bc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:50.029 7f8c975bc9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7587 (602.3068428039551 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=317929160, topics=[]) 01/05/2026 04:24:50.029 7f8c975bc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 317929160 with 0 response partitions (1 implied) 01/05/2026 04:24:50.043 7f8c975bc5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 168970.993408, idle connection 346414.000000, request 304397.934198 01/05/2026 04:24:50.043 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7866 01/05/2026 04:24:50.043 7f8c975bc5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:50.043 7f8c975bc5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7866 (602.4746894836426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=248144129, topics=[]) 01/05/2026 04:24:50.043 7f8c975bc5e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 248144129 with 0 response partitions (1 implied) 01/05/2026 04:24:50.109 7f8c975bc860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 169604.659912, idle connection 108072.000000, request 304397.886276 01/05/2026 04:24:50.110 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7327 01/05/2026 04:24:50.110 7f8c975bc860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:50.110 7f8c975bc860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7327 (602.6356220245361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1343120360, topics=[]) 01/05/2026 04:24:50.110 7f8c975bc860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1343120360 with 0 response partitions (1 implied) 01/05/2026 04:24:50.153 7f8c962fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 171151.383545, idle connection 110102.000000, request 304398.336411 01/05/2026 04:24:50.153 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6903 01/05/2026 04:24:50.153 7f8c962fc0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/05/2026 04:24:50.153 7f8c962fc0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6903 (602.1699905395508 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=789189458, topics=[]) 01/05/2026 04:24:50.153 7f8c962fc0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 789189458 with 0 response partitions (1 implied)