02/26/2026 02:37:59.222 7f0fed4efcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.223 7f0fed4efcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 693 (603.0669212341309 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1986605365, topics=[]) 02/26/2026 02:37:59.224 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1986605365 with 0 response partitions (1 implied) 02/26/2026 02:37:59.224 7f0fed4ef2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82652.112061, idle connection 259640.000000, request 304397.652626 02/26/2026 02:37:59.224 7f0feb6d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82131.282227, idle connection 260364.000000, request 304398.237705 02/26/2026 02:37:59.224 7f0fed4ef2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 02/26/2026 02:37:59.224 7f0fed4ef2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.224 7f0fed4ef2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 689 (602.7896404266357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1570397235, topics=[]) 02/26/2026 02:37:59.224 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1570397235 with 0 response partitions (1 implied) 02/26/2026 02:37:59.225 7f0feb6d22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 02/26/2026 02:37:59.225 7f0feb6d22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.225 7f0feb6d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 690 (602.5195121765137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=234902840, topics=[]) 02/26/2026 02:37:59.225 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 234902840 with 0 response partitions (1 implied) 02/26/2026 02:37:59.260 7f0fede89680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82219.430176, idle connection 260512.000000, request 304398.051262 02/26/2026 02:37:59.260 7f0fede89680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 734 02/26/2026 02:37:59.260 7f0fede89680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.260 7f0fede89680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 734 (602.4746894836426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=86757827, topics=[]) 02/26/2026 02:37:59.261 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 86757827 with 0 response partitions (1 implied) 02/26/2026 02:37:59.261 7f0fede890e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82698.816650, idle connection 260253.000000, request 304398.586988 02/26/2026 02:37:59.261 7f0fede890e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 735 02/26/2026 02:37:59.261 7f0fede890e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.261 7f0fede890e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 735 (601.7246246337891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1841935055, topics=[]) 02/26/2026 02:37:59.261 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1841935055 with 0 response partitions (1 implied) 02/26/2026 02:37:59.297 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3779 02/26/2026 02:37:59.297 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 02/26/2026 02:37:59.297 7f0febf2de00 [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)]) 02/26/2026 02:37:59.297 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.297 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123186983, session_epoch=1005, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3779, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.297 7f0febf2de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 1009 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123186983, session_epoch=1005, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3779, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.297 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81756.436035, idle connection 260309.000000, request 304999.950171 02/26/2026 02:37:59.298 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81756.029541, idle connection 260309.000000, request 304999.549866 02/26/2026 02:37:59.302 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/26/2026 02:37:59.302 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 02/26/2026 02:37:59.302 7f0febf2df40 [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)]) 02/26/2026 02:37:59.303 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.303 7f0febf2df40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=441217745, session_epoch=679, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.303 7f0febf2df40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=441217745, session_epoch=679, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.303 7f0febf2df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82817.687256, idle connection 260165.000000, request 304999.958992 02/26/2026 02:37:59.303 7f0febf2df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82817.354492, idle connection 260164.000000, request 304999.630690 02/26/2026 02:37:59.304 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 62 02/26/2026 02:37:59.304 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 02/26/2026 02:37:59.304 7f0fed4ef900 [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)]) 02/26/2026 02:37:59.304 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.304 7f0fed4ef900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=610899018, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.304 7f0fed4ef900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=610899018, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.304 7f0fed4ef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82151.526611, idle connection 260282.000000, request 304999.966383 02/26/2026 02:37:59.304 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 254 02/26/2026 02:37:59.304 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 02/26/2026 02:37:59.304 7f0fede89f40 [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)]) 02/26/2026 02:37:59.305 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.305 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1428526147, session_epoch=725, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.305 7f0fede89f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 729 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1428526147, session_epoch=725, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.305 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82172.855957, idle connection 260991.000000, request 304999.966383 02/26/2026 02:37:59.305 7f0fed4ef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82150.652588, idle connection 260281.000000, request 304999.094725 02/26/2026 02:37:59.305 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82275.903564, idle connection 260395.000000, request 304397.471189 02/26/2026 02:37:59.305 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82172.164795, idle connection 260991.000000, request 304999.274969 02/26/2026 02:37:59.306 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 717 02/26/2026 02:37:59.306 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.306 7f0fed4ef360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 717 (603.2397747039795 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=731202314, topics=[(topics='-uve-topic-2', partitions=[(partition=0, error_code=0, highwater_offset=189, last_stable_offset=189, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xb9\x00\x00\x03Y\x00\x00\x00\x00\x02!.\x11\xc6\x00\x00\x00\x00\x00\x03\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x04\x90\x03\x00\x00\x00\xd2\x02ObjectVRouter:cn-jenkins-deploy-...')])]) 02/26/2026 02:37:59.306 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 731202314 with 1 response partitions (0 implied) 02/26/2026 02:37:59.306 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 869 bytes of data for partition TopicPartition(topic='-uve-topic-2', partition=0) with offset 185 02/26/2026 02:37:59.306 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 185 for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) 02/26/2026 02:37:59.307 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-2', partition=0) to 189 (leader epoch 0) 02/26/2026 02:37:59.307 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 729 02/26/2026 02:37:59.307 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.307 7f0fede89f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 729 (2.3844242095947266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1428526147, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=256, last_stable_offset=256, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xfe\x00\x00\x02\x13\x00\x00\x00\x00\x02-Q\xf8\xdd\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xde\x03\x00\x00\x00\xa0\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 02/26/2026 02:37:59.307 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1428526147 with 1 response partitions (0 implied) 02/26/2026 02:37:59.307 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 543 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 254 02/26/2026 02:37:59.307 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 254 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) 02/26/2026 02:37:59.308 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 256 (leader epoch 0) 02/26/2026 02:37:59.332 7f0fed4eff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82246.200928, idle connection 260739.000000, request 304399.117708 02/26/2026 02:37:59.333 7f0fed4eff40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 02/26/2026 02:37:59.333 7f0fed4eff40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.333 7f0fed4eff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 693 (601.4132499694824 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=397915540, topics=[]) 02/26/2026 02:37:59.333 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 397915540 with 0 response partitions (1 implied) 02/26/2026 02:37:59.397 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82460.297363, idle connection 260673.000000, request 304399.114132 02/26/2026 02:37:59.397 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 737 02/26/2026 02:37:59.397 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.397 7f0fede89900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 737 (601.4158725738525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1980715442, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=267, last_stable_offset=267, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x01\n\x00\x00\x00\xfc\x00\x00\x00\x00\x02\x08\xb0\x03'\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\x92\x03\x00\x00\x00\xd4\x02ObjectVNTable:default-domain:def...")])]) 02/26/2026 02:37:59.397 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1980715442 with 1 response partitions (0 implied) 02/26/2026 02:37:59.398 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 264 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 266 02/26/2026 02:37:59.398 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 266 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 02/26/2026 02:37:59.398 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 267 (leader epoch 0) 02/26/2026 02:37:59.398 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82427.238037, idle connection 260473.000000, request 304399.321795 02/26/2026 02:37:59.398 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 703 02/26/2026 02:37:59.398 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.398 7f0fede89360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 703 (600.9912490844727 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1256647513, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=87, last_stable_offset=87, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00V\x00\x00\x01\x17\x00\x00\x00\x00\x02\xca\xf1Q\xa5\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xc8\x03\x00\x00\x00\x8a\x03ObjectVMITable:default-global-sy...')])]) 02/26/2026 02:37:59.399 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1256647513 with 1 response partitions (0 implied) 02/26/2026 02:37:59.399 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-19', partition=0) with offset 86 02/26/2026 02:37:59.399 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 86 for assigned partition TopicPartition(topic='-uve-topic-19', partition=0) 02/26/2026 02:37:59.399 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-19', partition=0) to 87 (leader epoch 0) 02/26/2026 02:37:59.401 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 15 02/26/2026 02:37:59.401 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 02/26/2026 02:37:59.401 7f0fed4ef720 [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)]) 02/26/2026 02:37:59.401 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.401 7f0fed4ef720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1664910702, session_epoch=683, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.401 7f0fed4ef720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1664910702, session_epoch=683, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.401 7f0fed4ef720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81572.147217, idle connection 259500.000000, request 304999.960184 02/26/2026 02:37:59.402 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 108 02/26/2026 02:37:59.402 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 02/26/2026 02:37:59.402 7f0fede899a0 [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)]) 02/26/2026 02:37:59.402 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.402 7f0fede899a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=793570068, session_epoch=696, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.402 7f0fede899a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=793570068, session_epoch=696, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.402 7f0fede899a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82843.594971, idle connection 260763.000000, request 304999.964476 02/26/2026 02:37:59.402 7f0fed4ef720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81571.189941, idle connection 259499.000000, request 304999.006271 02/26/2026 02:37:59.403 7f0fede899a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82842.972656, idle connection 260763.000000, request 304999.346018 02/26/2026 02:37:59.407 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 189 02/26/2026 02:37:59.407 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 02/26/2026 02:37:59.407 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-2', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 02/26/2026 02:37:59.407 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.407 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=731202314, session_epoch=714, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=189, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.408 7f0fed4ef360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=731202314, session_epoch=714, topics=[(topic='-uve-topic-2', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=189, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.408 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82173.418701, idle connection 260292.000000, request 304999.961615 02/26/2026 02:37:59.408 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 256 02/26/2026 02:37:59.408 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 02/26/2026 02:37:59.408 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 02/26/2026 02:37:59.408 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.408 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1428526147, session_epoch=726, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=256, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.408 7f0fede89f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 730 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1428526147, session_epoch=726, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=256, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.409 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82069.019531, idle connection 260888.000000, request 304999.965429 02/26/2026 02:37:59.409 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82172.234863, idle connection 260291.000000, request 304998.780966 02/26/2026 02:37:59.409 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82068.474854, idle connection 260887.000000, request 304999.423981 02/26/2026 02:37:59.477 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 241 02/26/2026 02:37:59.477 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 02/26/2026 02:37:59.477 7f0fede894a0 [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)]) 02/26/2026 02:37:59.477 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.477 7f0fede894a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=344673356, session_epoch=721, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.477 7f0fede894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 725 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=344673356, session_epoch=721, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.477 7f0fede894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82581.608398, idle connection 260118.000000, request 304999.951839 02/26/2026 02:37:59.478 7f0febd63c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82040.141602, idle connection 259892.000000, request 304397.668362 02/26/2026 02:37:59.478 7f0fede894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82581.065918, idle connection 260117.000000, request 304999.417782 02/26/2026 02:37:59.478 7f0febd63c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 697 02/26/2026 02:37:59.478 7f0febd63c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.478 7f0febd63c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 697 (602.9973030090332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1790419120, topics=[]) 02/26/2026 02:37:59.478 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1790419120 with 0 response partitions (1 implied) 02/26/2026 02:37:59.496 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 02/26/2026 02:37:59.496 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 02/26/2026 02:37:59.496 7f0fed4ef0e0 [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)]) 02/26/2026 02:37:59.496 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.496 7f0fed4ef0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1330368780, session_epoch=679, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.496 7f0fed4ef0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1330368780, session_epoch=679, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.496 7f0fed4ef0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81545.099854, idle connection 260147.000000, request 304999.946356 02/26/2026 02:37:59.496 7f0feb6d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82349.196045, idle connection 260303.000000, request 304388.211012 02/26/2026 02:37:59.502 7f0feb6d2180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 02/26/2026 02:37:59.502 7f0feb6d2180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.502 7f0feb6d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 687 (617.8145408630371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1012336525, topics=[]) 02/26/2026 02:37:59.502 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1012336525 with 0 response partitions (1 implied) 02/26/2026 02:37:59.504 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 267 02/26/2026 02:37:59.504 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 02/26/2026 02:37:59.504 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 02/26/2026 02:37:59.504 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.504 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1980715442, session_epoch=734, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=267, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.504 7f0fede89900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1980715442, session_epoch=734, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=267, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.504 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82352.883301, idle connection 260566.000000, request 304999.956846 02/26/2026 02:37:59.504 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 87 02/26/2026 02:37:59.505 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 02/26/2026 02:37:59.505 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-19', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 02/26/2026 02:37:59.505 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.505 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1256647513, session_epoch=700, topics=[(topic='-uve-topic-19', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=87, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.505 7f0fede89360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1256647513, session_epoch=700, topics=[(topic='-uve-topic-19', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=87, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:37:59.505 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82320.429199, idle connection 260367.000000, request 304999.965191 02/26/2026 02:37:59.507 7f0fed4ef0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81533.947266, idle connection 260135.000000, request 304988.808632 02/26/2026 02:37:59.508 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82349.166992, idle connection 260562.000000, request 304996.244669 02/26/2026 02:37:59.508 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82317.243164, idle connection 260363.000000, request 304996.782064 02/26/2026 02:37:59.569 7f0febd63e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 83294.525391, idle connection 259470.000000, request 304398.153782 02/26/2026 02:37:59.570 7f0febd63e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 02/26/2026 02:37:59.570 7f0febd63e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.570 7f0febd63e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 690 (602.3657321929932 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1137053957, topics=[]) 02/26/2026 02:37:59.570 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1137053957 with 0 response partitions (1 implied) 02/26/2026 02:37:59.572 7f0febd2d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82878.564209, idle connection 260337.000000, request 304398.460388 02/26/2026 02:37:59.572 7f0febd2d9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 02/26/2026 02:37:59.572 7f0febd2d9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.572 7f0febd2d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 692 (601.8421649932861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=291962954, topics=[]) 02/26/2026 02:37:59.572 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 291962954 with 0 response partitions (1 implied) 02/26/2026 02:37:59.576 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 40 02/26/2026 02:37:59.576 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 02/26/2026 02:37:59.576 7f0fed4efc20 [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)]) 02/26/2026 02:37:59.576 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.576 7f0fed4efc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876939456, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.576 7f0fed4efc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=876939456, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.576 7f0fed4efc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82746.108154, idle connection 260137.000000, request 304999.958277 02/26/2026 02:37:59.577 7f0fed4efc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82745.755127, idle connection 260137.000000, request 304999.609470 02/26/2026 02:37:59.653 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16 02/26/2026 02:37:59.653 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 02/26/2026 02:37:59.653 7f0feb6d25e0 [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)]) 02/26/2026 02:37:59.653 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.653 7f0feb6d25e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=651443891, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.653 7f0feb6d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=651443891, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.654 7f0feb6d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82777.763184, idle connection 260224.000000, request 304999.948502 02/26/2026 02:37:59.654 7f0feb6d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82777.345215, idle connection 260224.000000, request 304999.538183 02/26/2026 02:37:59.672 7f0fede89220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82755.912842, idle connection 259476.000000, request 304396.490574 02/26/2026 02:37:59.673 7f0fede89220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 717 02/26/2026 02:37:59.673 7f0fede89220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.673 7f0fede89220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 717 (603.9855480194092 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1526553912, topics=[]) 02/26/2026 02:37:59.673 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1526553912 with 0 response partitions (1 implied) 02/26/2026 02:37:59.673 7f0fed4efea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82103.779785, idle connection 259534.000000, request 304396.541595 02/26/2026 02:37:59.673 7f0fed4ef4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82644.371582, idle connection 259475.000000, request 304397.027493 02/26/2026 02:37:59.673 7f0fed4ef680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82688.643311, idle connection 259920.000000, request 304397.903681 02/26/2026 02:37:59.674 7f0fed4efea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 02/26/2026 02:37:59.674 7f0fed4efea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.674 7f0fed4efea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 694 (603.985071182251 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=53647297, topics=[]) 02/26/2026 02:37:59.674 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 53647297 with 0 response partitions (1 implied) 02/26/2026 02:37:59.674 7f0fed4ef4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 692 02/26/2026 02:37:59.674 7f0fed4ef4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.674 7f0fed4ef4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 692 (603.8053035736084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=989652527, topics=[]) 02/26/2026 02:37:59.674 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 989652527 with 0 response partitions (1 implied) 02/26/2026 02:37:59.674 7f0fed4ef680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 02/26/2026 02:37:59.674 7f0fed4ef680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.675 7f0fed4ef680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 688 (603.2288074493408 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1930860683, topics=[]) 02/26/2026 02:37:59.675 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1930860683 with 0 response partitions (1 implied) 02/26/2026 02:37:59.743 7f0fede89b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81836.521484, idle connection 260261.000000, request 304399.048805 02/26/2026 02:37:59.744 7f0fede89b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 709 02/26/2026 02:37:59.744 7f0fede89b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.744 7f0fede89b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 709 (601.50146484375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1123005179, topics=[]) 02/26/2026 02:37:59.744 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1123005179 with 0 response partitions (1 implied) 02/26/2026 02:37:59.776 7f0fede89ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82700.002686, idle connection 259926.000000, request 304399.100780 02/26/2026 02:37:59.776 7f0fede89ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 02/26/2026 02:37:59.777 7f0fede89ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.777 7f0fede89ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 710 (601.5121936798096 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=892350470, topics=[]) 02/26/2026 02:37:59.777 7f0fede89ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 892350470 with 0 response partitions (1 implied) 02/26/2026 02:37:59.779 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 330 02/26/2026 02:37:59.779 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 02/26/2026 02:37:59.779 7f0fede89720 [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)]) 02/26/2026 02:37:59.779 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.779 7f0fede89720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563880998, session_epoch=739, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.779 7f0fede89720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1563880998, session_epoch=739, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.779 7f0fede89720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82643.333984, idle connection 260472.000000, request 304999.957085 02/26/2026 02:37:59.780 7f0fede89720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82642.927246, idle connection 260471.000000, request 304999.550581 02/26/2026 02:37:59.824 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 26 02/26/2026 02:37:59.824 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 02/26/2026 02:37:59.824 7f0fed4efcc0 [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)]) 02/26/2026 02:37:59.824 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.824 7f0fed4efcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1986605365, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.824 7f0fed4efcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1986605365, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.825 7f0fed4efcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82605.346436, idle connection 260053.000000, request 304999.948263 02/26/2026 02:37:59.825 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 22 02/26/2026 02:37:59.825 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 02/26/2026 02:37:59.825 7f0fed4ef2c0 [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)]) 02/26/2026 02:37:59.825 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.825 7f0fed4ef2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1570397235, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.825 7f0fed4ef2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1570397235, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.825 7f0fed4ef2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82050.570312, idle connection 259039.000000, request 304999.965429 02/26/2026 02:37:59.826 7f0fed4efcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82604.337402, idle connection 260052.000000, request 304998.948574 02/26/2026 02:37:59.826 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 18 02/26/2026 02:37:59.826 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 02/26/2026 02:37:59.826 7f0feb6d22c0 [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)]) 02/26/2026 02:37:59.826 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.826 7f0feb6d22c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234902840, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.826 7f0feb6d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=234902840, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.826 7f0feb6d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.906006, idle connection 259762.000000, request 304999.966860 02/26/2026 02:37:59.827 7f0fed4ef2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82049.343262, idle connection 259038.000000, request 304998.741627 02/26/2026 02:37:59.827 7f0feb6d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81528.316650, idle connection 259761.000000, request 304999.380112 02/26/2026 02:37:59.861 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 281 02/26/2026 02:37:59.861 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 02/26/2026 02:37:59.861 7f0fede89680 [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)]) 02/26/2026 02:37:59.861 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.862 7f0fede89680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=86757827, session_epoch=731, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.862 7f0fede89680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=86757827, session_epoch=731, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.862 7f0fede89680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81617.259766, idle connection 259909.000000, request 304999.926805 02/26/2026 02:37:59.862 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 261 02/26/2026 02:37:59.862 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 02/26/2026 02:37:59.863 7f0fede890e0 [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)]) 02/26/2026 02:37:59.863 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.863 7f0fede890e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1841935055, session_epoch=732, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.863 7f0fede890e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1841935055, session_epoch=732, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.863 7f0fede890e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82096.425293, idle connection 259650.000000, request 304999.928713 02/26/2026 02:37:59.864 7f0fede89680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81615.612061, idle connection 259908.000000, request 304998.289585 02/26/2026 02:37:59.864 7f0fede890e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82095.425293, idle connection 259649.000000, request 304998.933077 02/26/2026 02:37:59.898 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81155.396729, idle connection 259708.000000, request 304398.909330 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1009 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 1009 (601.630449295044 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=123186983, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3780, last_stable_offset=3780, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xc3\x00\x00\x01\x04\x00\x00\x00\x00\x02\x1a\xc6X\xf6\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 123186983 with 1 response partitions (0 implied) 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3779 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3779 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 02/26/2026 02:37:59.899 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3780 (leader epoch 0) 02/26/2026 02:37:59.904 7f0febf2df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82216.641602, idle connection 259564.000000, request 304398.912907 02/26/2026 02:37:59.904 7f0febf2df40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 02/26/2026 02:37:59.904 7f0febf2df40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.904 7f0febf2df40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 683 (601.4306545257568 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=441217745, topics=[]) 02/26/2026 02:37:59.904 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 441217745 with 0 response partitions (1 implied) 02/26/2026 02:37:59.906 7f0fed4ef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81549.941406, idle connection 259680.000000, request 304398.380995 02/26/2026 02:37:59.906 7f0fed4ef900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 02/26/2026 02:37:59.906 7f0fed4ef900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:37:59.906 7f0fed4ef900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 695 (601.9058227539062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=610899018, topics=[]) 02/26/2026 02:37:59.906 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 610899018 with 0 response partitions (1 implied) 02/26/2026 02:37:59.933 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 53 02/26/2026 02:37:59.933 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 02/26/2026 02:37:59.933 7f0fed4eff40 [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)]) 02/26/2026 02:37:59.934 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:37:59.934 7f0fed4eff40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=397915540, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.934 7f0fed4eff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=397915540, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:37:59.934 7f0fed4eff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81644.557861, idle connection 260138.000000, request 304999.951363 02/26/2026 02:37:59.934 7f0fed4eff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81644.158691, idle connection 260137.000000, request 304999.558449 02/26/2026 02:38:00.000 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3780 02/26/2026 02:38:00.000 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 02/26/2026 02:38:00.000 7f0febf2de00 [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)]) 02/26/2026 02:38:00.000 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.000 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123186983, session_epoch=1006, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3780, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:38:00.000 7f0febf2de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 1010 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123186983, session_epoch=1006, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3780, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:38:00.001 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81052.982666, idle connection 259606.000000, request 304999.948740 02/26/2026 02:38:00.001 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81052.571777, idle connection 259606.000000, request 304999.544621 02/26/2026 02:38:00.005 7f0fed4ef720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80968.305420, idle connection 258897.000000, request 304396.120548 02/26/2026 02:38:00.005 7f0fed4ef720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 687 02/26/2026 02:38:00.005 7f0fed4ef720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.006 7f0fed4ef720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 687 (604.2826175689697 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1664910702, topics=[]) 02/26/2026 02:38:00.006 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1664910702 with 0 response partitions (1 implied) 02/26/2026 02:38:00.006 7f0fede899a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82239.609131, idle connection 260159.000000, request 304395.980120 02/26/2026 02:38:00.006 7f0fede899a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 700 02/26/2026 02:38:00.006 7f0fede899a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.006 7f0fede899a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 700 (604.3329238891602 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=793570068, topics=[]) 02/26/2026 02:38:00.006 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 793570068 with 0 response partitions (1 implied) 02/26/2026 02:38:00.009 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81571.701172, idle connection 259690.000000, request 304398.243904 02/26/2026 02:38:00.010 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 718 02/26/2026 02:38:00.010 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.010 7f0fed4ef360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 718 (602.0689010620117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=731202314, topics=[]) 02/26/2026 02:38:00.010 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 731202314 with 0 response partitions (1 implied) 02/26/2026 02:38:00.010 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81467.593262, idle connection 260286.000000, request 304398.540497 02/26/2026 02:38:00.010 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 730 02/26/2026 02:38:00.010 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.010 7f0fede89f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 730 (601.7487049102783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1428526147, topics=[]) 02/26/2026 02:38:00.010 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1428526147 with 0 response partitions (1 implied) 02/26/2026 02:38:00.079 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 65 02/26/2026 02:38:00.079 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 02/26/2026 02:38:00.079 7f0febd63c20 [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)]) 02/26/2026 02:38:00.079 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.079 7f0febd63c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1790419120, session_epoch=694, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.079 7f0febd63c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 698 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1790419120, session_epoch=694, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.079 7f0febd63c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81438.196533, idle connection 259290.000000, request 304999.948740 02/26/2026 02:38:00.080 7f0fede894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81979.191162, idle connection 259515.000000, request 304397.540808 02/26/2026 02:38:00.080 7f0febd63c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81437.644531, idle connection 259290.000000, request 304999.404192 02/26/2026 02:38:00.080 7f0fede894a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 725 02/26/2026 02:38:00.080 7f0fede894a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.080 7f0fede894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 725 (603.1358242034912 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=344673356, topics=[]) 02/26/2026 02:38:00.081 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 344673356 with 0 response partitions (1 implied) 02/26/2026 02:38:00.103 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 02/26/2026 02:38:00.103 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 02/26/2026 02:38:00.103 7f0feb6d2180 [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)]) 02/26/2026 02:38:00.103 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.103 7f0feb6d2180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1012336525, session_epoch=684, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.103 7f0feb6d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1012336525, session_epoch=684, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.104 7f0feb6d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81741.917969, idle connection 259696.000000, request 304999.948740 02/26/2026 02:38:00.104 7f0feb6d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81741.537598, idle connection 259696.000000, request 304999.576330 02/26/2026 02:38:00.109 7f0fed4ef0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80932.645020, idle connection 259534.000000, request 304387.502670 02/26/2026 02:38:00.109 7f0fed4ef0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 683 02/26/2026 02:38:00.109 7f0fed4ef0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.109 7f0fed4ef0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 683 (612.9212379455566 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1330368780, topics=[]) 02/26/2026 02:38:00.109 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1330368780 with 0 response partitions (1 implied) 02/26/2026 02:38:00.109 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81747.748535, idle connection 259961.000000, request 304394.825935 02/26/2026 02:38:00.109 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81715.961914, idle connection 259762.000000, request 304395.500660 02/26/2026 02:38:00.110 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 738 02/26/2026 02:38:00.110 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.110 7f0fede89900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 738 (605.5865287780762 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1980715442, topics=[]) 02/26/2026 02:38:00.110 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1980715442 with 0 response partitions (1 implied) 02/26/2026 02:38:00.110 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 704 02/26/2026 02:38:00.110 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.110 7f0fede89360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 704 (605.2095890045166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1256647513, topics=[]) 02/26/2026 02:38:00.110 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1256647513 with 0 response partitions (1 implied) 02/26/2026 02:38:00.170 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 26 02/26/2026 02:38:00.171 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 02/26/2026 02:38:00.171 7f0febd63e00 [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)]) 02/26/2026 02:38:00.171 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.171 7f0febd63e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137053957, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.171 7f0febd63e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1137053957, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.171 7f0febd63e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82692.493408, idle connection 258868.000000, request 304999.930620 02/26/2026 02:38:00.172 7f0febd63e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82692.019775, idle connection 258868.000000, request 304999.466181 02/26/2026 02:38:00.172 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 26 02/26/2026 02:38:00.172 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 02/26/2026 02:38:00.172 7f0febd2d9a0 [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)]) 02/26/2026 02:38:00.172 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.173 7f0febd2d9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=291962954, session_epoch=689, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.173 7f0febd2d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=291962954, session_epoch=689, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.173 7f0febd2d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82277.312744, idle connection 259736.000000, request 304999.963999 02/26/2026 02:38:00.173 7f0febd2d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82277.019287, idle connection 259736.000000, request 304999.661922 02/26/2026 02:38:00.177 7f0fed4efc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82145.425537, idle connection 259536.000000, request 304399.277925 02/26/2026 02:38:00.177 7f0fed4efc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 02/26/2026 02:38:00.177 7f0fed4efc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.177 7f0fed4efc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 690 (601.1953353881836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876939456, topics=[]) 02/26/2026 02:38:00.178 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876939456 with 0 response partitions (1 implied) 02/26/2026 02:38:00.254 7f0feb6d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82176.860840, idle connection 259623.000000, request 304399.044991 02/26/2026 02:38:00.255 7f0feb6d25e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 02/26/2026 02:38:00.255 7f0feb6d25e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.255 7f0feb6d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 690 (601.4792919158936 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=651443891, topics=[]) 02/26/2026 02:38:00.255 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 651443891 with 0 response partitions (1 implied) 02/26/2026 02:38:00.273 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 205 02/26/2026 02:38:00.273 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 02/26/2026 02:38:00.273 7f0fede89220 [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)]) 02/26/2026 02:38:00.274 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.274 7f0fede89220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1526553912, session_epoch=714, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.274 7f0fede89220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1526553912, session_epoch=714, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.274 7f0fede89220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82154.275391, idle connection 258874.000000, request 304999.948263 02/26/2026 02:38:00.274 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 51 02/26/2026 02:38:00.274 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 02/26/2026 02:38:00.274 7f0fed4efea0 [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)]) 02/26/2026 02:38:00.274 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.274 7f0fed4efea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=53647297, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.275 7f0fed4efea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=53647297, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.275 7f0fed4efea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81502.130371, idle connection 258932.000000, request 304999.947786 02/26/2026 02:38:00.275 7f0fede89220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82152.956055, idle connection 258873.000000, request 304998.633623 02/26/2026 02:38:00.275 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 26 02/26/2026 02:38:00.276 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 02/26/2026 02:38:00.276 7f0fed4ef4a0 [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)]) 02/26/2026 02:38:00.276 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.276 7f0fed4ef4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=989652527, session_epoch=689, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.276 7f0fed4ef4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=989652527, session_epoch=689, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.276 7f0fed4ef4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82041.654053, idle connection 258873.000000, request 304999.966860 02/26/2026 02:38:00.276 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 33 02/26/2026 02:38:00.276 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 02/26/2026 02:38:00.276 7f0fed4ef680 [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)]) 02/26/2026 02:38:00.276 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.276 7f0fed4ef680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1930860683, session_epoch=685, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.276 7f0fed4ef680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1930860683, session_epoch=685, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.277 7f0fed4ef680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82085.373535, idle connection 259316.000000, request 304999.955893 02/26/2026 02:38:00.277 7f0fed4efea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81499.949951, idle connection 258930.000000, request 304997.775316 02/26/2026 02:38:00.277 7f0fed4ef4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82040.307373, idle connection 258871.000000, request 304998.619556 02/26/2026 02:38:00.278 7f0fed4ef680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82084.424072, idle connection 259315.000000, request 304999.009609 02/26/2026 02:38:00.344 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 118 02/26/2026 02:38:00.345 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 02/26/2026 02:38:00.345 7f0fede89b80 [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)]) 02/26/2026 02:38:00.345 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.345 7f0fede89b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1123005179, session_epoch=706, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.345 7f0fede89b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 710 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1123005179, session_epoch=706, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.345 7f0fede89b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81234.597168, idle connection 259659.000000, request 304999.945641 02/26/2026 02:38:00.346 7f0fede89b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81234.173828, idle connection 259658.000000, request 304999.527216 02/26/2026 02:38:00.377 7f0fede89ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 211 02/26/2026 02:38:00.377 7f0fede89ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 02/26/2026 02:38:00.378 7f0fede89ae0 [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)]) 02/26/2026 02:38:00.378 7f0fede89ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.378 7f0fede89ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892350470, session_epoch=707, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.378 7f0fede89ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=892350470, session_epoch=707, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.378 7f0fede89ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82098.004639, idle connection 259324.000000, request 304999.948740 02/26/2026 02:38:00.379 7f0fede89ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82097.493896, idle connection 259324.000000, request 304999.446154 02/26/2026 02:38:00.380 7f0fede89720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82042.591309, idle connection 259871.000000, request 304399.217844 02/26/2026 02:38:00.380 7f0fede89720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 743 02/26/2026 02:38:00.380 7f0fede89720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.380 7f0fede89720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 743 (601.1302471160889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1563880998, topics=[]) 02/26/2026 02:38:00.381 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1563880998 with 0 response partitions (1 implied) 02/26/2026 02:38:00.427 7f0fed4efcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82003.019775, idle connection 259450.000000, request 304397.620440 02/26/2026 02:38:00.427 7f0fed4efcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 02/26/2026 02:38:00.427 7f0fed4efcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.427 7f0fed4efcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 694 (602.8649806976318 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1986605365, topics=[]) 02/26/2026 02:38:00.428 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1986605365 with 0 response partitions (1 implied) 02/26/2026 02:38:00.428 7f0fed4ef2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81448.060547, idle connection 258436.000000, request 304397.456169 02/26/2026 02:38:00.428 7f0feb6d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80927.223633, idle connection 259160.000000, request 304398.285866 02/26/2026 02:38:00.428 7f0fed4ef2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 690 02/26/2026 02:38:00.428 7f0fed4ef2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.428 7f0fed4ef2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 690 (602.975606918335 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1570397235, topics=[]) 02/26/2026 02:38:00.428 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1570397235 with 0 response partitions (1 implied) 02/26/2026 02:38:00.429 7f0feb6d22c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 02/26/2026 02:38:00.429 7f0feb6d22c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.429 7f0feb6d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 691 (602.4281978607178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=234902840, topics=[]) 02/26/2026 02:38:00.429 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 234902840 with 0 response partitions (1 implied) 02/26/2026 02:38:00.465 7f0fede89680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81014.502930, idle connection 259307.000000, request 304397.171259 02/26/2026 02:38:00.465 7f0fede89680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 735 02/26/2026 02:38:00.465 7f0fede89680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.465 7f0fede89680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 735 (603.3990383148193 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=86757827, topics=[]) 02/26/2026 02:38:00.465 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 86757827 with 0 response partitions (1 implied) 02/26/2026 02:38:00.466 7f0fede890e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81493.835205, idle connection 259048.000000, request 304397.345304 02/26/2026 02:38:00.466 7f0fede890e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 736 02/26/2026 02:38:00.466 7f0fede890e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.466 7f0fede890e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 736 (602.9446125030518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1841935055, topics=[]) 02/26/2026 02:38:00.466 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1841935055 with 0 response partitions (1 implied) 02/26/2026 02:38:00.505 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 02/26/2026 02:38:00.505 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 02/26/2026 02:38:00.505 7f0febf2df40 [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)]) 02/26/2026 02:38:00.505 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.505 7f0febf2df40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=441217745, session_epoch=680, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.505 7f0febf2df40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=441217745, session_epoch=680, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.506 7f0febf2df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81614.982422, idle connection 258962.000000, request 304999.933720 02/26/2026 02:38:00.506 7f0febf2df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81614.489258, idle connection 258962.000000, request 304999.448776 02/26/2026 02:38:00.507 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 62 02/26/2026 02:38:00.507 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 02/26/2026 02:38:00.507 7f0fed4ef900 [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)]) 02/26/2026 02:38:00.507 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.507 7f0fed4ef900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=610899018, session_epoch=692, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.507 7f0fed4ef900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 696 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=610899018, session_epoch=692, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.507 7f0fed4ef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80948.314941, idle connection 259078.000000, request 304999.947548 02/26/2026 02:38:00.508 7f0fed4ef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80947.923340, idle connection 259078.000000, request 304999.559641 02/26/2026 02:38:00.535 7f0fed4eff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81043.696045, idle connection 259537.000000, request 304399.085999 02/26/2026 02:38:00.535 7f0fed4eff40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 694 02/26/2026 02:38:00.535 7f0fed4eff40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.535 7f0fed4eff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 694 (601.4659404754639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=397915540, topics=[]) 02/26/2026 02:38:00.535 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 397915540 with 0 response partitions (1 implied) 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80452.076416, idle connection 259005.000000, request 304399.042368 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1010 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 1010 (601.4702320098877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=123186983, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3781, last_stable_offset=3781, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xc4\x00\x00\x00\xf8\x00\x00\x00\x00\x02\xff&\xa5\x95\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x8a\x03\x00\x00\x00\xcc\x02ObjectBgpRouter:cn-jenkins-deplo...')])]) 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 123186983 with 1 response partitions (0 implied) 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 260 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3780 02/26/2026 02:38:00.602 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3780 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 02/26/2026 02:38:00.603 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3781 (leader epoch 0) 02/26/2026 02:38:00.606 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 15 02/26/2026 02:38:00.606 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 02/26/2026 02:38:00.606 7f0fed4ef720 [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)]) 02/26/2026 02:38:00.606 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.606 7f0fed4ef720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1664910702, session_epoch=684, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.606 7f0fed4ef720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1664910702, session_epoch=684, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.607 7f0fed4ef720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80366.892090, idle connection 258295.000000, request 304999.953270 02/26/2026 02:38:00.607 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 108 02/26/2026 02:38:00.607 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 02/26/2026 02:38:00.607 7f0fede899a0 [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)]) 02/26/2026 02:38:00.607 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.607 7f0fede899a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=793570068, session_epoch=697, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.607 7f0fede899a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=793570068, session_epoch=697, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.607 7f0fede899a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81638.224365, idle connection 259558.000000, request 304999.963999 02/26/2026 02:38:00.608 7f0fed4ef720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80365.780029, idle connection 258294.000000, request 304998.844624 02/26/2026 02:38:00.608 7f0fede899a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81637.427734, idle connection 259557.000000, request 304999.167442 02/26/2026 02:38:00.610 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 189 02/26/2026 02:38:00.611 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 02/26/2026 02:38:00.611 7f0fed4ef360 [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)]) 02/26/2026 02:38:00.611 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.611 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=731202314, session_epoch=715, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.611 7f0fed4ef360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=731202314, session_epoch=715, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.611 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80969.819092, idle connection 259089.000000, request 304999.945402 02/26/2026 02:38:00.612 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 256 02/26/2026 02:38:00.612 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 02/26/2026 02:38:00.612 7f0fede89f40 [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)]) 02/26/2026 02:38:00.612 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.612 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1428526147, session_epoch=727, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.612 7f0fede89f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 731 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1428526147, session_epoch=727, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.612 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80865.343994, idle connection 259684.000000, request 304999.947548 02/26/2026 02:38:00.613 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80968.455566, idle connection 259087.000000, request 304998.585463 02/26/2026 02:38:00.613 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80864.543213, idle connection 259683.000000, request 304999.150753 02/26/2026 02:38:00.681 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 241 02/26/2026 02:38:00.681 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 02/26/2026 02:38:00.681 7f0fede894a0 [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)]) 02/26/2026 02:38:00.681 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.681 7f0fede894a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=344673356, session_epoch=722, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.682 7f0fede894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 726 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=344673356, session_epoch=722, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.682 7f0fede894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81377.226318, idle connection 258913.000000, request 304999.942780 02/26/2026 02:38:00.682 7f0febd63c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80835.737061, idle connection 258688.000000, request 304397.494555 02/26/2026 02:38:00.682 7f0fede894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81376.626465, idle connection 258913.000000, request 304999.349117 02/26/2026 02:38:00.683 7f0febd63c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 698 02/26/2026 02:38:00.683 7f0febd63c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.683 7f0febd63c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 698 (603.2555103302002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1790419120, topics=[]) 02/26/2026 02:38:00.683 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1790419120 with 0 response partitions (1 implied) 02/26/2026 02:38:00.703 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3781 02/26/2026 02:38:00.703 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 02/26/2026 02:38:00.703 7f0febf2de00 [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)]) 02/26/2026 02:38:00.703 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.704 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123186983, session_epoch=1007, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3781, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:38:00.704 7f0febf2de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 1011 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=123186983, session_epoch=1007, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3781, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 02/26/2026 02:38:00.704 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80349.728271, idle connection 258903.000000, request 304999.950886 02/26/2026 02:38:00.704 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80349.324707, idle connection 258902.000000, request 304999.552965 02/26/2026 02:38:00.704 7f0feb6d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81140.984619, idle connection 259095.000000, request 304399.024248 02/26/2026 02:38:00.705 7f0feb6d2180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 02/26/2026 02:38:00.705 7f0feb6d2180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.705 7f0feb6d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 688 (601.3596057891846 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1012336525, topics=[]) 02/26/2026 02:38:00.705 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1012336525 with 0 response partitions (1 implied) 02/26/2026 02:38:00.709 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 02/26/2026 02:38:00.709 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 02/26/2026 02:38:00.709 7f0fed4ef0e0 [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)]) 02/26/2026 02:38:00.710 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.710 7f0fed4ef0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1330368780, session_epoch=680, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.710 7f0fed4ef0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1330368780, session_epoch=680, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.710 7f0fed4ef0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80331.295898, idle connection 258933.000000, request 304999.958515 02/26/2026 02:38:00.710 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 267 02/26/2026 02:38:00.710 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 02/26/2026 02:38:00.710 7f0fede89900 [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)]) 02/26/2026 02:38:00.710 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.710 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1980715442, session_epoch=735, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.710 7f0fede89900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1980715442, session_epoch=735, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.710 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81146.548096, idle connection 259360.000000, request 304999.959230 02/26/2026 02:38:00.711 7f0fed4ef0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80330.322998, idle connection 258932.000000, request 304998.989582 02/26/2026 02:38:00.711 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 87 02/26/2026 02:38:00.711 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 02/26/2026 02:38:00.711 7f0fede89360 [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)]) 02/26/2026 02:38:00.711 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.711 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1256647513, session_epoch=701, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.711 7f0fede89360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 705 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1256647513, session_epoch=701, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.711 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81113.926270, idle connection 259160.000000, request 304999.968052 02/26/2026 02:38:00.712 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81145.270508, idle connection 259358.000000, request 304998.684406 02/26/2026 02:38:00.712 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81113.197266, idle connection 259159.000000, request 304999.240637 02/26/2026 02:38:00.772 7f0febd63e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 82091.464600, idle connection 258267.000000, request 304398.906231 02/26/2026 02:38:00.773 7f0febd63e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 02/26/2026 02:38:00.773 7f0febd63e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.773 7f0febd63e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 691 (601.6058921813965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1137053957, topics=[]) 02/26/2026 02:38:00.773 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1137053957 with 0 response partitions (1 implied) 02/26/2026 02:38:00.774 7f0febd2d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81675.880127, idle connection 259134.000000, request 304398.529768 02/26/2026 02:38:00.774 7f0febd2d9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 02/26/2026 02:38:00.774 7f0febd2d9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.775 7f0febd2d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 693 (601.7837524414062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=291962954, topics=[]) 02/26/2026 02:38:00.775 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 291962954 with 0 response partitions (1 implied) 02/26/2026 02:38:00.778 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 40 02/26/2026 02:38:00.778 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 02/26/2026 02:38:00.778 7f0fed4efc20 [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)]) 02/26/2026 02:38:00.778 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.778 7f0fed4efc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=876939456, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.778 7f0fed4efc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=876939456, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.778 7f0fed4efc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81543.876465, idle connection 258935.000000, request 304999.958515 02/26/2026 02:38:00.779 7f0fed4efc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81543.521729, idle connection 258934.000000, request 304999.606848 02/26/2026 02:38:00.856 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 16 02/26/2026 02:38:00.856 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 02/26/2026 02:38:00.856 7f0feb6d25e0 [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)]) 02/26/2026 02:38:00.856 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.856 7f0feb6d25e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=651443891, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.856 7f0feb6d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=651443891, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.856 7f0feb6d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81575.078125, idle connection 259022.000000, request 304999.946117 02/26/2026 02:38:00.857 7f0feb6d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81574.654297, idle connection 259021.000000, request 304999.529362 02/26/2026 02:38:00.877 7f0fede89220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81550.853760, idle connection 258271.000000, request 304396.523714 02/26/2026 02:38:00.878 7f0fede89220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 718 02/26/2026 02:38:00.878 7f0fede89220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.878 7f0fede89220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 718 (603.9738655090332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1526553912, topics=[]) 02/26/2026 02:38:00.878 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1526553912 with 0 response partitions (1 implied) 02/26/2026 02:38:00.878 7f0fed4efea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80898.557373, idle connection 258329.000000, request 304396.381378 02/26/2026 02:38:00.878 7f0fed4efea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 695 02/26/2026 02:38:00.879 7f0fed4efea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.879 7f0fed4efea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 695 (603.9533615112305 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=53647297, topics=[]) 02/26/2026 02:38:00.879 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 53647297 with 0 response partitions (1 implied) 02/26/2026 02:38:00.879 7f0fed4ef4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81438.548584, idle connection 258270.000000, request 304396.851540 02/26/2026 02:38:00.879 7f0fed4ef680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81482.782471, idle connection 258714.000000, request 304397.367477 02/26/2026 02:38:00.879 7f0fed4ef4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 693 02/26/2026 02:38:00.880 7f0fed4ef4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.880 7f0fed4ef4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 693 (603.6937236785889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=989652527, topics=[]) 02/26/2026 02:38:00.880 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 989652527 with 0 response partitions (1 implied) 02/26/2026 02:38:00.880 7f0fed4ef680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 689 02/26/2026 02:38:00.880 7f0fed4ef680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.880 7f0fed4ef680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 689 (603.4886837005615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1930860683, topics=[]) 02/26/2026 02:38:00.880 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1930860683 with 0 response partitions (1 implied) 02/26/2026 02:38:00.946 7f0fede89b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80633.687500, idle connection 259058.000000, request 304399.034739 02/26/2026 02:38:00.946 7f0fede89b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 710 02/26/2026 02:38:00.947 7f0fede89b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.947 7f0fede89b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 710 (601.4924049377441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1123005179, topics=[]) 02/26/2026 02:38:00.947 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1123005179 with 0 response partitions (1 implied) 02/26/2026 02:38:00.979 7f0fede89ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81497.062988, idle connection 258723.000000, request 304399.008036 02/26/2026 02:38:00.979 7f0fede89ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 711 02/26/2026 02:38:00.979 7f0fede89ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:00.979 7f0fede89ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 711 (601.4754772186279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=892350470, topics=[]) 02/26/2026 02:38:00.980 7f0fede89ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 892350470 with 0 response partitions (1 implied) 02/26/2026 02:38:00.981 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 330 02/26/2026 02:38:00.981 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 02/26/2026 02:38:00.981 7f0fede89720 [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)]) 02/26/2026 02:38:00.981 7f0fede89720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:00.981 7f0fede89720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1563880998, session_epoch=740, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.981 7f0fede89720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1563880998, session_epoch=740, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:00.982 7f0fede89720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81441.132812, idle connection 259270.000000, request 304999.953270 02/26/2026 02:38:00.982 7f0fede89720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81440.772705, idle connection 259269.000000, request 304999.598265 02/26/2026 02:38:01.028 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 26 02/26/2026 02:38:01.028 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 02/26/2026 02:38:01.028 7f0fed4efcc0 [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)]) 02/26/2026 02:38:01.028 7f0fed4efcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.028 7f0fed4efcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1986605365, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.029 7f0fed4efcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1986605365, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.029 7f0fed4efcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81401.274170, idle connection 258849.000000, request 304999.947071 02/26/2026 02:38:01.029 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 22 02/26/2026 02:38:01.029 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 02/26/2026 02:38:01.029 7f0fed4ef2c0 [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)]) 02/26/2026 02:38:01.029 7f0fed4ef2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.029 7f0fed4ef2c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1570397235, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.029 7f0fed4ef2c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1570397235, session_epoch=687, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.029 7f0fed4ef2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80846.476562, idle connection 257835.000000, request 304999.964237 02/26/2026 02:38:01.030 7f0fed4efcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81400.229248, idle connection 258847.000000, request 304998.912334 02/26/2026 02:38:01.030 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 18 02/26/2026 02:38:01.030 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 02/26/2026 02:38:01.030 7f0feb6d22c0 [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)]) 02/26/2026 02:38:01.030 7f0feb6d22c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.030 7f0feb6d22c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=234902840, session_epoch=688, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.030 7f0feb6d22c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=234902840, session_epoch=688, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.030 7f0feb6d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80324.787354, idle connection 258558.000000, request 304999.966621 02/26/2026 02:38:01.031 7f0fed4ef2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80845.198486, idle connection 257833.000000, request 304998.688698 02/26/2026 02:38:01.031 7f0feb6d22c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80324.162109, idle connection 258557.000000, request 304999.343634 02/26/2026 02:38:01.066 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 281 02/26/2026 02:38:01.066 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 02/26/2026 02:38:01.066 7f0fede89680 [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)]) 02/26/2026 02:38:01.066 7f0fede89680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.066 7f0fede89680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=86757827, session_epoch=732, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.066 7f0fede89680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=86757827, session_epoch=732, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.067 7f0fede89680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80412.647705, idle connection 258705.000000, request 304999.946117 02/26/2026 02:38:01.067 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 261 02/26/2026 02:38:01.067 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 02/26/2026 02:38:01.067 7f0fede890e0 [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)]) 02/26/2026 02:38:01.067 7f0fede890e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.067 7f0fede890e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1841935055, session_epoch=733, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.067 7f0fede890e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 737 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1841935055, session_epoch=733, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.067 7f0fede890e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80892.213867, idle connection 258446.000000, request 304999.962807 02/26/2026 02:38:01.068 7f0fede89680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80411.574707, idle connection 258704.000000, request 304998.882294 02/26/2026 02:38:01.068 7f0fede890e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80891.588867, idle connection 258445.000000, request 304999.343395 02/26/2026 02:38:01.107 7f0febf2df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81013.541504, idle connection 258361.000000, request 304398.495674 02/26/2026 02:38:01.107 7f0febf2df40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 02/26/2026 02:38:01.107 7f0febf2df40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.108 7f0febf2df40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 684 (602.0307540893555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=441217745, topics=[]) 02/26/2026 02:38:01.108 7f0febf2df40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 441217745 with 0 response partitions (1 implied) 02/26/2026 02:38:01.109 7f0fed4ef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80347.161865, idle connection 258477.000000, request 304398.797989 02/26/2026 02:38:01.109 7f0fed4ef900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 696 02/26/2026 02:38:01.109 7f0fed4ef900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.109 7f0fed4ef900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 696 (601.5629768371582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=610899018, topics=[]) 02/26/2026 02:38:01.109 7f0fed4ef900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 610899018 with 0 response partitions (1 implied) 02/26/2026 02:38:01.136 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 53 02/26/2026 02:38:01.136 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 02/26/2026 02:38:01.136 7f0fed4eff40 [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)]) 02/26/2026 02:38:01.136 7f0fed4eff40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.136 7f0fed4eff40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=397915540, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.136 7f0fed4eff40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 695 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=397915540, session_epoch=691, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.137 7f0fed4eff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80441.896729, idle connection 258935.000000, request 304999.949455 02/26/2026 02:38:01.137 7f0fed4eff40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80441.494629, idle connection 258934.000000, request 304999.554873 02/26/2026 02:38:01.209 7f0fed4ef720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79764.909424, idle connection 257693.000000, request 304397.967815 02/26/2026 02:38:01.209 7f0fed4ef720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 688 02/26/2026 02:38:01.209 7f0fed4ef720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.209 7f0fed4ef720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 688 (602.5302410125732 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1664910702, topics=[]) 02/26/2026 02:38:01.209 7f0fed4ef720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1664910702 with 0 response partitions (1 implied) 02/26/2026 02:38:01.209 7f0fede899a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81036.120117, idle connection 258956.000000, request 304397.860765 02/26/2026 02:38:01.210 7f0fede899a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 701 02/26/2026 02:38:01.210 7f0fede899a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.210 7f0fede899a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 701 (602.4801731109619 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=793570068, topics=[]) 02/26/2026 02:38:01.210 7f0fede899a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 793570068 with 0 response partitions (1 implied) 02/26/2026 02:38:01.213 7f0fed4ef360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80367.640381, idle connection 258486.000000, request 304397.771120 02/26/2026 02:38:01.214 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 719 02/26/2026 02:38:01.214 7f0fed4ef360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.214 7f0fed4ef360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 719 (602.6420593261719 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=731202314, topics=[]) 02/26/2026 02:38:01.214 7f0fed4ef360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 731202314 with 0 response partitions (1 implied) 02/26/2026 02:38:01.214 7f0fede89f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80263.349365, idle connection 259082.000000, request 304397.958755 02/26/2026 02:38:01.214 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 731 02/26/2026 02:38:01.215 7f0fede89f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.215 7f0fede89f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 731 (602.332353591919 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1428526147, topics=[]) 02/26/2026 02:38:01.215 7f0fede89f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1428526147 with 0 response partitions (1 implied) 02/26/2026 02:38:01.283 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 65 02/26/2026 02:38:01.283 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 02/26/2026 02:38:01.283 7f0febd63c20 [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)]) 02/26/2026 02:38:01.284 7f0febd63c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.284 7f0febd63c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1790419120, session_epoch=695, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.284 7f0febd63c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1790419120, session_epoch=695, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.284 7f0febd63c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80233.793945, idle connection 258086.000000, request 304999.934673 02/26/2026 02:38:01.284 7f0fede894a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80774.759277, idle connection 258311.000000, request 304397.482634 02/26/2026 02:38:01.284 7f0febd63c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80233.180176, idle connection 258085.000000, request 304999.329567 02/26/2026 02:38:01.285 7f0fede894a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 726 02/26/2026 02:38:01.285 7f0fede894a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.285 7f0fede894a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 726 (603.2454967498779 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=344673356, topics=[]) 02/26/2026 02:38:01.285 7f0fede894a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 344673356 with 0 response partitions (1 implied) 02/26/2026 02:38:01.305 7f0febf2de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79748.768799, idle connection 258302.000000, request 304398.991108 02/26/2026 02:38:01.305 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1011 02/26/2026 02:38:01.305 7f0febf2de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.305 7f0febf2de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 1011 (601.4935970306396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=123186983, topics=[]) 02/26/2026 02:38:01.305 7f0febf2de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 123186983 with 0 response partitions (1 implied) 02/26/2026 02:38:01.306 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 13 02/26/2026 02:38:01.306 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 02/26/2026 02:38:01.306 7f0feb6d2180 [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)]) 02/26/2026 02:38:01.306 7f0feb6d2180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.306 7f0feb6d2180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1012336525, session_epoch=685, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.306 7f0feb6d2180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1012336525, session_epoch=685, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.306 7f0feb6d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80539.267822, idle connection 258494.000000, request 304999.959946 02/26/2026 02:38:01.307 7f0feb6d2180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80538.914307, idle connection 258493.000000, request 304999.609947 02/26/2026 02:38:01.312 7f0fed4ef0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 79729.020508, idle connection 258331.000000, request 304397.684097 02/26/2026 02:38:01.312 7f0fed4ef0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 684 02/26/2026 02:38:01.312 7f0fed4ef0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.313 7f0fed4ef0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 684 (602.7281284332275 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1330368780, topics=[]) 02/26/2026 02:38:01.313 7f0fed4ef0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1330368780 with 0 response partitions (1 implied) 02/26/2026 02:38:01.313 7f0fede89900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80544.157959, idle connection 258757.000000, request 304397.573471 02/26/2026 02:38:01.313 7f0fede89360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80512.297607, idle connection 258558.000000, request 304398.338795 02/26/2026 02:38:01.313 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 739 02/26/2026 02:38:01.313 7f0fede89900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.313 7f0fede89900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 739 (602.9355525970459 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1980715442, topics=[]) 02/26/2026 02:38:01.314 7f0fede89900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1980715442 with 0 response partitions (1 implied) 02/26/2026 02:38:01.314 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 705 02/26/2026 02:38:01.314 7f0fede89360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.314 7f0fede89360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 705 (602.3876667022705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1256647513, topics=[]) 02/26/2026 02:38:01.314 7f0fede89360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1256647513 with 0 response partitions (1 implied) 02/26/2026 02:38:01.373 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 26 02/26/2026 02:38:01.374 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 02/26/2026 02:38:01.374 7f0febd63e00 [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)]) 02/26/2026 02:38:01.374 7f0febd63e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.374 7f0febd63e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137053957, session_epoch=688, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.374 7f0febd63e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1137053957, session_epoch=688, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.374 7f0febd63e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81489.708252, idle connection 257666.000000, request 304999.937296 02/26/2026 02:38:01.375 7f0febd63e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81489.286621, idle connection 257665.000000, request 304999.523163 02/26/2026 02:38:01.375 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 26 02/26/2026 02:38:01.375 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 02/26/2026 02:38:01.375 7f0febd2d9a0 [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)]) 02/26/2026 02:38:01.375 7f0febd2d9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.375 7f0febd2d9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=291962954, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.375 7f0febd2d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=291962954, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.375 7f0febd2d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81074.706055, idle connection 258533.000000, request 304999.963284 02/26/2026 02:38:01.376 7f0febd2d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 81074.416748, idle connection 258533.000000, request 304999.676228 02/26/2026 02:38:01.379 7f0fed4efc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80942.869873, idle connection 258334.000000, request 304398.952723 02/26/2026 02:38:01.380 7f0fed4efc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 02/26/2026 02:38:01.380 7f0fed4efc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.380 7f0fed4efc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 691 (601.4385223388672 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=876939456, topics=[]) 02/26/2026 02:38:01.380 7f0fed4efc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 876939456 with 0 response partitions (1 implied) 02/26/2026 02:38:01.457 7f0feb6d25e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80974.188232, idle connection 258421.000000, request 304399.055481 02/26/2026 02:38:01.458 7f0feb6d25e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 691 02/26/2026 02:38:01.458 7f0feb6d25e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 02/26/2026 02:38:01.458 7f0feb6d25e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Response 691 (601.4652252197266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=651443891, topics=[]) 02/26/2026 02:38:01.458 7f0feb6d25e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 651443891 with 0 response partitions (1 implied) 02/26/2026 02:38:01.478 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 205 02/26/2026 02:38:01.478 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 02/26/2026 02:38:01.478 7f0fede89220 [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)]) 02/26/2026 02:38:01.479 7f0fede89220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.479 7f0fede89220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1526553912, session_epoch=715, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.479 7f0fede89220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1526553912, session_epoch=715, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.479 7f0fede89220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80949.333740, idle connection 257669.000000, request 304999.951124 02/26/2026 02:38:01.479 7f0fede89220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80948.924561, idle connection 257669.000000, request 304999.548197 02/26/2026 02:38:01.480 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 51 02/26/2026 02:38:01.480 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 02/26/2026 02:38:01.480 7f0fed4efea0 [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)]) 02/26/2026 02:38:01.480 7f0fed4efea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.480 7f0fed4efea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=53647297, session_epoch=692, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.480 7f0fed4efea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 9092)]>: Request 696 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=53647297, session_epoch=692, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.480 7f0fed4efea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80296.543945, idle connection 257727.000000, request 304999.964476 02/26/2026 02:38:01.481 7f0fed4efea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80296.202393, idle connection 257726.000000, request 304999.625206 02/26/2026 02:38:01.481 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 26 02/26/2026 02:38:01.481 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 02/26/2026 02:38:01.481 7f0fed4ef4a0 [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)]) 02/26/2026 02:38:01.481 7f0fed4ef4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.481 7f0fed4ef4a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=989652527, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.481 7f0fed4ef4a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=989652527, session_epoch=690, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.481 7f0fed4ef4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80836.196289, idle connection 257667.000000, request 304999.966621 02/26/2026 02:38:01.482 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 33 02/26/2026 02:38:01.482 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 02/26/2026 02:38:01.482 7f0fed4ef680 [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)]) 02/26/2026 02:38:01.482 7f0fed4ef680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.482 7f0fed4ef680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1930860683, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.482 7f0fed4ef680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1930860683, session_epoch=686, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.482 7f0fed4ef680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80880.015381, idle connection 258111.000000, request 304999.970436 02/26/2026 02:38:01.483 7f0fed4ef4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80835.099854, idle connection 257666.000000, request 304998.871088 02/26/2026 02:38:01.483 7f0fed4ef680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80878.924072, idle connection 258110.000000, request 304998.879910 02/26/2026 02:38:01.547 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 118 02/26/2026 02:38:01.547 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 02/26/2026 02:38:01.547 7f0fede89b80 [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)]) 02/26/2026 02:38:01.547 7f0fede89b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 02/26/2026 02:38:01.548 7f0fede89b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1123005179, session_epoch=707, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.548 7f0fede89b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.22', 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=1123005179, session_epoch=707, topics=[], forgotten_topics_data=[]) 02/26/2026 02:38:01.548 7f0fede89b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80031.976074, idle connection 258456.000000, request 304999.949455 02/26/2026 02:38:01.548 7f0fede89b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 80031.562500, idle connection 258456.000000, request 304999.542713