07/28/2025 02:31:24.900 7fa5e5778438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 716 (603.6021709442139 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=319414245, topics=[]) 07/28/2025 02:31:24.901 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 319414245 with 0 response partitions (1 implied) 07/28/2025 02:31:24.918 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 18 07/28/2025 02:31:24.919 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 07/28/2025 02:31:24.919 7fa5e6284a20 [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)]) 07/28/2025 02:31:24.919 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:24.919 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1915679017, session_epoch=678, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:24.919 7fa5e6284a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1915679017, session_epoch=678, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:24.919 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88638.393311, idle connection 265986.000000, request 304999.929667 07/28/2025 02:31:24.920 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88637.894775, idle connection 265985.000000, request 304999.432802 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 11 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=80388427, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 679 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=80388427, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:24.929 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88668.017334, idle connection 266030.000000, request 304999.942303 07/28/2025 02:31:24.930 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89022.823486, idle connection 266407.000000, request 304397.246361 07/28/2025 02:31:24.930 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88667.370117, idle connection 266029.000000, request 304999.301910 07/28/2025 02:31:24.930 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 741 07/28/2025 02:31:24.930 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:24.930 7fa5e593e240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 741 (603.5995483398438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1222969371, topics=[]) 07/28/2025 02:31:24.931 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1222969371 with 0 response partitions (1 implied) 07/28/2025 02:31:25.010 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88939.854980, idle connection 266566.000000, request 304398.452997 07/28/2025 02:31:25.010 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 756 07/28/2025 02:31:25.010 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.010 7fa5e58998d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 756 (602.308988571167 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1099027523, topics=[]) 07/28/2025 02:31:25.011 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1099027523 with 0 response partitions (1 implied) 07/28/2025 02:31:25.061 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89205.145752, idle connection 267099.000000, request 304398.780584 07/28/2025 02:31:25.061 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 701 07/28/2025 02:31:25.061 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.061 7fa5e628f588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 701 (601.7780303955078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1670241337, topics=[]) 07/28/2025 02:31:25.062 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1670241337 with 0 response partitions (1 implied) 07/28/2025 02:31:25.105 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 28 07/28/2025 02:31:25.105 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 07/28/2025 02:31:25.105 7fa5e61e5240 [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)]) 07/28/2025 02:31:25.105 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.105 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879929184, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.105 7fa5e61e5240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879929184, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.106 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88073.070312, idle connection 265868.000000, request 304999.942541 07/28/2025 02:31:25.106 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88072.651367, idle connection 265868.000000, request 304999.531507 07/28/2025 02:31:25.106 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 313 07/28/2025 02:31:25.106 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 07/28/2025 02:31:25.107 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 07/28/2025 02:31:25.107 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.107 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=6280536, session_epoch=728, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.107 7fa5e57b2780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 732 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=6280536, session_epoch=728, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.107 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89027.717041, idle connection 266485.000000, request 304999.943733 07/28/2025 02:31:25.107 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89027.379639, idle connection 266485.000000, request 304999.610186 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3773 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1047, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1051 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1047, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.116 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88487.196777, idle connection 266494.000000, request 304999.946833 07/28/2025 02:31:25.117 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88486.805908, idle connection 266493.000000, request 304999.561787 07/28/2025 02:31:25.135 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 64 07/28/2025 02:31:25.136 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 07/28/2025 02:31:25.136 7fa5e5933eb8 [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)]) 07/28/2025 02:31:25.136 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.136 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1783325526, session_epoch=688, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.136 7fa5e5933eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1783325526, session_epoch=688, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.136 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88618.428467, idle connection 266064.000000, request 304999.940395 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=920524365, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=920524365, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.137 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88649.361328, idle connection 266028.000000, request 304999.958515 07/28/2025 02:31:25.137 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88617.246338, idle connection 266063.000000, request 304998.766422 07/28/2025 02:31:25.138 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88648.594482, idle connection 266027.000000, request 304999.194860 07/28/2025 02:31:25.152 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88054.584961, idle connection 265919.000000, request 304398.303986 07/28/2025 02:31:25.153 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 07/28/2025 02:31:25.153 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.153 7fa5e6242390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (602.2012233734131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=438116716, topics=[]) 07/28/2025 02:31:25.153 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 438116716 with 0 response partitions (1 implied) 07/28/2025 02:31:25.206 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88996.575928, idle connection 267200.000000, request 304398.137331 07/28/2025 02:31:25.206 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 07/28/2025 02:31:25.206 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.206 7fa5e5485240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 710 (602.4167537689209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=278134106, topics=[]) 07/28/2025 02:31:25.207 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 278134106 with 0 response partitions (1 implied) 07/28/2025 02:31:25.207 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 91 07/28/2025 02:31:25.207 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 07/28/2025 02:31:25.207 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 07/28/2025 02:31:25.207 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.207 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1357566540, session_epoch=696, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.207 7fa5e54a8ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 700 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1357566540, session_epoch=696, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.208 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89562.113281, idle connection 266690.000000, request 304999.947548 07/28/2025 02:31:25.208 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89561.663086, idle connection 266690.000000, request 304999.501705 07/28/2025 02:31:25.239 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89194.188965, idle connection 266529.000000, request 304395.150185 07/28/2025 02:31:25.239 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 07/28/2025 02:31:25.239 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.239 7fa5e61e2240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (605.3717136383057 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=197425454, topics=[]) 07/28/2025 02:31:25.239 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 197425454 with 0 response partitions (1 implied) 07/28/2025 02:31:25.240 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88008.371094, idle connection 266567.000000, request 304395.329237 07/28/2025 02:31:25.240 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89397.831055, idle connection 266038.000000, request 304396.370888 07/28/2025 02:31:25.240 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 07/28/2025 02:31:25.240 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.240 7fa5e61c3588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (605.1356792449951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677633217, topics=[]) 07/28/2025 02:31:25.240 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677633217 with 0 response partitions (1 implied) 07/28/2025 02:31:25.240 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 733 07/28/2025 02:31:25.240 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.241 7fa5e62f5048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 733 (604.4661998748779 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300324484, topics=[]) 07/28/2025 02:31:25.241 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300324484 with 0 response partitions (1 implied) 07/28/2025 02:31:25.252 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88912.612793, idle connection 266544.000000, request 304398.458958 07/28/2025 02:31:25.253 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 705 07/28/2025 02:31:25.253 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.253 7fa5e58cc048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 705 (602.0939350128174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=4518980, topics=[]) 07/28/2025 02:31:25.253 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 4518980 with 0 response partitions (1 implied) 07/28/2025 02:31:25.280 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88840.773438, idle connection 266286.000000, request 304398.904562 07/28/2025 02:31:25.281 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 698 07/28/2025 02:31:25.281 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.281 7fa5e573c6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 698 (601.6125679016113 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=70999304, topics=[]) 07/28/2025 02:31:25.281 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 70999304 with 0 response partitions (1 implied) 07/28/2025 02:31:25.288 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88475.099609, idle connection 266006.000000, request 304399.054050 07/28/2025 02:31:25.288 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 07/28/2025 02:31:25.288 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.288 7fa5e62beac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.3381481170654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=186045572, topics=[]) 07/28/2025 02:31:25.288 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 186045572 with 0 response partitions (1 implied) 07/28/2025 02:31:25.378 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 89175.419678, idle connection 265415.000000, request 304398.893356 07/28/2025 02:31:25.378 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 07/28/2025 02:31:25.379 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.379 7fa5e62e42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (601.895809173584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1122986152, topics=[]) 07/28/2025 02:31:25.379 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1122986152 with 0 response partitions (1 implied) 07/28/2025 02:31:25.436 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87918.921631, idle connection 265298.000000, request 304398.919344 07/28/2025 02:31:25.436 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 677 07/28/2025 02:31:25.436 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.436 7fa5e88c9780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 677 (601.8054485321045 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=75571364, topics=[]) 07/28/2025 02:31:25.436 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 75571364 with 0 response partitions (1 implied) 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 252 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=974989986, session_epoch=734, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 738 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=974989986, session_epoch=734, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.439 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88160.758301, idle connection 266128.000000, request 304999.947548 07/28/2025 02:31:25.440 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87970.888916, idle connection 265352.000000, request 304397.617817 07/28/2025 02:31:25.440 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88160.145020, idle connection 266127.000000, request 304999.340057 07/28/2025 02:31:25.440 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 677 07/28/2025 02:31:25.440 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.441 7fa5e62be2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 677 (603.1007766723633 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349167670, topics=[]) 07/28/2025 02:31:25.441 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1349167670 with 0 response partitions (1 implied) 07/28/2025 02:31:25.461 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88004.874756, idle connection 265365.000000, request 304398.622751 07/28/2025 02:31:25.462 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 677 07/28/2025 02:31:25.462 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.462 7fa5e61bdc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 677 (602.1835803985596 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609648681, topics=[]) 07/28/2025 02:31:25.463 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609648681 with 0 response partitions (1 implied) 07/28/2025 02:31:25.463 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 16 07/28/2025 02:31:25.463 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 07/28/2025 02:31:25.463 7fa5e79e2c18 [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)]) 07/28/2025 02:31:25.463 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.464 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=823660160, session_epoch=679, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.464 7fa5e79e2c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=823660160, session_epoch=679, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.464 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88597.548584, idle connection 265950.000000, request 304999.912262 07/28/2025 02:31:25.464 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 177 07/28/2025 02:31:25.464 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 07/28/2025 02:31:25.465 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 07/28/2025 02:31:25.465 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.465 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389960446, session_epoch=712, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.465 7fa5e54b8eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 716 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389960446, session_epoch=712, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.465 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88963.793213, idle connection 265981.000000, request 304999.907017 07/28/2025 02:31:25.466 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88595.839600, idle connection 265948.000000, request 304998.216152 07/28/2025 02:31:25.466 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88962.726562, idle connection 265980.000000, request 304998.855829 07/28/2025 02:31:25.481 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88953.439941, idle connection 265194.000000, request 304398.972750 07/28/2025 02:31:25.482 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 720 07/28/2025 02:31:25.482 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.482 7fa5e59bb0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 720 (601.5722751617432 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458489424, topics=[]) 07/28/2025 02:31:25.482 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458489424 with 0 response partitions (1 implied) 07/28/2025 02:31:25.499 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 35 07/28/2025 02:31:25.499 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 07/28/2025 02:31:25.499 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 07/28/2025 02:31:25.499 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.500 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=705023370, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.500 7fa5e61ed438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=705023370, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.500 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87909.051514, idle connection 266498.000000, request 304999.944448 07/28/2025 02:31:25.500 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 24 07/28/2025 02:31:25.500 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 07/28/2025 02:31:25.500 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 07/28/2025 02:31:25.500 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.500 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=153234809, session_epoch=682, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.501 7fa5e61e50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=153234809, session_epoch=682, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.501 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88066.204834, idle connection 265915.000000, request 304999.952793 07/28/2025 02:31:25.501 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87907.628418, idle connection 266497.000000, request 304998.527765 07/28/2025 02:31:25.501 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 174 07/28/2025 02:31:25.502 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 07/28/2025 02:31:25.502 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 07/28/2025 02:31:25.502 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.502 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=319414245, session_epoch=713, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.502 7fa5e5778438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 717 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=319414245, session_epoch=713, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.502 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88384.384277, idle connection 266074.000000, request 304999.957085 07/28/2025 02:31:25.502 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88064.446777, idle connection 265913.000000, request 304998.199224 07/28/2025 02:31:25.503 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88383.544434, idle connection 266074.000000, request 304999.119759 07/28/2025 02:31:25.520 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88037.319092, idle connection 265385.000000, request 304398.856878 07/28/2025 02:31:25.521 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 682 07/28/2025 02:31:25.521 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.521 7fa5e6284a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 682 (601.6490459442139 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1915679017, topics=[]) 07/28/2025 02:31:25.521 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1915679017 with 0 response partitions (1 implied) 07/28/2025 02:31:25.531 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 270 07/28/2025 02:31:25.531 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 07/28/2025 02:31:25.531 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 07/28/2025 02:31:25.531 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.531 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222969371, session_epoch=738, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.532 7fa5e593e240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 742 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222969371, session_epoch=738, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.532 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88420.745361, idle connection 265805.000000, request 304999.945641 07/28/2025 02:31:25.532 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88065.420410, idle connection 265428.000000, request 304397.351503 07/28/2025 02:31:25.532 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88420.167236, idle connection 265804.000000, request 304999.374866 07/28/2025 02:31:25.532 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 679 07/28/2025 02:31:25.533 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.533 7fa5e591ff60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 679 (603.3658981323242 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=80388427, topics=[]) 07/28/2025 02:31:25.533 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 80388427 with 0 response partitions (1 implied) 07/28/2025 02:31:25.611 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 476 07/28/2025 02:31:25.611 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 07/28/2025 02:31:25.611 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 07/28/2025 02:31:25.611 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.612 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1099027523, session_epoch=753, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.612 7fa5e58998d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 757 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1099027523, session_epoch=753, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.612 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88337.344482, idle connection 265964.000000, request 304999.911308 07/28/2025 02:31:25.613 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88336.704102, idle connection 265963.000000, request 304999.281883 07/28/2025 02:31:25.662 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 102 07/28/2025 02:31:25.662 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 07/28/2025 02:31:25.662 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 07/28/2025 02:31:25.662 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.662 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1670241337, session_epoch=698, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.663 7fa5e628f588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 702 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1670241337, session_epoch=698, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.663 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88603.075439, idle connection 266497.000000, request 304999.933481 07/28/2025 02:31:25.663 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88602.605469, idle connection 266496.000000, request 304999.472618 07/28/2025 02:31:25.707 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87471.613770, idle connection 265267.000000, request 304398.485422 07/28/2025 02:31:25.708 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 07/28/2025 02:31:25.708 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.708 7fa5e61e5240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (602.1132469177246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=879929184, topics=[]) 07/28/2025 02:31:25.708 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 879929184 with 0 response partitions (1 implied) 07/28/2025 02:31:25.708 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88426.586670, idle connection 265884.000000, request 304398.808002 07/28/2025 02:31:25.709 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 732 07/28/2025 02:31:25.709 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.709 7fa5e57b2780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 732 (601.6016006469727 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=6280536, topics=[]) 07/28/2025 02:31:25.709 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 6280536 with 0 response partitions (1 implied) 07/28/2025 02:31:25.717 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87886.306152, idle connection 265893.000000, request 304399.051428 07/28/2025 02:31:25.718 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1051 07/28/2025 02:31:25.718 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.718 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1051 (601.6204357147217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529149950, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3774, last_stable_offset=3774, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xbd\x00\x00\x01\x04\x00\x00\x00\x00\x02\xcaFd\xe8\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\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 07/28/2025 02:31:25.718 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529149950 with 1 response partitions (0 implied) 07/28/2025 02:31:25.719 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3773 07/28/2025 02:31:25.719 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3773 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 07/28/2025 02:31:25.719 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3774 (leader epoch 0) 07/28/2025 02:31:25.739 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88016.210938, idle connection 265462.000000, request 304397.722483 07/28/2025 02:31:25.739 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 07/28/2025 02:31:25.739 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.739 7fa5e5933eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 692 (602.8189659118652 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1783325526, topics=[]) 07/28/2025 02:31:25.739 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1783325526 with 0 response partitions (1 implied) 07/28/2025 02:31:25.740 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88046.809814, idle connection 265425.000000, request 304397.405863 07/28/2025 02:31:25.740 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 07/28/2025 02:31:25.740 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.740 7fa5e62c3390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (602.9646396636963 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=920524365, topics=[]) 07/28/2025 02:31:25.740 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 920524365 with 0 response partitions (1 implied) 07/28/2025 02:31:25.753 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 38 07/28/2025 02:31:25.754 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 07/28/2025 02:31:25.754 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 07/28/2025 02:31:25.754 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.754 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=438116716, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.754 7fa5e6242390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=438116716, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.755 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87452.284912, idle connection 265317.000000, request 304999.936104 07/28/2025 02:31:25.755 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87451.840332, idle connection 265316.000000, request 304999.500751 07/28/2025 02:31:25.807 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 182 07/28/2025 02:31:25.807 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 07/28/2025 02:31:25.807 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 07/28/2025 02:31:25.807 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.808 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=278134106, session_epoch=707, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.808 7fa5e5485240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 711 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=278134106, session_epoch=707, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.808 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88394.472900, idle connection 266598.000000, request 304999.937296 07/28/2025 02:31:25.809 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88393.922363, idle connection 266597.000000, request 304999.395132 07/28/2025 02:31:25.809 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88960.896973, idle connection 266089.000000, request 304398.735523 07/28/2025 02:31:25.809 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 700 07/28/2025 02:31:25.809 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:25.809 7fa5e54a8ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 700 (601.7169952392578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1357566540, topics=[]) 07/28/2025 02:31:25.809 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1357566540 with 0 response partitions (1 implied) 07/28/2025 02:31:25.820 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3774 07/28/2025 02:31:25.820 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 07/28/2025 02:31:25.820 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 07/28/2025 02:31:25.820 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.820 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1048, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3774, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:25.821 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1052 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1048, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3774, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:25.821 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87782.912598, idle connection 265789.000000, request 304999.943972 07/28/2025 02:31:25.821 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87782.487549, idle connection 265789.000000, request 304999.523640 07/28/2025 02:31:25.840 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 27 07/28/2025 02:31:25.840 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 07/28/2025 02:31:25.840 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 07/28/2025 02:31:25.840 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.840 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=197425454, session_epoch=679, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.840 7fa5e61e2240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=197425454, session_epoch=679, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.841 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88592.115967, idle connection 265927.000000, request 304999.931097 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 14 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677633217, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677633217, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.841 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87406.408203, idle connection 265965.000000, request 304999.950886 07/28/2025 02:31:25.842 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88590.627197, idle connection 265925.000000, request 304998.448610 07/28/2025 02:31:25.842 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 283 07/28/2025 02:31:25.842 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 07/28/2025 02:31:25.843 7fa5e62f5048 [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)]) 07/28/2025 02:31:25.843 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.843 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300324484, session_epoch=730, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.843 7fa5e62f5048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 734 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300324484, session_epoch=730, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.843 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88794.466309, idle connection 265434.000000, request 304999.928951 07/28/2025 02:31:25.843 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87404.428467, idle connection 265963.000000, request 304997.977495 07/28/2025 02:31:25.844 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88793.567139, idle connection 265433.000000, request 304999.034882 07/28/2025 02:31:25.853 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 105 07/28/2025 02:31:25.854 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 07/28/2025 02:31:25.854 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 07/28/2025 02:31:25.854 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.854 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4518980, session_epoch=702, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.854 7fa5e58cc048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 706 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4518980, session_epoch=702, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.854 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88310.840576, idle connection 265942.000000, request 304999.948502 07/28/2025 02:31:25.855 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88310.332031, idle connection 265942.000000, request 304999.444485 07/28/2025 02:31:25.881 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 81 07/28/2025 02:31:25.881 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 07/28/2025 02:31:25.881 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 07/28/2025 02:31:25.882 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.882 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=70999304, session_epoch=695, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.882 7fa5e573c6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 699 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=70999304, session_epoch=695, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.882 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88238.862793, idle connection 265684.000000, request 304999.938250 07/28/2025 02:31:25.883 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88238.364258, idle connection 265684.000000, request 304999.448538 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 63 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=186045572, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=186045572, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.889 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87873.533203, idle connection 265405.000000, request 304999.947786 07/28/2025 02:31:25.890 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87873.154785, idle connection 265404.000000, request 304999.574423 07/28/2025 02:31:25.979 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 25 07/28/2025 02:31:25.980 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 07/28/2025 02:31:25.980 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 07/28/2025 02:31:25.980 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:25.980 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1122986152, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.980 7fa5e62e42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1122986152, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:25.980 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88573.131104, idle connection 264812.000000, request 304999.922037 07/28/2025 02:31:25.981 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88572.527100, idle connection 264812.000000, request 304999.333143 07/28/2025 02:31:26.037 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 07/28/2025 02:31:26.037 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 07/28/2025 02:31:26.037 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 07/28/2025 02:31:26.037 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.037 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=75571364, session_epoch=674, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.038 7fa5e88c9780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 678 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=75571364, session_epoch=674, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.038 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87316.763672, idle connection 264696.000000, request 304999.942064 07/28/2025 02:31:26.038 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87316.208740, idle connection 264696.000000, request 304999.394417 07/28/2025 02:31:26.041 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 07/28/2025 02:31:26.041 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 07/28/2025 02:31:26.041 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 07/28/2025 02:31:26.041 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.042 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349167670, session_epoch=674, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.042 7fa5e62be2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 678 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349167670, session_epoch=674, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.042 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87368.751465, idle connection 264750.000000, request 304999.927044 07/28/2025 02:31:26.042 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87557.982910, idle connection 265525.000000, request 304397.168636 07/28/2025 02:31:26.043 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87367.907959, idle connection 264749.000000, request 304999.088287 07/28/2025 02:31:26.043 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 738 07/28/2025 02:31:26.043 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.043 7fa5e62936d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 738 (603.9729118347168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=974989986, topics=[]) 07/28/2025 02:31:26.044 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 974989986 with 0 response partitions (1 implied) 07/28/2025 02:31:26.063 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 07/28/2025 02:31:26.063 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 07/28/2025 02:31:26.064 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 07/28/2025 02:31:26.064 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.064 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609648681, session_epoch=674, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.064 7fa5e61bdc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 678 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609648681, session_epoch=674, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.064 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87402.019287, idle connection 264762.000000, request 304999.915838 07/28/2025 02:31:26.065 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87401.395020, idle connection 264762.000000, request 304999.301672 07/28/2025 02:31:26.067 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87994.552490, idle connection 265347.000000, request 304396.928310 07/28/2025 02:31:26.067 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 07/28/2025 02:31:26.067 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.068 7fa5e79e2c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (603.7204265594482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=823660160, topics=[]) 07/28/2025 02:31:26.068 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 823660160 with 0 response partitions (1 implied) 07/28/2025 02:31:26.068 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88360.743164, idle connection 265378.000000, request 304396.869659 07/28/2025 02:31:26.068 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 716 07/28/2025 02:31:26.069 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.069 7fa5e54b8eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 716 (603.6312580108643 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1389960446, topics=[]) 07/28/2025 02:31:26.069 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1389960446 with 0 response partitions (1 implied) 07/28/2025 02:31:26.083 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 07/28/2025 02:31:26.083 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 07/28/2025 02:31:26.083 7fa5e59bb0f0 [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)]) 07/28/2025 02:31:26.083 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.083 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458489424, session_epoch=717, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.083 7fa5e59bb0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 721 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458489424, session_epoch=717, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.084 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88351.183350, idle connection 264591.000000, request 304999.919415 07/28/2025 02:31:26.084 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88350.594482, idle connection 264591.000000, request 304999.340057 07/28/2025 02:31:26.103 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87305.885742, idle connection 265895.000000, request 304396.777153 07/28/2025 02:31:26.103 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 07/28/2025 02:31:26.103 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.104 7fa5e61ed438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (603.7731170654297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=705023370, topics=[]) 07/28/2025 02:31:26.104 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 705023370 with 0 response partitions (1 implied) 07/28/2025 02:31:26.104 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87462.937256, idle connection 265311.000000, request 304396.688700 07/28/2025 02:31:26.104 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87782.295166, idle connection 265472.000000, request 304397.870302 07/28/2025 02:31:26.104 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 686 07/28/2025 02:31:26.104 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.104 7fa5e61e50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 686 (603.7886142730713 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=153234809, topics=[]) 07/28/2025 02:31:26.105 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 153234809 with 0 response partitions (1 implied) 07/28/2025 02:31:26.105 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 717 07/28/2025 02:31:26.105 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.105 7fa5e5778438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 717 (602.9489040374756 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=319414245, topics=[]) 07/28/2025 02:31:26.105 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 319414245 with 0 response partitions (1 implied) 07/28/2025 02:31:26.121 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 18 07/28/2025 02:31:26.122 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 07/28/2025 02:31:26.122 7fa5e6284a20 [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)]) 07/28/2025 02:31:26.122 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.122 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1915679017, session_epoch=679, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.122 7fa5e6284a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1915679017, session_epoch=679, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.122 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87435.526123, idle connection 264783.000000, request 304999.947309 07/28/2025 02:31:26.122 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87435.086914, idle connection 264783.000000, request 304999.513626 07/28/2025 02:31:26.133 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 11 07/28/2025 02:31:26.133 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 07/28/2025 02:31:26.133 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 07/28/2025 02:31:26.133 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.133 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=80388427, session_epoch=676, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.134 7fa5e591ff60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=80388427, session_epoch=676, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.134 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87463.608154, idle connection 264826.000000, request 304999.950171 07/28/2025 02:31:26.134 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87818.464111, idle connection 265203.000000, request 304397.670031 07/28/2025 02:31:26.134 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87463.056641, idle connection 264825.000000, request 304999.402761 07/28/2025 02:31:26.134 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 742 07/28/2025 02:31:26.135 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.135 7fa5e593e240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 742 (603.0230522155762 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1222969371, topics=[]) 07/28/2025 02:31:26.135 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1222969371 with 0 response partitions (1 implied) 07/28/2025 02:31:26.213 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87736.077393, idle connection 265363.000000, request 304398.652792 07/28/2025 02:31:26.214 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 757 07/28/2025 02:31:26.214 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.214 7fa5e58998d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 757 (601.947546005249 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1099027523, topics=[]) 07/28/2025 02:31:26.214 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1099027523 with 0 response partitions (1 implied) 07/28/2025 02:31:26.264 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88001.849365, idle connection 265895.000000, request 304398.710728 07/28/2025 02:31:26.264 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 702 07/28/2025 02:31:26.265 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.265 7fa5e628f588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 702 (601.8080711364746 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1670241337, topics=[]) 07/28/2025 02:31:26.265 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1670241337 with 0 response partitions (1 implied) 07/28/2025 02:31:26.308 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 28 07/28/2025 02:31:26.309 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 07/28/2025 02:31:26.309 7fa5e61e5240 [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)]) 07/28/2025 02:31:26.309 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.309 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879929184, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.309 7fa5e61e5240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879929184, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.309 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86869.660645, idle connection 264665.000000, request 304999.945402 07/28/2025 02:31:26.309 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86869.246338, idle connection 264664.000000, request 304999.537706 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 313 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=6280536, session_epoch=729, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 733 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=6280536, session_epoch=729, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.310 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87824.671143, idle connection 265282.000000, request 304999.955654 07/28/2025 02:31:26.311 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87824.263672, idle connection 265282.000000, request 304999.551296 07/28/2025 02:31:26.340 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 64 07/28/2025 02:31:26.340 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 07/28/2025 02:31:26.340 7fa5e5933eb8 [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)]) 07/28/2025 02:31:26.340 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.340 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1783325526, session_epoch=689, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.340 7fa5e5933eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 693 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1783325526, session_epoch=689, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.340 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87414.334717, idle connection 264860.000000, request 304999.946594 07/28/2025 02:31:26.341 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87413.958252, idle connection 264860.000000, request 304999.574423 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=920524365, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=920524365, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.341 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87444.903320, idle connection 264823.000000, request 304999.957800 07/28/2025 02:31:26.342 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87444.529541, idle connection 264823.000000, request 304999.586821 07/28/2025 02:31:26.356 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86851.385742, idle connection 264716.000000, request 304399.043560 07/28/2025 02:31:26.356 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 07/28/2025 02:31:26.356 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.356 7fa5e6242390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (601.4096736907959 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=438116716, topics=[]) 07/28/2025 02:31:26.356 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 438116716 with 0 response partitions (1 implied) 07/28/2025 02:31:26.409 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87793.216797, idle connection 265996.000000, request 304398.682594 07/28/2025 02:31:26.410 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 711 07/28/2025 02:31:26.410 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.410 7fa5e5485240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 711 (601.865291595459 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=278134106, topics=[]) 07/28/2025 02:31:26.410 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 278134106 with 0 response partitions (1 implied) 07/28/2025 02:31:26.410 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 91 07/28/2025 02:31:26.410 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 07/28/2025 02:31:26.410 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 07/28/2025 02:31:26.410 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.410 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1357566540, session_epoch=697, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.411 7fa5e54a8ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 701 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1357566540, session_epoch=697, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.411 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88358.907227, idle connection 265487.000000, request 304999.951363 07/28/2025 02:31:26.412 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88358.113281, idle connection 265486.000000, request 304999.159336 07/28/2025 02:31:26.422 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87182.062988, idle connection 265188.000000, request 304399.095774 07/28/2025 02:31:26.422 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1052 07/28/2025 02:31:26.422 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.422 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1052 (601.412296295166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529149950, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3777, last_stable_offset=3777, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xbe\x00\x00\x01\x02\x00\x00\x00\x00\x02p\x03!\xf5\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9e\x03\x00\x00\x00\xe0\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 07/28/2025 02:31:26.422 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529149950 with 1 response partitions (0 implied) 07/28/2025 02:31:26.423 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 774 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3774 07/28/2025 02:31:26.423 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3774 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 07/28/2025 02:31:26.423 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3777 (leader epoch 0) 07/28/2025 02:31:26.444 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87988.703125, idle connection 265323.000000, request 304396.511555 07/28/2025 02:31:26.445 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 07/28/2025 02:31:26.445 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.445 7fa5e61e2240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (604.257345199585 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=197425454, topics=[]) 07/28/2025 02:31:26.445 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 197425454 with 0 response partitions (1 implied) 07/28/2025 02:31:26.445 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86802.426514, idle connection 265361.000000, request 304395.966530 07/28/2025 02:31:26.446 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 88191.781738, idle connection 264832.000000, request 304397.248983 07/28/2025 02:31:26.446 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 07/28/2025 02:31:26.446 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.446 7fa5e61c3588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 684 (604.7923564910889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677633217, topics=[]) 07/28/2025 02:31:26.446 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677633217 with 0 response partitions (1 implied) 07/28/2025 02:31:26.447 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 734 07/28/2025 02:31:26.447 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.447 7fa5e62f5048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 734 (604.0012836456299 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300324484, topics=[]) 07/28/2025 02:31:26.447 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300324484 with 0 response partitions (1 implied) 07/28/2025 02:31:26.455 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87709.877686, idle connection 265341.000000, request 304398.984194 07/28/2025 02:31:26.455 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 706 07/28/2025 02:31:26.456 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.456 7fa5e58cc048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 706 (601.5996932983398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=4518980, topics=[]) 07/28/2025 02:31:26.456 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 4518980 with 0 response partitions (1 implied) 07/28/2025 02:31:26.483 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87637.885986, idle connection 265083.000000, request 304398.962975 07/28/2025 02:31:26.483 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 699 07/28/2025 02:31:26.484 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.484 7fa5e573c6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 699 (601.7653942108154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=70999304, topics=[]) 07/28/2025 02:31:26.484 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 70999304 with 0 response partitions (1 implied) 07/28/2025 02:31:26.490 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87272.668945, idle connection 264804.000000, request 304399.082899 07/28/2025 02:31:26.491 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 07/28/2025 02:31:26.491 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.491 7fa5e62beac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (601.4313697814941 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=186045572, topics=[]) 07/28/2025 02:31:26.491 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 186045572 with 0 response partitions (1 implied) 07/28/2025 02:31:26.524 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3777 07/28/2025 02:31:26.524 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 07/28/2025 02:31:26.524 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 07/28/2025 02:31:26.524 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.524 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1049, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3777, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:26.525 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1053 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1049, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3777, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:26.525 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87078.953125, idle connection 265085.000000, request 304999.941349 07/28/2025 02:31:26.525 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87078.513184, idle connection 265085.000000, request 304999.507427 07/28/2025 02:31:26.581 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87971.929932, idle connection 264211.000000, request 304398.728371 07/28/2025 02:31:26.582 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 07/28/2025 02:31:26.582 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.582 7fa5e62e42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 688 (601.8662452697754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1122986152, topics=[]) 07/28/2025 02:31:26.582 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1122986152 with 0 response partitions (1 implied) 07/28/2025 02:31:26.639 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86715.684326, idle connection 264095.000000, request 304398.862362 07/28/2025 02:31:26.639 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 678 07/28/2025 02:31:26.639 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.639 7fa5e88c9780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 678 (601.7162799835205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=75571364, topics=[]) 07/28/2025 02:31:26.640 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 75571364 with 0 response partitions (1 implied) 07/28/2025 02:31:26.644 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 252 07/28/2025 02:31:26.644 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 07/28/2025 02:31:26.644 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 07/28/2025 02:31:26.644 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.644 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=974989986, session_epoch=735, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.645 7fa5e62936d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 739 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=974989986, session_epoch=735, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.645 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86955.572754, idle connection 264923.000000, request 304999.946117 07/28/2025 02:31:26.645 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86765.736328, idle connection 264147.000000, request 304396.922112 07/28/2025 02:31:26.645 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86954.993408, idle connection 264922.000000, request 304999.373913 07/28/2025 02:31:26.646 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 678 07/28/2025 02:31:26.646 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.646 7fa5e62be2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 678 (603.851318359375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349167670, topics=[]) 07/28/2025 02:31:26.646 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1349167670 with 0 response partitions (1 implied) 07/28/2025 02:31:26.666 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86800.820068, idle connection 264161.000000, request 304398.725748 07/28/2025 02:31:26.666 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 678 07/28/2025 02:31:26.666 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.666 7fa5e61bdc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 678 (601.8357276916504 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609648681, topics=[]) 07/28/2025 02:31:26.666 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609648681 with 0 response partitions (1 implied) 07/28/2025 02:31:26.668 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 16 07/28/2025 02:31:26.668 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 07/28/2025 02:31:26.668 7fa5e79e2c18 [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)]) 07/28/2025 02:31:26.668 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.669 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=823660160, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.669 7fa5e79e2c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=823660160, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.669 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87392.748291, idle connection 264745.000000, request 304999.950886 07/28/2025 02:31:26.669 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87392.193359, idle connection 264745.000000, request 304999.399900 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 177 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389960446, session_epoch=713, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 717 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389960446, session_epoch=713, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87758.868408, idle connection 264776.000000, request 304999.956131 07/28/2025 02:31:26.670 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87758.446045, idle connection 264775.000000, request 304999.536753 07/28/2025 02:31:26.685 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87750.067627, idle connection 263990.000000, request 304398.810863 07/28/2025 02:31:26.685 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 721 07/28/2025 02:31:26.685 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.685 7fa5e59bb0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 721 (601.6778945922852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458489424, topics=[]) 07/28/2025 02:31:26.685 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458489424 with 0 response partitions (1 implied) 07/28/2025 02:31:26.704 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 35 07/28/2025 02:31:26.704 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 07/28/2025 02:31:26.704 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 07/28/2025 02:31:26.704 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.704 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=705023370, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.705 7fa5e61ed438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=705023370, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.705 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86704.147217, idle connection 265293.000000, request 304999.948025 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 24 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=153234809, session_epoch=683, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 687 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=153234809, session_epoch=683, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.705 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86861.414307, idle connection 264710.000000, request 304999.955416 07/28/2025 02:31:26.706 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86703.052490, idle connection 265292.000000, request 304998.859167 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 174 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=319414245, session_epoch=714, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 718 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=319414245, session_epoch=714, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.706 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87179.867920, idle connection 264870.000000, request 304999.959230 07/28/2025 02:31:26.707 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86860.056885, idle connection 264708.000000, request 304998.602390 07/28/2025 02:31:26.707 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87179.099609, idle connection 264869.000000, request 304999.193430 07/28/2025 02:31:26.723 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86834.615479, idle connection 264182.000000, request 304399.036407 07/28/2025 02:31:26.723 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 07/28/2025 02:31:26.723 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.723 7fa5e6284a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 683 (601.4862060546875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1915679017, topics=[]) 07/28/2025 02:31:26.724 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1915679017 with 0 response partitions (1 implied) 07/28/2025 02:31:26.735 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 270 07/28/2025 02:31:26.735 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 07/28/2025 02:31:26.735 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 07/28/2025 02:31:26.735 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.736 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222969371, session_epoch=739, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.736 7fa5e593e240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 743 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222969371, session_epoch=739, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.736 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87216.644287, idle connection 264601.000000, request 304999.947548 07/28/2025 02:31:26.736 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86861.315918, idle connection 264223.000000, request 304397.660017 07/28/2025 02:31:26.736 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87215.944092, idle connection 264600.000000, request 304999.253273 07/28/2025 02:31:26.737 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 680 07/28/2025 02:31:26.737 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.737 7fa5e591ff60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 680 (603.2528877258301 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=80388427, topics=[]) 07/28/2025 02:31:26.737 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 80388427 with 0 response partitions (1 implied) 07/28/2025 02:31:26.814 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 476 07/28/2025 02:31:26.815 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 07/28/2025 02:31:26.815 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 07/28/2025 02:31:26.815 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.815 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1099027523, session_epoch=754, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.815 7fa5e58998d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 758 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1099027523, session_epoch=754, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.815 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87134.146729, idle connection 264761.000000, request 304999.939680 07/28/2025 02:31:26.816 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87133.686279, idle connection 264760.000000, request 304999.486923 07/28/2025 02:31:26.865 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 102 07/28/2025 02:31:26.865 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 07/28/2025 02:31:26.865 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 07/28/2025 02:31:26.866 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.866 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1670241337, session_epoch=699, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.866 7fa5e628f588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 703 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1670241337, session_epoch=699, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.866 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87400.036621, idle connection 265294.000000, request 304999.942780 07/28/2025 02:31:26.866 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87399.563965, idle connection 265293.000000, request 304999.477386 07/28/2025 02:31:26.911 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86267.428467, idle connection 264062.000000, request 304397.704124 07/28/2025 02:31:26.912 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 07/28/2025 02:31:26.912 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.912 7fa5e61e5240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (603.1022071838379 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=879929184, topics=[]) 07/28/2025 02:31:26.912 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 879929184 with 0 response partitions (1 implied) 07/28/2025 02:31:26.913 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87222.108154, idle connection 264680.000000, request 304397.387028 07/28/2025 02:31:26.913 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 733 07/28/2025 02:31:26.913 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.913 7fa5e57b2780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 733 (603.1589508056641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=6280536, topics=[]) 07/28/2025 02:31:26.914 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 6280536 with 0 response partitions (1 implied) 07/28/2025 02:31:26.942 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86812.703369, idle connection 264259.000000, request 304398.311377 07/28/2025 02:31:26.942 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 07/28/2025 02:31:26.943 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.943 7fa5e5933eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 693 (602.2429466247559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1783325526, topics=[]) 07/28/2025 02:31:26.943 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1783325526 with 0 response partitions (1 implied) 07/28/2025 02:31:26.943 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86843.395752, idle connection 264222.000000, request 304398.450136 07/28/2025 02:31:26.943 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 07/28/2025 02:31:26.943 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:26.943 7fa5e62c3390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.8922328948975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=920524365, topics=[]) 07/28/2025 02:31:26.944 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 920524365 with 0 response partitions (1 implied) 07/28/2025 02:31:26.956 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 38 07/28/2025 02:31:26.957 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 07/28/2025 02:31:26.957 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 07/28/2025 02:31:26.957 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:26.957 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=438116716, session_epoch=687, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.957 7fa5e6242390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=438116716, session_epoch=687, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:26.958 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86249.331055, idle connection 264114.000000, request 304999.916077 07/28/2025 02:31:26.958 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86248.699707, idle connection 264113.000000, request 304999.295950 07/28/2025 02:31:27.010 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 182 07/28/2025 02:31:27.011 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 07/28/2025 02:31:27.011 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 07/28/2025 02:31:27.011 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.011 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=278134106, session_epoch=708, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.011 7fa5e5485240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 712 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=278134106, session_epoch=708, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.012 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87190.875244, idle connection 265394.000000, request 304999.914408 07/28/2025 02:31:27.012 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87190.261963, idle connection 265394.000000, request 304999.313116 07/28/2025 02:31:27.012 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87757.172607, idle connection 264885.000000, request 304398.214817 07/28/2025 02:31:27.013 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 701 07/28/2025 02:31:27.013 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.013 7fa5e54a8ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 701 (602.4215221405029 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1357566540, topics=[]) 07/28/2025 02:31:27.013 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1357566540 with 0 response partitions (1 implied) 07/28/2025 02:31:27.046 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 27 07/28/2025 02:31:27.047 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 07/28/2025 02:31:27.047 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 07/28/2025 02:31:27.047 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.047 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=197425454, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.047 7fa5e61e2240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=197425454, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.048 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87385.172852, idle connection 264720.000000, request 304999.912739 07/28/2025 02:31:27.048 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 14 07/28/2025 02:31:27.048 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 07/28/2025 02:31:27.048 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 07/28/2025 02:31:27.048 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.048 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677633217, session_epoch=681, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.049 7fa5e61c3588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677633217, session_epoch=681, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.049 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86199.200439, idle connection 264757.000000, request 304999.932528 07/28/2025 02:31:27.049 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87383.459717, idle connection 264718.000000, request 304998.211622 07/28/2025 02:31:27.050 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86198.174561, idle connection 264756.000000, request 304998.913527 07/28/2025 02:31:27.050 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 283 07/28/2025 02:31:27.050 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 07/28/2025 02:31:27.050 7fa5e62f5048 [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)]) 07/28/2025 02:31:27.051 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.051 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300324484, session_epoch=731, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.051 7fa5e62f5048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 735 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300324484, session_epoch=731, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.051 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87586.505859, idle connection 264226.000000, request 304999.935865 07/28/2025 02:31:27.052 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87586.001221, idle connection 264226.000000, request 304999.433517 07/28/2025 02:31:27.058 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 105 07/28/2025 02:31:27.058 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 07/28/2025 02:31:27.058 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 07/28/2025 02:31:27.058 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.058 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4518980, session_epoch=703, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.058 7fa5e58cc048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 707 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4518980, session_epoch=703, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.059 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87106.378174, idle connection 264738.000000, request 304999.931097 07/28/2025 02:31:27.059 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87105.753418, idle connection 264737.000000, request 304999.310970 07/28/2025 02:31:27.084 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 81 07/28/2025 02:31:27.085 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 07/28/2025 02:31:27.085 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 07/28/2025 02:31:27.085 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.085 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=70999304, session_epoch=696, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.085 7fa5e573c6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 700 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=70999304, session_epoch=696, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.085 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87035.671387, idle connection 264481.000000, request 304999.938250 07/28/2025 02:31:27.086 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87035.226318, idle connection 264481.000000, request 304999.501705 07/28/2025 02:31:27.091 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 63 07/28/2025 02:31:27.091 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 07/28/2025 02:31:27.091 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 07/28/2025 02:31:27.091 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.092 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=186045572, session_epoch=687, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.092 7fa5e62beac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=186045572, session_epoch=687, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.092 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86670.875977, idle connection 264202.000000, request 304999.803066 07/28/2025 02:31:27.093 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86670.257324, idle connection 264202.000000, request 304999.224186 07/28/2025 02:31:27.126 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86477.961426, idle connection 264484.000000, request 304398.949385 07/28/2025 02:31:27.126 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1053 07/28/2025 02:31:27.126 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.126 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1053 (601.6576290130615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529149950, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3778, last_stable_offset=3778, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xc1\x00\x00\x01\x04\x00\x00\x00\x00\x023\xd4j\x08\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\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 07/28/2025 02:31:27.127 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529149950 with 1 response partitions (0 implied) 07/28/2025 02:31:27.127 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3777 07/28/2025 02:31:27.127 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3777 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 07/28/2025 02:31:27.127 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3778 (leader epoch 0) 07/28/2025 02:31:27.183 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 25 07/28/2025 02:31:27.183 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 07/28/2025 02:31:27.183 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 07/28/2025 02:31:27.183 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.184 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1122986152, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.184 7fa5e62e42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 689 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1122986152, session_epoch=685, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.184 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87369.398682, idle connection 263609.000000, request 304999.938250 07/28/2025 02:31:27.184 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87368.935303, idle connection 263608.000000, request 304999.481678 07/28/2025 02:31:27.228 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3778 07/28/2025 02:31:27.228 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 07/28/2025 02:31:27.228 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 07/28/2025 02:31:27.228 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.228 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1050, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3778, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:27.228 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 1054 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529149950, session_epoch=1050, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3778, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 07/28/2025 02:31:27.229 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86375.120850, idle connection 264382.000000, request 304999.894381 07/28/2025 02:31:27.229 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86374.450439, idle connection 264381.000000, request 304999.240160 07/28/2025 02:31:27.240 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 07/28/2025 02:31:27.240 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 07/28/2025 02:31:27.240 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 07/28/2025 02:31:27.240 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.240 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=75571364, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.241 7fa5e88c9780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 679 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=75571364, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.241 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86113.644287, idle connection 263493.000000, request 304999.920845 07/28/2025 02:31:27.241 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86113.152832, idle connection 263493.000000, request 304999.438763 07/28/2025 02:31:27.246 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 07/28/2025 02:31:27.246 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 07/28/2025 02:31:27.246 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 07/28/2025 02:31:27.247 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.247 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349167670, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.247 7fa5e62be2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 679 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1349167670, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.247 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86163.660645, idle connection 263545.000000, request 304999.944687 07/28/2025 02:31:27.247 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86352.989746, idle connection 264320.000000, request 304397.367716 07/28/2025 02:31:27.248 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86163.022461, idle connection 263544.000000, request 304999.312162 07/28/2025 02:31:27.248 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 739 07/28/2025 02:31:27.248 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.248 7fa5e62936d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 739 (603.4286022186279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=974989986, topics=[]) 07/28/2025 02:31:27.248 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 974989986 with 0 response partitions (1 implied) 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 0 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609648681, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 679 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=609648681, session_epoch=675, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.267 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86198.900635, idle connection 263559.000000, request 304999.923229 07/28/2025 02:31:27.268 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86198.382324, idle connection 263559.000000, request 304999.413252 07/28/2025 02:31:27.270 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86791.078125, idle connection 264144.000000, request 304398.283482 07/28/2025 02:31:27.271 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 07/28/2025 02:31:27.271 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.271 7fa5e79e2c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 684 (602.1263599395752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=823660160, topics=[]) 07/28/2025 02:31:27.271 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 823660160 with 0 response partitions (1 implied) 07/28/2025 02:31:27.271 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87157.697510, idle connection 264175.000000, request 304398.786783 07/28/2025 02:31:27.271 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 717 07/28/2025 02:31:27.272 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.272 7fa5e54b8eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 717 (601.6247272491455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1389960446, topics=[]) 07/28/2025 02:31:27.272 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1389960446 with 0 response partitions (1 implied) 07/28/2025 02:31:27.286 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 191 07/28/2025 02:31:27.286 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 07/28/2025 02:31:27.286 7fa5e59bb0f0 [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)]) 07/28/2025 02:31:27.286 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.286 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458489424, session_epoch=718, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.286 7fa5e59bb0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 722 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=458489424, session_epoch=718, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.287 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87148.346924, idle connection 263389.000000, request 304999.881268 07/28/2025 02:31:27.287 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87147.699707, idle connection 263388.000000, request 304999.301672 07/28/2025 02:31:27.307 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86101.609375, idle connection 264691.000000, request 304397.408009 07/28/2025 02:31:27.308 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 07/28/2025 02:31:27.308 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.308 7fa5e61ed438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (603.3885478973389 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=705023370, topics=[]) 07/28/2025 02:31:27.309 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 705023370 with 0 response partitions (1 implied) 07/28/2025 02:31:27.309 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86258.053467, idle connection 264106.000000, request 304396.595240 07/28/2025 02:31:27.309 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86577.393555, idle connection 264267.000000, request 304397.484303 07/28/2025 02:31:27.309 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 07/28/2025 02:31:27.309 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.310 7fa5e61e50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 687 (604.133129119873 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=153234809, topics=[]) 07/28/2025 02:31:27.310 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 153234809 with 0 response partitions (1 implied) 07/28/2025 02:31:27.310 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 718 07/28/2025 02:31:27.310 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.310 7fa5e5778438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 718 (603.7662029266357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=319414245, topics=[]) 07/28/2025 02:31:27.310 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 319414245 with 0 response partitions (1 implied) 07/28/2025 02:31:27.324 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 18 07/28/2025 02:31:27.324 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 07/28/2025 02:31:27.324 7fa5e6284a20 [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)]) 07/28/2025 02:31:27.324 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.325 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1915679017, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.325 7fa5e6284a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1915679017, session_epoch=680, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.325 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86232.642090, idle connection 263580.000000, request 304999.933481 07/28/2025 02:31:27.326 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86231.964600, idle connection 263579.000000, request 304999.268055 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 11 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=80388427, session_epoch=677, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=80388427, session_epoch=677, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.338 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86259.032471, idle connection 263621.000000, request 304999.938965 07/28/2025 02:31:27.339 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86613.746582, idle connection 263998.000000, request 304397.053003 07/28/2025 02:31:27.339 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86258.307861, idle connection 263620.000000, request 304999.221802 07/28/2025 02:31:27.339 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743 07/28/2025 02:31:27.339 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.339 7fa5e593e240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 743 (603.7299633026123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1222969371, topics=[]) 07/28/2025 02:31:27.340 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1222969371 with 0 response partitions (1 implied) 07/28/2025 02:31:27.416 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86533.157959, idle connection 264160.000000, request 304398.949862 07/28/2025 02:31:27.417 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 758 07/28/2025 02:31:27.417 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.417 7fa5e58998d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 758 (601.6113758087158 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1099027523, topics=[]) 07/28/2025 02:31:27.417 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1099027523 with 0 response partitions (1 implied) 07/28/2025 02:31:27.467 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86799.030518, idle connection 264693.000000, request 304398.934603 07/28/2025 02:31:27.467 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 703 07/28/2025 02:31:27.467 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.468 7fa5e628f588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 703 (601.74560546875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1670241337, topics=[]) 07/28/2025 02:31:27.468 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1670241337 with 0 response partitions (1 implied) 07/28/2025 02:31:27.514 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 28 07/28/2025 02:31:27.514 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 07/28/2025 02:31:27.514 7fa5e61e5240 [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)]) 07/28/2025 02:31:27.514 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.514 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879929184, session_epoch=687, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.515 7fa5e61e5240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 691 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879929184, session_epoch=687, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.515 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85663.856689, idle connection 263459.000000, request 304999.899387 07/28/2025 02:31:27.515 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 313 07/28/2025 02:31:27.515 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 07/28/2025 02:31:27.515 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 07/28/2025 02:31:27.515 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.515 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=6280536, session_epoch=730, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.516 7fa5e57b2780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 734 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=6280536, session_epoch=730, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.516 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86619.177246, idle connection 264077.000000, request 304999.954462 07/28/2025 02:31:27.516 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85662.670654, idle connection 263458.000000, request 304998.759985 07/28/2025 02:31:27.516 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86618.500732, idle connection 264076.000000, request 304999.282122 07/28/2025 02:31:27.543 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 64 07/28/2025 02:31:27.543 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 07/28/2025 02:31:27.544 7fa5e5933eb8 [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)]) 07/28/2025 02:31:27.544 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.544 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1783325526, session_epoch=690, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.544 7fa5e5933eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 694 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1783325526, session_epoch=690, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.544 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86210.745850, idle connection 263657.000000, request 304999.941587 07/28/2025 02:31:27.544 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 29 07/28/2025 02:31:27.545 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 07/28/2025 02:31:27.545 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 07/28/2025 02:31:27.545 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.545 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=920524365, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.545 7fa5e62c3390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=920524365, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.545 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86241.252441, idle connection 263620.000000, request 304999.942064 07/28/2025 02:31:27.546 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86208.958252, idle connection 263655.000000, request 304998.163462 07/28/2025 02:31:27.546 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86239.899658, idle connection 263618.000000, request 304998.594999 07/28/2025 02:31:27.559 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85647.903809, idle connection 263512.000000, request 304398.497581 07/28/2025 02:31:27.559 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 07/28/2025 02:31:27.559 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.559 7fa5e6242390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 691 (601.9690036773682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=438116716, topics=[]) 07/28/2025 02:31:27.560 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 438116716 with 0 response partitions (1 implied) 07/28/2025 02:31:27.613 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86589.272461, idle connection 264793.000000, request 304398.319960 07/28/2025 02:31:27.614 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 712 07/28/2025 02:31:27.614 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.614 7fa5e5485240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 712 (602.217435836792 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=278134106, topics=[]) 07/28/2025 02:31:27.614 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 278134106 with 0 response partitions (1 implied) 07/28/2025 02:31:27.614 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 91 07/28/2025 02:31:27.614 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 07/28/2025 02:31:27.614 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 07/28/2025 02:31:27.614 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.615 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1357566540, session_epoch=698, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.615 7fa5e54a8ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 702 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1357566540, session_epoch=698, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.615 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87154.833984, idle connection 264283.000000, request 304999.896288 07/28/2025 02:31:27.615 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 87154.170898, idle connection 264282.000000, request 304999.236822 07/28/2025 02:31:27.650 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86782.398682, idle connection 264117.000000, request 304397.148132 07/28/2025 02:31:27.651 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 07/28/2025 02:31:27.651 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.651 7fa5e61e2240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 684 (603.3601760864258 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=197425454, topics=[]) 07/28/2025 02:31:27.651 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 197425454 with 0 response partitions (1 implied) 07/28/2025 02:31:27.651 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85596.688721, idle connection 264155.000000, request 304397.430182 07/28/2025 02:31:27.651 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 685 07/28/2025 02:31:27.651 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.652 7fa5e61c3588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 685 (602.9558181762695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677633217, topics=[]) 07/28/2025 02:31:27.652 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677633217 with 0 response partitions (1 implied) 07/28/2025 02:31:27.652 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86985.561279, idle connection 263625.000000, request 304398.997307 07/28/2025 02:31:27.652 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 735 07/28/2025 02:31:27.652 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.652 7fa5e62f5048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 735 (601.337194442749 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300324484, topics=[]) 07/28/2025 02:31:27.652 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300324484 with 0 response partitions (1 implied) 07/28/2025 02:31:27.660 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86505.243896, idle connection 264137.000000, request 304398.803711 07/28/2025 02:31:27.660 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 707 07/28/2025 02:31:27.660 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.660 7fa5e58cc048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 707 (601.5908718109131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=4518980, topics=[]) 07/28/2025 02:31:27.660 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 4518980 with 0 response partitions (1 implied) 07/28/2025 02:31:27.686 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86434.666016, idle connection 263880.000000, request 304398.933649 07/28/2025 02:31:27.687 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 700 07/28/2025 02:31:27.687 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.687 7fa5e573c6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 700 (601.6874313354492 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=70999304, topics=[]) 07/28/2025 02:31:27.687 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 70999304 with 0 response partitions (1 implied) 07/28/2025 02:31:27.693 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86069.658691, idle connection 263601.000000, request 304398.620367 07/28/2025 02:31:27.693 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 07/28/2025 02:31:27.694 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.694 7fa5e62beac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 691 (601.830005645752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=186045572, topics=[]) 07/28/2025 02:31:27.694 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 186045572 with 0 response partitions (1 implied) 07/28/2025 02:31:27.785 7fa5e62e42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86768.379150, idle connection 263008.000000, request 304398.918390 07/28/2025 02:31:27.785 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 07/28/2025 02:31:27.785 7fa5e62e42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.786 7fa5e62e42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 689 (601.6614437103271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1122986152, topics=[]) 07/28/2025 02:31:27.786 7fa5e62e42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1122986152 with 0 response partitions (1 implied) 07/28/2025 02:31:27.830 7fa5e62be0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85773.914307, idle connection 263780.000000, request 304398.696184 07/28/2025 02:31:27.830 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1054 07/28/2025 02:31:27.830 7fa5e62be0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.830 7fa5e62be0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 1054 (601.8490791320801 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529149950, topics=[]) 07/28/2025 02:31:27.831 7fa5e62be0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529149950 with 0 response partitions (1 implied) 07/28/2025 02:31:27.842 7fa5e88c9780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85512.607178, idle connection 262892.000000, request 304398.885965 07/28/2025 02:31:27.842 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 679 07/28/2025 02:31:27.842 7fa5e88c9780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.842 7fa5e88c9780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 679 (601.5920639038086 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=75571364, topics=[]) 07/28/2025 02:31:27.842 7fa5e88c9780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 75571364 with 0 response partitions (1 implied) 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 252 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=974989986, session_epoch=736, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 740 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=974989986, session_epoch=736, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.849 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85751.036621, idle connection 263718.000000, request 304999.946117 07/28/2025 02:31:27.849 7fa5e62be2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85561.204590, idle connection 262943.000000, request 304397.493839 07/28/2025 02:31:27.850 7fa5e62936d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85750.468994, idle connection 263718.000000, request 304999.384403 07/28/2025 02:31:27.850 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 679 07/28/2025 02:31:27.850 7fa5e62be2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.850 7fa5e62be2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 679 (603.1997203826904 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1349167670, topics=[]) 07/28/2025 02:31:27.850 7fa5e62be2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1349167670 with 0 response partitions (1 implied) 07/28/2025 02:31:27.869 7fa5e61bdc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85597.723389, idle connection 262958.000000, request 304398.744583 07/28/2025 02:31:27.869 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 679 07/28/2025 02:31:27.869 7fa5e61bdc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.869 7fa5e61bdc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 679 (602.0939350128174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=609648681, topics=[]) 07/28/2025 02:31:27.870 7fa5e61bdc18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 609648681 with 0 response partitions (1 implied) 07/28/2025 02:31:27.871 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 16 07/28/2025 02:31:27.871 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 07/28/2025 02:31:27.872 7fa5e79e2c18 [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)]) 07/28/2025 02:31:27.872 7fa5e79e2c18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.872 7fa5e79e2c18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=823660160, session_epoch=681, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.872 7fa5e79e2c18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=823660160, session_epoch=681, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.872 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86189.232910, idle connection 263542.000000, request 304999.920845 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 177 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389960446, session_epoch=714, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 718 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1389960446, session_epoch=714, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.873 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86555.472412, idle connection 263572.000000, request 304999.930859 07/28/2025 02:31:27.874 7fa5e79e2c18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86187.515869, idle connection 263540.000000, request 304998.211145 07/28/2025 02:31:27.874 7fa5e54b8eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86554.491211, idle connection 263572.000000, request 304998.954058 07/28/2025 02:31:27.888 7fa5e59bb0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86547.000977, idle connection 262787.000000, request 304398.601055 07/28/2025 02:31:27.888 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 722 07/28/2025 02:31:27.888 7fa5e59bb0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.888 7fa5e59bb0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 722 (601.8753051757812 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=458489424, topics=[]) 07/28/2025 02:31:27.888 7fa5e59bb0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 458489424 with 0 response partitions (1 implied) 07/28/2025 02:31:27.909 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 35 07/28/2025 02:31:27.909 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 07/28/2025 02:31:27.909 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 07/28/2025 02:31:27.909 7fa5e61ed438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.909 7fa5e61ed438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=705023370, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.910 7fa5e61ed438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 690 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=705023370, session_epoch=686, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.910 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85499.187256, idle connection 264088.000000, request 304999.943972 07/28/2025 02:31:27.910 7fa5e61ed438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85498.766357, idle connection 264088.000000, request 304999.529839 07/28/2025 02:31:27.910 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 24 07/28/2025 02:31:27.910 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 07/28/2025 02:31:27.910 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 07/28/2025 02:31:27.910 7fa5e61e50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.911 7fa5e61e50f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=153234809, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.911 7fa5e61e50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 688 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=153234809, session_epoch=684, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.911 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85656.060303, idle connection 263504.000000, request 304999.957323 07/28/2025 02:31:27.911 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 174 07/28/2025 02:31:27.911 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 07/28/2025 02:31:27.911 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 07/28/2025 02:31:27.911 7fa5e5778438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.911 7fa5e5778438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=319414245, session_epoch=715, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.911 7fa5e5778438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 719 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=319414245, session_epoch=715, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.912 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85974.776611, idle connection 263665.000000, request 304999.958754 07/28/2025 02:31:27.912 7fa5e61e50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85654.968750, idle connection 263503.000000, request 304998.868465 07/28/2025 02:31:27.912 7fa5e5778438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85974.152344, idle connection 263664.000000, request 304999.337435 07/28/2025 02:31:27.926 7fa5e6284a20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85631.376709, idle connection 262979.000000, request 304398.678541 07/28/2025 02:31:27.927 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 07/28/2025 02:31:27.927 7fa5e6284a20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.927 7fa5e6284a20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 684 (601.8707752227783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1915679017, topics=[]) 07/28/2025 02:31:27.927 7fa5e6284a20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1915679017 with 0 response partitions (1 implied) 07/28/2025 02:31:27.940 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 270 07/28/2025 02:31:27.940 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 07/28/2025 02:31:27.940 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 07/28/2025 02:31:27.940 7fa5e593e240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:27.940 7fa5e593e240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222969371, session_epoch=740, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.941 7fa5e593e240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 744 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1222969371, session_epoch=740, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:27.941 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86011.634277, idle connection 263396.000000, request 304999.943256 07/28/2025 02:31:27.941 7fa5e591ff60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85656.309082, idle connection 263018.000000, request 304397.222519 07/28/2025 02:31:27.941 7fa5e593e240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86011.041260, idle connection 263395.000000, request 304999.357700 07/28/2025 02:31:27.942 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 681 07/28/2025 02:31:27.942 7fa5e591ff60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:27.942 7fa5e591ff60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 681 (603.499174118042 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=80388427, topics=[]) 07/28/2025 02:31:27.942 7fa5e591ff60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 80388427 with 0 response partitions (1 implied) 07/28/2025 02:31:28.017 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 476 07/28/2025 02:31:28.018 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 07/28/2025 02:31:28.018 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 07/28/2025 02:31:28.018 7fa5e58998d0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.018 7fa5e58998d0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1099027523, session_epoch=755, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.018 7fa5e58998d0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 759 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1099027523, session_epoch=755, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.018 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85931.085449, idle connection 263558.000000, request 304999.933004 07/28/2025 02:31:28.019 7fa5e58998d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85930.645020, idle connection 263557.000000, request 304999.502659 07/28/2025 02:31:28.068 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 102 07/28/2025 02:31:28.068 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 07/28/2025 02:31:28.068 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 07/28/2025 02:31:28.069 7fa5e628f588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.069 7fa5e628f588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1670241337, session_epoch=700, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.069 7fa5e628f588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 704 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1670241337, session_epoch=700, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.069 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86196.897217, idle connection 264090.000000, request 304999.922991 07/28/2025 02:31:28.070 7fa5e628f588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86196.300537, idle connection 264090.000000, request 304999.340773 07/28/2025 02:31:28.117 7fa5e61e5240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85061.911377, idle connection 262857.000000, request 304397.992373 07/28/2025 02:31:28.117 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 07/28/2025 02:31:28.117 7fa5e61e5240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:28.117 7fa5e61e5240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 691 (602.6566028594971 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=879929184, topics=[]) 07/28/2025 02:31:28.118 7fa5e61e5240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 879929184 with 0 response partitions (1 implied) 07/28/2025 02:31:28.118 7fa5e57b2780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86016.922852, idle connection 263474.000000, request 304397.699833 07/28/2025 02:31:28.118 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 734 07/28/2025 02:31:28.118 7fa5e57b2780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:28.118 7fa5e57b2780 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 734 (602.6701927185059 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=6280536, topics=[]) 07/28/2025 02:31:28.118 7fa5e57b2780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 6280536 with 0 response partitions (1 implied) 07/28/2025 02:31:28.147 7fa5e5933eb8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85607.497803, idle connection 263053.000000, request 304396.695137 07/28/2025 02:31:28.148 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 07/28/2025 02:31:28.148 7fa5e5933eb8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:28.148 7fa5e5933eb8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 694 (603.9977073669434 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1783325526, topics=[]) 07/28/2025 02:31:28.148 7fa5e5933eb8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1783325526 with 0 response partitions (1 implied) 07/28/2025 02:31:28.148 7fa5e62c3390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85638.043701, idle connection 263017.000000, request 304396.736622 07/28/2025 02:31:28.149 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 07/28/2025 02:31:28.149 7fa5e62c3390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:28.149 7fa5e62c3390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 690 (603.600263595581 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=920524365, topics=[]) 07/28/2025 02:31:28.149 7fa5e62c3390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 920524365 with 0 response partitions (1 implied) 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 38 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=438116716, session_epoch=688, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=438116716, session_epoch=688, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.161 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85045.551025, idle connection 262910.000000, request 304999.922991 07/28/2025 02:31:28.162 7fa5e6242390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85045.099609, idle connection 262909.000000, request 304999.478579 07/28/2025 02:31:28.214 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 182 07/28/2025 02:31:28.215 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 07/28/2025 02:31:28.215 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 07/28/2025 02:31:28.215 7fa5e5485240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.215 7fa5e5485240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=278134106, session_epoch=709, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.215 7fa5e5485240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 713 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=278134106, session_epoch=709, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.215 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85987.281738, idle connection 264191.000000, request 304999.939442 07/28/2025 02:31:28.216 7fa5e5485240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85986.670166, idle connection 264190.000000, request 304999.335289 07/28/2025 02:31:28.216 7fa5e54a8ac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86553.606445, idle connection 263682.000000, request 304398.672342 07/28/2025 02:31:28.216 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 702 07/28/2025 02:31:28.217 7fa5e54a8ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 07/28/2025 02:31:28.217 7fa5e54a8ac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 702 (601.9299030303955 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1357566540, topics=[]) 07/28/2025 02:31:28.217 7fa5e54a8ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1357566540 with 0 response partitions (1 implied) 07/28/2025 02:31:28.251 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 27 07/28/2025 02:31:28.252 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 07/28/2025 02:31:28.252 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 07/28/2025 02:31:28.252 7fa5e61e2240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.252 7fa5e61e2240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=197425454, session_epoch=681, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.252 7fa5e61e2240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=197425454, session_epoch=681, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.252 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86180.498535, idle connection 263515.000000, request 304999.937534 07/28/2025 02:31:28.252 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 14 07/28/2025 02:31:28.252 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 07/28/2025 02:31:28.253 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 07/28/2025 02:31:28.253 7fa5e61c3588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.253 7fa5e61c3588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677633217, session_epoch=682, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.253 7fa5e61c3588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677633217, session_epoch=682, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.253 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84994.953613, idle connection 263553.000000, request 304999.958992 07/28/2025 02:31:28.253 7fa5e61e2240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86179.392334, idle connection 263514.000000, request 304998.841524 07/28/2025 02:31:28.253 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 283 07/28/2025 02:31:28.254 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 07/28/2025 02:31:28.254 7fa5e62f5048 [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)]) 07/28/2025 02:31:28.254 7fa5e62f5048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.254 7fa5e62f5048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300324484, session_epoch=732, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.254 7fa5e62f5048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 736 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300324484, session_epoch=732, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.254 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86383.508057, idle connection 263023.000000, request 304999.959469 07/28/2025 02:31:28.254 7fa5e61c3588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 84993.583496, idle connection 263552.000000, request 304998.591423 07/28/2025 02:31:28.255 7fa5e62f5048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 86382.658691, idle connection 263023.000000, request 304999.111414 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 105 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4518980, session_epoch=704, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 708 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4518980, session_epoch=704, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.261 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85903.697754, idle connection 263535.000000, request 304999.949694 07/28/2025 02:31:28.262 7fa5e58cc048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85903.248535, idle connection 263535.000000, request 304999.505520 07/28/2025 02:31:28.287 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 81 07/28/2025 02:31:28.288 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 07/28/2025 02:31:28.288 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 07/28/2025 02:31:28.288 7fa5e573c6d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.288 7fa5e573c6d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=70999304, session_epoch=697, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.288 7fa5e573c6d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 701 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=70999304, session_epoch=697, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.288 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85832.556885, idle connection 263278.000000, request 304999.933720 07/28/2025 02:31:28.289 7fa5e573c6d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85832.106201, idle connection 263278.000000, request 304999.491930 07/28/2025 02:31:28.294 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 63 07/28/2025 02:31:28.294 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 07/28/2025 02:31:28.294 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 07/28/2025 02:31:28.294 7fa5e62beac8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 07/28/2025 02:31:28.295 7fa5e62beac8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=186045572, session_epoch=688, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.295 7fa5e62beac8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 692 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=186045572, session_epoch=688, topics=[], forgotten_topics_data=[]) 07/28/2025 02:31:28.295 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85468.017822, idle connection 262999.000000, request 304999.946117 07/28/2025 02:31:28.295 7fa5e62beac8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 85467.602783, idle connection 262999.000000, request 304999.535322