10/27/2025 04:39:58.734 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7614 10/27/2025 04:39:58.736 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:58.736 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7614 (603.532075881958 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1176578778, topics=[]) 10/27/2025 04:39:58.736 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1176578778 with 0 response partitions (1 implied) 10/27/2025 04:39:58.801 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243232.680664, idle connection 181958.000000, request 304397.919416 10/27/2025 04:39:58.802 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7750 10/27/2025 04:39:58.802 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:58.802 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7750 (602.783203125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817607707, topics=[]) 10/27/2025 04:39:58.802 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1817607707 with 0 response partitions (1 implied) 10/27/2025 04:39:58.806 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58795 10/27/2025 04:39:58.806 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:39:58.807 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 10/27/2025 04:39:58.807 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:39:58.807 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11705, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:58.807 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11712 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11705, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:58.807 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 238468.083740, idle connection 417177.000000, request 304999.953032 10/27/2025 04:39:58.807 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 238467.675049, idle connection 417177.000000, request 304999.549150 10/27/2025 04:39:58.862 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 246930.057617, idle connection 185792.000000, request 304398.517609 10/27/2025 04:39:58.863 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8322 10/27/2025 04:39:58.863 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:58.863 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 8322 (602.0500659942627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=638027122, topics=[]) 10/27/2025 04:39:58.863 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 638027122 with 0 response partitions (1 implied) 10/27/2025 04:39:58.968 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243440.108643, idle connection 422060.000000, request 304397.796869 10/27/2025 04:39:58.969 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7605 10/27/2025 04:39:58.969 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:58.969 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 7605 (602.741003036499 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1104718384, topics=[]) 10/27/2025 04:39:58.969 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1104718384 with 0 response partitions (1 implied) 10/27/2025 04:39:59.149 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 569 10/27/2025 04:39:59.149 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/27/2025 04:39:59.149 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/27/2025 04:39:59.149 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:39:59.149 7f537c239220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7613, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.149 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 7631 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7613, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.150 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242834.655029, idle connection 181922.000000, request 304999.940157 10/27/2025 04:39:59.150 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242834.201172, idle connection 181921.000000, request 304999.496460 10/27/2025 04:39:59.261 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243431.749512, idle connection 182062.000000, request 304398.818016 10/27/2025 04:39:59.261 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7615 10/27/2025 04:39:59.261 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:59.262 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7615 (601.6957759857178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1593509618, topics=[]) 10/27/2025 04:39:59.262 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1593509618 with 0 response partitions (1 implied) 10/27/2025 04:39:59.271 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 246163.100098, idle connection 424874.000000, request 304398.998260 10/27/2025 04:39:59.271 7f537c918040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7809 10/27/2025 04:39:59.271 7f537c918040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:59.271 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7809 (601.3531684875488 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=821146780, topics=[]) 10/27/2025 04:39:59.272 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 821146780 with 0 response partitions (1 implied) 10/27/2025 04:39:59.336 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 331 10/27/2025 04:39:59.337 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/27/2025 04:39:59.337 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/27/2025 04:39:59.337 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:39:59.337 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7597, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.337 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7615 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7597, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.337 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241627.367920, idle connection 180707.000000, request 304999.930143 10/27/2025 04:39:59.338 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241626.830322, idle connection 180706.000000, request 304999.385834 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 842 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7733, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7751 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7733, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.403 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242630.572754, idle connection 181356.000000, request 304999.946833 10/27/2025 04:39:59.404 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242630.131348, idle connection 181356.000000, request 304999.511719 10/27/2025 04:39:59.408 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237867.305908, idle connection 416577.000000, request 304399.178982 10/27/2025 04:39:59.408 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11712 10/27/2025 04:39:59.408 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:59.408 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 11712 (601.2206077575684 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416537503, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=58797, last_stable_offset=58797, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe5\xab\x00\x00\x01\x05\x00\x00\x00\x00\x02O\xa9V_\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 10/27/2025 04:39:59.408 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416537503 with 1 response partitions (0 implied) 10/27/2025 04:39:59.409 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 546 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 58795 10/27/2025 04:39:59.409 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 58795 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 10/27/2025 04:39:59.409 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 58797 (leader epoch 0) 10/27/2025 04:39:59.465 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4759 10/27/2025 04:39:59.465 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/27/2025 04:39:59.465 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 10/27/2025 04:39:59.465 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:39:59.465 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8311, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.465 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 8323 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8311, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.465 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 246327.215576, idle connection 185189.000000, request 304999.947071 10/27/2025 04:39:59.466 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 246326.755615, idle connection 185188.000000, request 304999.494076 10/27/2025 04:39:59.510 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58797 10/27/2025 04:39:59.510 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:39:59.510 7f537c918a40 [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)]) 10/27/2025 04:39:59.510 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:39:59.510 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11706, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58797, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:39:59.510 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11713 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11706, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58797, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:39:59.511 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237764.463379, idle connection 416474.000000, request 304999.943495 10/27/2025 04:39:59.511 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237764.018555, idle connection 416473.000000, request 304999.506950 10/27/2025 04:39:59.569 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 442 10/27/2025 04:39:59.570 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 10/27/2025 04:39:59.570 7f537ed85f40 [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)]) 10/27/2025 04:39:59.570 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:39:59.570 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7584, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.571 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 7606 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7584, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.571 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242837.507080, idle connection 421457.000000, request 304999.900103 10/27/2025 04:39:59.572 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242836.676270, idle connection 421457.000000, request 304999.074936 10/27/2025 04:39:59.751 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242233.580811, idle connection 181320.000000, request 304398.858786 10/27/2025 04:39:59.751 7f537c239220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7631 10/27/2025 04:39:59.751 7f537c239220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:59.752 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 7631 (601.9494533538818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065643614, topics=[]) 10/27/2025 04:39:59.752 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1065643614 with 0 response partitions (1 implied) 10/27/2025 04:39:59.862 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 344 10/27/2025 04:39:59.862 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/27/2025 04:39:59.862 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/27/2025 04:39:59.862 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:39:59.863 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7596, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.864 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7616 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7596, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.864 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242828.817627, idle connection 181459.000000, request 304999.937773 10/27/2025 04:39:59.864 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242828.284668, idle connection 181459.000000, request 304999.414682 10/27/2025 04:39:59.872 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1675 10/27/2025 04:39:59.872 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 10/27/2025 04:39:59.872 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 10/27/2025 04:39:59.872 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:39:59.872 7f537c918040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7799, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.872 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7810 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7799, topics=[], forgotten_topics_data=[]) 10/27/2025 04:39:59.873 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 245561.645508, idle connection 424273.000000, request 304999.945402 10/27/2025 04:39:59.873 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 245561.303711, idle connection 424272.000000, request 304999.607325 10/27/2025 04:39:59.940 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241025.255371, idle connection 180105.000000, request 304397.820711 10/27/2025 04:39:59.940 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7615 10/27/2025 04:39:59.940 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:39:59.940 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7615 (602.7946472167969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1176578778, topics=[]) 10/27/2025 04:39:59.940 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1176578778 with 0 response partitions (1 implied) 10/27/2025 04:40:00.005 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242028.517822, idle connection 180754.000000, request 304397.888422 10/27/2025 04:40:00.006 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7751 10/27/2025 04:40:00.006 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.006 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7751 (602.7309894561768 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817607707, topics=[]) 10/27/2025 04:40:00.006 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1817607707 with 0 response partitions (1 implied) 10/27/2025 04:40:00.066 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 245726.234131, idle connection 184588.000000, request 304398.961067 10/27/2025 04:40:00.067 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8323 10/27/2025 04:40:00.067 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.067 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 8323 (601.6185283660889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=638027122, topics=[]) 10/27/2025 04:40:00.067 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 638027122 with 0 response partitions (1 implied) 10/27/2025 04:40:00.112 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237163.486328, idle connection 415873.000000, request 304398.966551 10/27/2025 04:40:00.112 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11713 10/27/2025 04:40:00.112 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.112 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 11713 (601.646900177002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416537503, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=58800, last_stable_offset=58800, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe5\xad\x00\x00\x01\x05\x00\x00\x00\x00\x02\xe5\x97\x04\xc5\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 10/27/2025 04:40:00.112 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416537503 with 1 response partitions (0 implied) 10/27/2025 04:40:00.113 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 819 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 58797 10/27/2025 04:40:00.113 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 58797 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 10/27/2025 04:40:00.113 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 58800 (leader epoch 0) 10/27/2025 04:40:00.172 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242235.947754, idle connection 420856.000000, request 304398.345232 10/27/2025 04:40:00.173 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7606 10/27/2025 04:40:00.173 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.173 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 7606 (602.2262573242188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1104718384, topics=[]) 10/27/2025 04:40:00.173 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1104718384 with 0 response partitions (1 implied) 10/27/2025 04:40:00.214 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58800 10/27/2025 04:40:00.214 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:40:00.214 7f537c918a40 [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)]) 10/27/2025 04:40:00.214 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:00.214 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11707, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58800, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:00.215 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11714 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11707, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58800, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:00.215 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237060.368408, idle connection 415770.000000, request 304999.942064 10/27/2025 04:40:00.215 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237059.916260, idle connection 415769.000000, request 304999.500513 10/27/2025 04:40:00.352 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 569 10/27/2025 04:40:00.352 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/27/2025 04:40:00.352 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/27/2025 04:40:00.352 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:40:00.353 7f537c239220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7614, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.353 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 7632 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7614, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.353 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241631.435547, idle connection 180718.000000, request 304999.948025 10/27/2025 04:40:00.353 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241630.812500, idle connection 180718.000000, request 304999.331951 10/27/2025 04:40:00.465 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242227.702393, idle connection 180858.000000, request 304398.823738 10/27/2025 04:40:00.465 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7616 10/27/2025 04:40:00.466 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.466 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7616 (601.7227172851562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1593509618, topics=[]) 10/27/2025 04:40:00.466 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1593509618 with 0 response partitions (1 implied) 10/27/2025 04:40:00.473 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 244960.855225, idle connection 423672.000000, request 304399.152756 10/27/2025 04:40:00.474 7f537c918040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7810 10/27/2025 04:40:00.474 7f537c918040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.474 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7810 (601.2663841247559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=821146780, topics=[]) 10/27/2025 04:40:00.474 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 821146780 with 0 response partitions (1 implied) 10/27/2025 04:40:00.541 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 331 10/27/2025 04:40:00.541 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/27/2025 04:40:00.541 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/27/2025 04:40:00.541 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:00.541 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7598, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.541 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7616 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7598, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.542 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240423.247803, idle connection 179503.000000, request 304999.934912 10/27/2025 04:40:00.542 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240422.841064, idle connection 179502.000000, request 304999.537230 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 842 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7734, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7752 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7734, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.607 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241426.396973, idle connection 180152.000000, request 304999.941826 10/27/2025 04:40:00.608 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241425.943848, idle connection 180151.000000, request 304999.499321 10/27/2025 04:40:00.667 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4759 10/27/2025 04:40:00.668 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/27/2025 04:40:00.668 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 10/27/2025 04:40:00.668 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:40:00.668 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8312, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.668 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 8324 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8312, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.668 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 245124.251953, idle connection 183986.000000, request 304999.945641 10/27/2025 04:40:00.669 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 245123.784668, idle connection 183985.000000, request 304999.485731 10/27/2025 04:40:00.774 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 442 10/27/2025 04:40:00.774 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 10/27/2025 04:40:00.774 7f537ed85f40 [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)]) 10/27/2025 04:40:00.774 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:00.774 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7585, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.774 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 7607 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7585, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:00.775 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241633.826904, idle connection 420254.000000, request 304999.945402 10/27/2025 04:40:00.775 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241633.416504, idle connection 420253.000000, request 304999.543905 10/27/2025 04:40:00.816 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 236458.922607, idle connection 415168.000000, request 304398.496389 10/27/2025 04:40:00.817 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11714 10/27/2025 04:40:00.817 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.817 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 11714 (602.0560264587402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416537503, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=58801, last_stable_offset=58801, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe5\xb0\x00\x00\x01\x05\x00\x00\x00\x00\x02%\xcbih\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 10/27/2025 04:40:00.817 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416537503 with 1 response partitions (0 implied) 10/27/2025 04:40:00.817 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 58800 10/27/2025 04:40:00.817 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 58800 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 10/27/2025 04:40:00.817 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 58801 (leader epoch 0) 10/27/2025 04:40:00.918 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58801 10/27/2025 04:40:00.918 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:40:00.918 7f537c918a40 [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)]) 10/27/2025 04:40:00.918 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:00.918 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11708, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58801, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:00.919 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11715 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11708, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58801, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:00.919 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 236356.247559, idle connection 415066.000000, request 304999.941349 10/27/2025 04:40:00.919 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 236355.790771, idle connection 415065.000000, request 304999.490023 10/27/2025 04:40:00.954 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241030.233643, idle connection 180117.000000, request 304398.746729 10/27/2025 04:40:00.954 7f537c239220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7632 10/27/2025 04:40:00.954 7f537c239220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:00.955 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 7632 (601.7961502075195 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065643614, topics=[]) 10/27/2025 04:40:00.955 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1065643614 with 0 response partitions (1 implied) 10/27/2025 04:40:01.066 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 344 10/27/2025 04:40:01.066 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/27/2025 04:40:01.066 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/27/2025 04:40:01.067 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:01.067 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7597, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.067 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7617 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7597, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.067 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241625.779541, idle connection 180256.000000, request 304999.941826 10/27/2025 04:40:01.067 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241625.344482, idle connection 180256.000000, request 304999.514818 10/27/2025 04:40:01.074 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1675 10/27/2025 04:40:01.074 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 10/27/2025 04:40:01.074 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 10/27/2025 04:40:01.075 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:01.075 7f537c918040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7800, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.075 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7811 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7800, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.075 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 244359.243164, idle connection 423070.000000, request 304999.952316 10/27/2025 04:40:01.075 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 244358.890869, idle connection 423070.000000, request 304999.604464 10/27/2025 04:40:01.142 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239822.292236, idle connection 178902.000000, request 304398.980856 10/27/2025 04:40:01.143 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7616 10/27/2025 04:40:01.143 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.143 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7616 (601.5496253967285 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1176578778, topics=[]) 10/27/2025 04:40:01.143 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1176578778 with 0 response partitions (1 implied) 10/27/2025 04:40:01.208 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240825.419434, idle connection 179551.000000, request 304398.963928 10/27/2025 04:40:01.209 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7752 10/27/2025 04:40:01.209 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.209 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7752 (601.6151905059814 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817607707, topics=[]) 10/27/2025 04:40:01.209 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1817607707 with 0 response partitions (1 implied) 10/27/2025 04:40:01.269 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 244523.230957, idle connection 183385.000000, request 304398.926258 10/27/2025 04:40:01.270 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8324 10/27/2025 04:40:01.270 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.270 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 8324 (601.6018390655518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=638027122, topics=[]) 10/27/2025 04:40:01.270 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 638027122 with 0 response partitions (1 implied) 10/27/2025 04:40:01.376 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241032.867676, idle connection 419653.000000, request 304398.984194 10/27/2025 04:40:01.376 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7607 10/27/2025 04:40:01.376 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.376 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 7607 (601.6106605529785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1104718384, topics=[]) 10/27/2025 04:40:01.376 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1104718384 with 0 response partitions (1 implied) 10/27/2025 04:40:01.520 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 235755.214844, idle connection 414465.000000, request 304398.909807 10/27/2025 04:40:01.520 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11715 10/27/2025 04:40:01.520 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.520 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 11715 (601.6409397125244 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416537503, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=58802, last_stable_offset=58802, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe5\xb1\x00\x00\x01\x05\x00\x00\x00\x00\x02.\xe3c_\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 10/27/2025 04:40:01.521 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416537503 with 1 response partitions (0 implied) 10/27/2025 04:40:01.521 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 58801 10/27/2025 04:40:01.521 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 58801 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 10/27/2025 04:40:01.521 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 58802 (leader epoch 0) 10/27/2025 04:40:01.556 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 569 10/27/2025 04:40:01.556 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/27/2025 04:40:01.556 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/27/2025 04:40:01.556 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:40:01.556 7f537c239220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7615, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.556 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 7633 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7615, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.556 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240427.917725, idle connection 179515.000000, request 304999.932051 10/27/2025 04:40:01.557 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240427.409424, idle connection 179514.000000, request 304999.438286 10/27/2025 04:40:01.622 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58802 10/27/2025 04:40:01.622 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:40:01.622 7f537c918a40 [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)]) 10/27/2025 04:40:01.622 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:01.622 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11709, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58802, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:01.623 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11716 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11709, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58802, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:01.623 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 235652.352295, idle connection 414362.000000, request 304999.941587 10/27/2025 04:40:01.623 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 235651.623291, idle connection 414361.000000, request 304999.214411 10/27/2025 04:40:01.668 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241024.735840, idle connection 179655.000000, request 304398.895979 10/27/2025 04:40:01.668 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7617 10/27/2025 04:40:01.669 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.669 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7617 (601.8059253692627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1593509618, topics=[]) 10/27/2025 04:40:01.669 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1593509618 with 0 response partitions (1 implied) 10/27/2025 04:40:01.676 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243758.481689, idle connection 422470.000000, request 304399.188280 10/27/2025 04:40:01.676 7f537c918040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7811 10/27/2025 04:40:01.676 7f537c918040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:01.676 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7811 (601.2773513793945 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=821146780, topics=[]) 10/27/2025 04:40:01.676 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 821146780 with 0 response partitions (1 implied) 10/27/2025 04:40:01.744 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 331 10/27/2025 04:40:01.744 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/27/2025 04:40:01.745 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/27/2025 04:40:01.745 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:01.745 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7599, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.745 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7617 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7599, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.745 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239219.598145, idle connection 178299.000000, request 304999.925852 10/27/2025 04:40:01.746 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239218.978760, idle connection 178298.000000, request 304999.316216 10/27/2025 04:40:01.811 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 842 10/27/2025 04:40:01.811 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/27/2025 04:40:01.811 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/27/2025 04:40:01.812 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:01.812 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7735, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.812 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7753 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7735, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.812 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240221.554443, idle connection 178947.000000, request 304999.896049 10/27/2025 04:40:01.813 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240220.873779, idle connection 178946.000000, request 304999.238014 10/27/2025 04:40:01.871 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4759 10/27/2025 04:40:01.871 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/27/2025 04:40:01.871 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 10/27/2025 04:40:01.871 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:40:01.872 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8313, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.872 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 8325 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8313, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.872 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243920.432617, idle connection 182782.000000, request 304999.901056 10/27/2025 04:40:01.873 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243919.689697, idle connection 182781.000000, request 304999.173880 10/27/2025 04:40:01.978 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 442 10/27/2025 04:40:01.978 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 10/27/2025 04:40:01.978 7f537ed85f40 [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)]) 10/27/2025 04:40:01.978 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:01.979 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7586, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.979 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 7608 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7586, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:01.979 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240429.114990, idle connection 419049.000000, request 304999.898434 10/27/2025 04:40:01.981 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240427.356201, idle connection 419047.000000, request 304998.157740 10/27/2025 04:40:02.158 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239826.734619, idle connection 178914.000000, request 304398.735046 10/27/2025 04:40:02.158 7f537c239220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7633 10/27/2025 04:40:02.158 7f537c239220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.159 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 7633 (602.2520065307617 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065643614, topics=[]) 10/27/2025 04:40:02.159 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1065643614 with 0 response partitions (1 implied) 10/27/2025 04:40:02.225 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 235050.172852, idle connection 413760.000000, request 304397.751331 10/27/2025 04:40:02.225 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11716 10/27/2025 04:40:02.226 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.226 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 11716 (603.0426025390625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416537503, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=58803, last_stable_offset=58803, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe5\xb2\x00\x00\x01\x05\x00\x00\x00\x00\x02\x91E\xf8\xf4\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 10/27/2025 04:40:02.226 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416537503 with 1 response partitions (0 implied) 10/27/2025 04:40:02.226 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 58802 10/27/2025 04:40:02.226 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 58802 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 10/27/2025 04:40:02.227 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 58803 (leader epoch 0) 10/27/2025 04:40:02.270 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 344 10/27/2025 04:40:02.270 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/27/2025 04:40:02.271 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/27/2025 04:40:02.271 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:02.271 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7598, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.272 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7618 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7598, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.272 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240420.713867, idle connection 179051.000000, request 304999.810696 10/27/2025 04:40:02.273 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240419.815186, idle connection 179050.000000, request 304998.930693 10/27/2025 04:40:02.277 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1675 10/27/2025 04:40:02.278 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 10/27/2025 04:40:02.278 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 10/27/2025 04:40:02.278 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:02.278 7f537c918040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7801, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.278 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7812 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7801, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.278 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243155.937744, idle connection 421867.000000, request 304999.939442 10/27/2025 04:40:02.279 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243155.293457, idle connection 421866.000000, request 304999.259949 10/27/2025 04:40:02.328 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58803 10/27/2025 04:40:02.328 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:40:02.328 7f537c918a40 [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)]) 10/27/2025 04:40:02.328 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:02.328 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11710, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58803, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:02.328 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11717 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11710, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=58803, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:02.328 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 234946.655029, idle connection 413656.000000, request 304999.926329 10/27/2025 04:40:02.329 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 234945.754150, idle connection 413655.000000, request 304999.031067 10/27/2025 04:40:02.347 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 238617.571045, idle connection 177697.000000, request 304397.892475 10/27/2025 04:40:02.348 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7617 10/27/2025 04:40:02.348 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.348 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7617 (602.607011795044 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1176578778, topics=[]) 10/27/2025 04:40:02.348 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1176578778 with 0 response partitions (1 implied) 10/27/2025 04:40:02.414 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239619.484375, idle connection 178345.000000, request 304397.831202 10/27/2025 04:40:02.415 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7753 10/27/2025 04:40:02.415 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.415 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7753 (603.0969619750977 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817607707, topics=[]) 10/27/2025 04:40:02.416 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1817607707 with 0 response partitions (1 implied) 10/27/2025 04:40:02.475 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243317.722900, idle connection 182179.000000, request 304397.190332 10/27/2025 04:40:02.475 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8325 10/27/2025 04:40:02.476 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.476 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 8325 (603.7108898162842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=638027122, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=4760, last_stable_offset=4760, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x12\x97\x00\x00\x00\xfc\x00\x00\x00\x00\x02\xc3bFh\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...')])]) 10/27/2025 04:40:02.476 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 638027122 with 1 response partitions (0 implied) 10/27/2025 04:40:02.476 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 264 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 4759 10/27/2025 04:40:02.476 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4759 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 10/27/2025 04:40:02.476 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 4760 (leader epoch 0) 10/27/2025 04:40:02.578 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4760 10/27/2025 04:40:02.578 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 10/27/2025 04:40:02.578 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 10/27/2025 04:40:02.578 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:40:02.578 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8314, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4760, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:02.579 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 8326 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=638027122, session_epoch=8314, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4760, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 10/27/2025 04:40:02.579 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243213.430420, idle connection 182075.000000, request 304999.851227 10/27/2025 04:40:02.580 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 243212.678955, idle connection 182074.000000, request 304999.056101 10/27/2025 04:40:02.582 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239826.716797, idle connection 418447.000000, request 304397.522926 10/27/2025 04:40:02.582 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7608 10/27/2025 04:40:02.582 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.582 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 7608 (602.9088497161865 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1104718384, topics=[]) 10/27/2025 04:40:02.582 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1104718384 with 0 response partitions (1 implied) 10/27/2025 04:40:02.760 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 569 10/27/2025 04:40:02.761 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 10/27/2025 04:40:02.761 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 10/27/2025 04:40:02.761 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 10/27/2025 04:40:02.761 7f537c239220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7616, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.761 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Request 7634 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1065643614, session_epoch=7616, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.761 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239223.082764, idle connection 178310.000000, request 304999.942064 10/27/2025 04:40:02.762 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239222.590088, idle connection 178310.000000, request 304999.460697 10/27/2025 04:40:02.874 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239818.890137, idle connection 178449.000000, request 304397.993326 10/27/2025 04:40:02.874 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7618 10/27/2025 04:40:02.874 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.874 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7618 (602.5917530059814 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1593509618, topics=[]) 10/27/2025 04:40:02.875 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1593509618 with 0 response partitions (1 implied) 10/27/2025 04:40:02.880 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242554.628662, idle connection 421266.000000, request 304398.632288 10/27/2025 04:40:02.880 7f537c918040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7812 10/27/2025 04:40:02.880 7f537c918040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.880 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7812 (601.8707752227783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=821146780, topics=[]) 10/27/2025 04:40:02.880 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 821146780 with 0 response partitions (1 implied) 10/27/2025 04:40:02.930 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 234344.765625, idle connection 413054.000000, request 304398.037434 10/27/2025 04:40:02.931 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11717 10/27/2025 04:40:02.931 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:02.931 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Response 11717 (602.6909351348877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1416537503, topics=[]) 10/27/2025 04:40:02.931 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1416537503 with 0 response partitions (1 implied) 10/27/2025 04:40:02.949 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 331 10/27/2025 04:40:02.949 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 10/27/2025 04:40:02.949 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 10/27/2025 04:40:02.949 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:02.950 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7600, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.950 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7618 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1176578778, session_epoch=7600, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:02.950 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 238014.770752, idle connection 177094.000000, request 304999.923944 10/27/2025 04:40:02.951 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 238014.209473, idle connection 177094.000000, request 304999.377251 10/27/2025 04:40:03.017 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 842 10/27/2025 04:40:03.017 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 10/27/2025 04:40:03.017 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 10/27/2025 04:40:03.017 7f537ed85ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:03.017 7f537ed85ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7736, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.018 7f537ed85ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7754 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817607707, session_epoch=7736, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.018 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239016.138184, idle connection 177742.000000, request 304999.926329 10/27/2025 04:40:03.018 7f537ed85ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239015.591309, idle connection 177741.000000, request 304999.390125 10/27/2025 04:40:03.181 7f537c50b360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242611.443359, idle connection 181473.000000, request 304397.870541 10/27/2025 04:40:03.181 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8326 10/27/2025 04:40:03.182 7f537c50b360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:03.182 7f537c50b360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 8326 (602.806806564331 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=638027122, topics=[]) 10/27/2025 04:40:03.182 7f537c50b360 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 638027122 with 0 response partitions (1 implied) 10/27/2025 04:40:03.183 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 442 10/27/2025 04:40:03.183 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 10/27/2025 04:40:03.183 7f537ed85f40 [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)]) 10/27/2025 04:40:03.183 7f537ed85f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:03.184 7f537ed85f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7587, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.184 7f537ed85f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 7609 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1104718384, session_epoch=7587, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.184 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239224.562744, idle connection 417844.000000, request 304999.953747 10/27/2025 04:40:03.184 7f537ed85f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239224.197510, idle connection 417844.000000, request 304999.593973 10/27/2025 04:40:03.362 7f537c239220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 238622.039795, idle connection 177709.000000, request 304398.902655 10/27/2025 04:40:03.363 7f537c239220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7634 10/27/2025 04:40:03.363 7f537c239220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:03.363 7f537c239220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.129', 9092)]>: Response 7634 (601.6321182250977 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1065643614, topics=[]) 10/27/2025 04:40:03.363 7f537c239220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1065643614 with 0 response partitions (1 implied) 10/27/2025 04:40:03.475 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 344 10/27/2025 04:40:03.475 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 10/27/2025 04:40:03.476 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 10/27/2025 04:40:03.476 7f537ed85cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:03.476 7f537ed85cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7599, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.476 7f537ed85cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7619 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1593509618, session_epoch=7599, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.476 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239216.641846, idle connection 177847.000000, request 304999.939442 10/27/2025 04:40:03.477 7f537ed85cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239216.200439, idle connection 177847.000000, request 304999.506950 10/27/2025 04:40:03.481 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1675 10/27/2025 04:40:03.482 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 10/27/2025 04:40:03.482 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 10/27/2025 04:40:03.482 7f537c918040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 10/27/2025 04:40:03.482 7f537c918040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7802, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.482 7f537c918040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7813 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=821146780, session_epoch=7802, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.482 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241952.132324, idle connection 420663.000000, request 304999.956369 10/27/2025 04:40:03.482 7f537c918040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241951.802246, idle connection 420663.000000, request 304999.629974 10/27/2025 04:40:03.532 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 58803 10/27/2025 04:40:03.532 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 10/27/2025 04:40:03.532 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 10/27/2025 04:40:03.532 7f537c918a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 10/27/2025 04:40:03.533 7f537c918a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11711, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.533 7f537c918a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.249', 9092)]>: Request 11718 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1416537503, session_epoch=11711, topics=[], forgotten_topics_data=[]) 10/27/2025 04:40:03.533 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 233742.297363, idle connection 412452.000000, request 304999.945641 10/27/2025 04:40:03.533 7f537c918a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 233741.860596, idle connection 412451.000000, request 304999.518394 10/27/2025 04:40:03.551 7f537c918e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 237413.467285, idle connection 176493.000000, request 304398.631573 10/27/2025 04:40:03.552 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7618 10/27/2025 04:40:03.552 7f537c918e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 10/27/2025 04:40:03.552 7f537c918e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7618 (601.933479309082 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1176578778, topics=[]) 10/27/2025 04:40:03.552 7f537c918e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1176578778 with 0 response partitions (1 implied)