02/12/2026 04:32:06.400 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12465, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59369, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:06.401 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12480 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12465, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59369, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:06.401 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71074.182617, idle connection 10303.000000, request 304999.945641
02/12/2026 04:32:06.402 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71073.747803, idle connection 10302.000000, request 304999.517679
02/12/2026 04:32:06.444 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
02/12/2026 04:32:06.445 7f56ff31bcc0 [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/12/2026 04:32:06.445 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee89970> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
02/12/2026 04:32:06.445 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:06.445 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6990, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:06.445 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7007 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6990, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:06.445 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74105.580566, idle connection 12915.000000, request 304999.954224
02/12/2026 04:32:06.445 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73496.451660, idle connection 11114.000000, request 304397.647619
02/12/2026 04:32:06.446 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74105.038086, idle connection 12915.000000, request 304999.418259
02/12/2026 04:32:06.446 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6937
02/12/2026 04:32:06.446 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:06.446 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6937 (602.9884815216064 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1820012549, topics=[])
02/12/2026 04:32:06.446 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1820012549 with 0 response partitions (1 implied)
02/12/2026 04:32:06.475 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73638.293213, idle connection 12619.000000, request 304399.191856
02/12/2026 04:32:06.476 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7026
02/12/2026 04:32:06.476 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:06.476 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7026 (601.2897491455078 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1620918480, topics=[])
02/12/2026 04:32:06.476 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1620918480 with 0 response partitions (1 implied)
02/12/2026 04:32:06.690 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2435
02/12/2026 04:32:06.690 7f56ff31b860 [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/12/2026 04:32:06.690 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff1c11c0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
02/12/2026 04:32:06.691 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:06.691 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7267, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:06.691 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7280 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7267, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:06.691 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 75821.654541, idle connection 14730.000000, request 304999.951601
02/12/2026 04:32:06.691 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 75821.260010, idle connection 14729.000000, request 304999.563932
02/12/2026 04:32:06.691 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73035.885254, idle connection 490610.000000, request 304398.999453
02/12/2026 04:32:06.692 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6993
02/12/2026 04:32:06.692 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:06.692 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6993 (601.3896465301514 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1342925977, topics=[])
02/12/2026 04:32:06.692 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1342925977 with 0 response partitions (1 implied)
02/12/2026 04:32:06.995 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 2970
02/12/2026 04:32:06.995 7f56ff31bf40 [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/12/2026 04:32:06.995 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff1bb8e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
02/12/2026 04:32:06.995 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:06.995 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7422, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:06.995 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7441 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7422, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:06.995 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72520.543213, idle connection 249759.000000, request 304999.942303
02/12/2026 04:32:06.996 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72519.889893, idle connection 249759.000000, request 304999.294519
02/12/2026 04:32:07.004 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70471.349609, idle connection 9700.000000, request 304397.115231
02/12/2026 04:32:07.004 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12480
02/12/2026 04:32:07.004 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.004 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12480 (603.2893657684326 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=59370, last_stable_offset=59370, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe7\xe9\x00\x00\x01\x04\x00\x00\x00\x00\x02\x9a\x85\x11\xfe\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/12/2026 04:32:07.005 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 1 response partitions (0 implied)
02/12/2026 04:32:07.005 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 59369
02/12/2026 04:32:07.005 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 59369 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
02/12/2026 04:32:07.005 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 59370 (leader epoch 0)
02/12/2026 04:32:07.046 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/12/2026 04:32:07.047 7f56fde4fea0 [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/12/2026 04:32:07.047 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff1bb6d0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
02/12/2026 04:32:07.047 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
02/12/2026 04:32:07.047 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6912, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.047 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6938 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6912, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.047 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72894.653076, idle connection 10512.000000, request 304999.948025
02/12/2026 04:32:07.047 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73503.299561, idle connection 12313.000000, request 304397.677660
02/12/2026 04:32:07.048 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72894.117432, idle connection 10512.000000, request 304999.421120
02/12/2026 04:32:07.048 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7007
02/12/2026 04:32:07.048 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.048 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7007 (602.957010269165 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1929483605, topics=[])
02/12/2026 04:32:07.048 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1929483605 with 0 response partitions (1 implied)
02/12/2026 04:32:07.077 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 359
02/12/2026 04:32:07.077 7f56ff31ba40 [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/12/2026 04:32:07.077 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff2a10a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
02/12/2026 04:32:07.077 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:07.077 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7011, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.077 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7027 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7011, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.077 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73036.375000, idle connection 12017.000000, request 304999.948502
02/12/2026 04:32:07.078 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73035.898438, idle connection 12017.000000, request 304999.479055
02/12/2026 04:32:07.106 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59370
02/12/2026 04:32:07.106 7f56ffd402c0 [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/12/2026 04:32:07.106 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff10c820> 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/12/2026 04:32:07.106 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:07.106 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12466, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59370, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:07.106 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12481 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12466, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59370, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:07.107 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70368.816162, idle connection 9597.000000, request 304999.947309
02/12/2026 04:32:07.107 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70368.435547, idle connection 9597.000000, request 304999.575138
02/12/2026 04:32:07.292 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 75220.623535, idle connection 14129.000000, request 304398.920536
02/12/2026 04:32:07.292 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7280
02/12/2026 04:32:07.292 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.293 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7280 (601.6459465026855 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1640977164, topics=[])
02/12/2026 04:32:07.293 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1640977164 with 0 response partitions (1 implied)
02/12/2026 04:32:07.293 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 234
02/12/2026 04:32:07.293 7f56ff31bc20 [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/12/2026 04:32:07.293 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee29f40> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
02/12/2026 04:32:07.293 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:07.293 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6969, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.293 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6994 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6969, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.293 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72434.019775, idle connection 490008.000000, request 304999.959707
02/12/2026 04:32:07.294 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72433.595947, idle connection 490008.000000, request 304999.538660
02/12/2026 04:32:07.598 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71918.356934, idle connection 249157.000000, request 304397.753716
02/12/2026 04:32:07.598 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7441
02/12/2026 04:32:07.598 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.598 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7441 (602.7848720550537 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1922371140, topics=[])
02/12/2026 04:32:07.598 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1922371140 with 0 response partitions (1 implied)
02/12/2026 04:32:07.649 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
02/12/2026 04:32:07.650 7f56ff31bcc0 [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/12/2026 04:32:07.650 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee8e430> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
02/12/2026 04:32:07.650 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:07.650 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6991, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.650 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7008 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6991, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.650 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72900.493896, idle connection 11710.000000, request 304999.948502
02/12/2026 04:32:07.650 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72291.344238, idle connection 9909.000000, request 304396.644592
02/12/2026 04:32:07.651 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72899.907959, idle connection 11710.000000, request 304999.371052
02/12/2026 04:32:07.651 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6938
02/12/2026 04:32:07.651 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.651 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6938 (604.0337085723877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1820012549, topics=[])
02/12/2026 04:32:07.651 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1820012549 with 0 response partitions (1 implied)
02/12/2026 04:32:07.679 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72434.994385, idle connection 11416.000000, request 304398.566961
02/12/2026 04:32:07.679 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7027
02/12/2026 04:32:07.679 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.679 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7027 (602.0650863647461 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1620918480, topics=[])
02/12/2026 04:32:07.680 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1620918480 with 0 response partitions (1 implied)
02/12/2026 04:32:07.707 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69767.901611, idle connection 8996.000000, request 304399.032831
02/12/2026 04:32:07.708 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12481
02/12/2026 04:32:07.708 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.708 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12481 (601.4785766601562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[])
02/12/2026 04:32:07.708 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 0 response partitions (1 implied)
02/12/2026 04:32:07.893 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2435
02/12/2026 04:32:07.894 7f56ff31b860 [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/12/2026 04:32:07.894 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff2155b0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
02/12/2026 04:32:07.894 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:07.894 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7268, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.894 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7281 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7268, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:07.894 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74618.199707, idle connection 13526.000000, request 304999.927998
02/12/2026 04:32:07.895 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74617.750488, idle connection 13526.000000, request 304999.492407
02/12/2026 04:32:07.895 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71832.388672, idle connection 489407.000000, request 304398.331404
02/12/2026 04:32:07.895 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6994
02/12/2026 04:32:07.895 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:07.895 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6994 (602.130651473999 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1342925977, topics=[])
02/12/2026 04:32:07.896 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1342925977 with 0 response partitions (1 implied)
02/12/2026 04:32:08.199 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 2970
02/12/2026 04:32:08.199 7f56ff31bf40 [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/12/2026 04:32:08.199 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff1c5220> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
02/12/2026 04:32:08.199 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:08.199 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7423, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.199 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7442 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7423, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.200 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71316.115234, idle connection 248555.000000, request 304999.927282
02/12/2026 04:32:08.200 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71315.596680, idle connection 248554.000000, request 304999.409437
02/12/2026 04:32:08.253 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/12/2026 04:32:08.253 7f56fde4fea0 [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/12/2026 04:32:08.253 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff0d6520> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
02/12/2026 04:32:08.253 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
02/12/2026 04:32:08.253 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6913, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.253 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6939 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6913, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.253 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71688.416504, idle connection 9306.000000, request 304999.948025
02/12/2026 04:32:08.254 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72297.061768, idle connection 11107.000000, request 304396.522284
02/12/2026 04:32:08.254 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71687.846191, idle connection 9305.000000, request 304999.387741
02/12/2026 04:32:08.254 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7008
02/12/2026 04:32:08.254 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:08.254 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7008 (604.1793823242188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1929483605, topics=[])
02/12/2026 04:32:08.254 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1929483605 with 0 response partitions (1 implied)
02/12/2026 04:32:08.282 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 359
02/12/2026 04:32:08.282 7f56ff31ba40 [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/12/2026 04:32:08.282 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff2154c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
02/12/2026 04:32:08.282 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:08.282 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7012, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.283 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7028 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7012, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.283 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71831.107422, idle connection 10812.000000, request 304999.949455
02/12/2026 04:32:08.283 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71830.658936, idle connection 10812.000000, request 304999.507666
02/12/2026 04:32:08.309 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59370
02/12/2026 04:32:08.309 7f56ffd402c0 [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/12/2026 04:32:08.309 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff0d6730> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
02/12/2026 04:32:08.309 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:08.309 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12467, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.309 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12482 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12467, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.310 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69165.712158, idle connection 8394.000000, request 304999.950171
02/12/2026 04:32:08.310 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69165.302002, idle connection 8394.000000, request 304999.546528
02/12/2026 04:32:08.310 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12482
02/12/2026 04:32:08.310 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:08.311 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12482 (1.2874603271484375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=59371, last_stable_offset=59371, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe7\xea\x00\x00\x01\x04\x00\x00\x00\x00\x02\xc0@\xa9\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/12/2026 04:32:08.311 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 1 response partitions (0 implied)
02/12/2026 04:32:08.311 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 59370
02/12/2026 04:32:08.311 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 59370 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
02/12/2026 04:32:08.312 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 59371 (leader epoch 0)
02/12/2026 04:32:08.413 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59371
02/12/2026 04:32:08.413 7f56ffd402c0 [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/12/2026 04:32:08.413 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56feeaed90> 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/12/2026 04:32:08.413 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:08.414 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12468, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59371, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:08.414 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12483 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12468, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59371, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:08.414 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69061.304199, idle connection 8290.000000, request 304999.924421
02/12/2026 04:32:08.415 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69060.730957, idle connection 8289.000000, request 304999.360561
02/12/2026 04:32:08.496 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 74016.891602, idle connection 12925.000000, request 304398.626566
02/12/2026 04:32:08.496 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7281
02/12/2026 04:32:08.496 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:08.496 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7281 (601.8829345703125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1640977164, topics=[])
02/12/2026 04:32:08.496 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1640977164 with 0 response partitions (1 implied)
02/12/2026 04:32:08.497 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 234
02/12/2026 04:32:08.497 7f56ff31bc20 [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/12/2026 04:32:08.497 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff1f50d0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
02/12/2026 04:32:08.497 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:08.497 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6970, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.497 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6995 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6970, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.497 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71230.322998, idle connection 488804.000000, request 304999.960423
02/12/2026 04:32:08.497 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71229.921143, idle connection 488804.000000, request 304999.560595
02/12/2026 04:32:08.802 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70714.130371, idle connection 247953.000000, request 304397.948742
02/12/2026 04:32:08.802 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7442
02/12/2026 04:32:08.802 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:08.802 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7442 (602.5741100311279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1922371140, topics=[])
02/12/2026 04:32:08.802 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1922371140 with 0 response partitions (1 implied)
02/12/2026 04:32:08.855 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
02/12/2026 04:32:08.855 7f56ff31bcc0 [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/12/2026 04:32:08.856 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff1bb8e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
02/12/2026 04:32:08.856 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:08.856 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6992, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.856 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7009 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6992, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:08.856 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71694.709473, idle connection 10504.000000, request 304999.947548
02/12/2026 04:32:08.856 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71085.578125, idle connection 8703.000000, request 304397.118807
02/12/2026 04:32:08.857 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71694.105225, idle connection 10504.000000, request 304999.352455
02/12/2026 04:32:08.857 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6939
02/12/2026 04:32:08.857 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:08.857 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6939 (603.6148071289062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1820012549, topics=[])
02/12/2026 04:32:08.857 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1820012549 with 0 response partitions (1 implied)
02/12/2026 04:32:08.885 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71229.090820, idle connection 10210.000000, request 304397.930145
02/12/2026 04:32:08.885 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7028
02/12/2026 04:32:08.885 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:08.885 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7028 (602.6365756988525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1620918480, topics=[])
02/12/2026 04:32:08.885 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1620918480 with 0 response partitions (1 implied)
02/12/2026 04:32:09.016 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68459.216309, idle connection 7688.000000, request 304397.840977
02/12/2026 04:32:09.016 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12483
02/12/2026 04:32:09.017 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:09.017 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12483 (602.6902198791504 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[])
02/12/2026 04:32:09.017 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 0 response partitions (1 implied)
02/12/2026 04:32:09.097 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2435
02/12/2026 04:32:09.098 7f56ff31b860 [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/12/2026 04:32:09.098 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee8ebe0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
02/12/2026 04:32:09.098 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:09.098 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7269, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.098 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7282 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7269, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.098 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73414.449219, idle connection 12322.000000, request 304999.948740
02/12/2026 04:32:09.099 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 73413.990723, idle connection 12322.000000, request 304999.496698
02/12/2026 04:32:09.099 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70628.609131, idle connection 488203.000000, request 304398.248672
02/12/2026 04:32:09.099 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6995
02/12/2026 04:32:09.099 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:09.099 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6995 (602.1566390991211 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1342925977, topics=[])
02/12/2026 04:32:09.099 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1342925977 with 0 response partitions (1 implied)
02/12/2026 04:32:09.404 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 2970
02/12/2026 04:32:09.404 7f56ff31bf40 [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/12/2026 04:32:09.404 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff10fb20> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
02/12/2026 04:32:09.404 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:09.404 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7424, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.405 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7443 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7424, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.405 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70111.109863, idle connection 247350.000000, request 304999.945879
02/12/2026 04:32:09.405 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70110.624512, idle connection 247349.000000, request 304999.468565
02/12/2026 04:32:09.458 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/12/2026 04:32:09.458 7f56fde4fea0 [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/12/2026 04:32:09.458 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff0e2130> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
02/12/2026 04:32:09.458 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
02/12/2026 04:32:09.458 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6914, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.459 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6940 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6914, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.459 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70483.110596, idle connection 8101.000000, request 304999.936581
02/12/2026 04:32:09.459 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71091.741699, idle connection 9901.000000, request 304396.986485
02/12/2026 04:32:09.459 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70482.553467, idle connection 8100.000000, request 304999.401808
02/12/2026 04:32:09.459 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7009
02/12/2026 04:32:09.460 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:09.460 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7009 (603.6770343780518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1929483605, topics=[])
02/12/2026 04:32:09.460 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1929483605 with 0 response partitions (1 implied)
02/12/2026 04:32:09.486 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 359
02/12/2026 04:32:09.486 7f56ff31ba40 [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/12/2026 04:32:09.486 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff157370> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
02/12/2026 04:32:09.486 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:09.487 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7013, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.487 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7029 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7013, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.487 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70626.922119, idle connection 9608.000000, request 304999.950171
02/12/2026 04:32:09.487 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70626.519287, idle connection 9608.000000, request 304999.554396
02/12/2026 04:32:09.618 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59371
02/12/2026 04:32:09.618 7f56ffd402c0 [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/12/2026 04:32:09.618 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fd96ed60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
02/12/2026 04:32:09.618 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:09.618 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12469, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.618 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12484 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12469, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.619 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67856.774170, idle connection 7085.000000, request 304999.947309
02/12/2026 04:32:09.619 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67856.347656, idle connection 7085.000000, request 304999.528885
02/12/2026 04:32:09.700 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72812.425049, idle connection 11720.000000, request 304397.923708
02/12/2026 04:32:09.701 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7282
02/12/2026 04:32:09.701 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:09.701 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7282 (602.644681930542 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1640977164, topics=[])
02/12/2026 04:32:09.701 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1640977164 with 0 response partitions (1 implied)
02/12/2026 04:32:09.701 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 234
02/12/2026 04:32:09.701 7f56ff31bc20 [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/12/2026 04:32:09.701 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff0d47f0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
02/12/2026 04:32:09.701 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:09.701 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6971, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.702 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6996 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6971, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:09.702 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70025.672119, idle connection 487600.000000, request 304999.957323
02/12/2026 04:32:09.702 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70025.325684, idle connection 487599.000000, request 304999.614239
02/12/2026 04:32:10.007 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69508.990723, idle connection 246748.000000, request 304397.827387
02/12/2026 04:32:10.007 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7443
02/12/2026 04:32:10.007 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.007 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7443 (602.6954650878906 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1922371140, topics=[])
02/12/2026 04:32:10.008 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1922371140 with 0 response partitions (1 implied)
02/12/2026 04:32:10.061 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 438
02/12/2026 04:32:10.061 7f56ff31bcc0 [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/12/2026 04:32:10.061 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee8c730> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
02/12/2026 04:32:10.061 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:10.062 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6993, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.062 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7010 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1929483605, session_epoch=6993, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.062 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70488.847900, idle connection 9299.000000, request 304999.949455
02/12/2026 04:32:10.062 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69879.718750, idle connection 7497.000000, request 304396.564960
02/12/2026 04:32:10.062 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70488.208740, idle connection 9298.000000, request 304999.314308
02/12/2026 04:32:10.063 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6940
02/12/2026 04:32:10.063 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.063 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 6940 (604.2337417602539 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1820012549, topics=[])
02/12/2026 04:32:10.063 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1820012549 with 0 response partitions (1 implied)
02/12/2026 04:32:10.088 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70025.331543, idle connection 9006.000000, request 304398.359537
02/12/2026 04:32:10.089 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7029
02/12/2026 04:32:10.089 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.089 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7029 (602.1327972412109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1620918480, topics=[])
02/12/2026 04:32:10.089 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1620918480 with 0 response partitions (1 implied)
02/12/2026 04:32:10.220 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67255.854004, idle connection 6484.000000, request 304399.027109
02/12/2026 04:32:10.220 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12484
02/12/2026 04:32:10.220 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.220 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12484 (601.5129089355469 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=59372, last_stable_offset=59372, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe7\xeb\x00\x00\x01\x04\x00\x00\x00\x00\x02Nc\xfe\xcd\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/12/2026 04:32:10.220 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 1 response partitions (0 implied)
02/12/2026 04:32:10.220 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 59371
02/12/2026 04:32:10.220 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 59371 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
02/12/2026 04:32:10.221 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 59372 (leader epoch 0)
02/12/2026 04:32:10.301 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2435
02/12/2026 04:32:10.301 7f56ff31b860 [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/12/2026 04:32:10.301 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff10f3a0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
02/12/2026 04:32:10.302 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:10.302 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7270, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.302 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7283 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1640977164, session_epoch=7270, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.302 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72210.623779, idle connection 11119.000000, request 304999.950409
02/12/2026 04:32:10.302 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 72210.210693, idle connection 11118.000000, request 304999.544382
02/12/2026 04:32:10.303 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69424.829346, idle connection 486999.000000, request 304399.118185
02/12/2026 04:32:10.303 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6996
02/12/2026 04:32:10.303 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.303 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 6996 (601.2749671936035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1342925977, topics=[])
02/12/2026 04:32:10.303 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1342925977 with 0 response partitions (1 implied)
02/12/2026 04:32:10.322 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59372
02/12/2026 04:32:10.322 7f56ffd402c0 [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/12/2026 04:32:10.322 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56feebea30> 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/12/2026 04:32:10.322 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:10.322 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12470, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59372, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:10.322 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12485 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12470, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59372, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:10.322 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67152.992432, idle connection 6382.000000, request 304999.950171
02/12/2026 04:32:10.323 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67152.593018, idle connection 6381.000000, request 304999.557495
02/12/2026 04:32:10.608 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 2970
02/12/2026 04:32:10.608 7f56ff31bf40 [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/12/2026 04:32:10.608 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee8e190> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
02/12/2026 04:32:10.608 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:10.609 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7425, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.609 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 7444 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1922371140, session_epoch=7425, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.609 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68907.047119, idle connection 246146.000000, request 304999.949455
02/12/2026 04:32:10.609 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68906.644287, idle connection 246145.000000, request 304999.552011
02/12/2026 04:32:10.663 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/12/2026 04:32:10.664 7f56fde4fea0 [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/12/2026 04:32:10.664 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56feebe6d0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
02/12/2026 04:32:10.664 7f56fde4fea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
02/12/2026 04:32:10.664 7f56fde4fea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6915, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.664 7f56fde4fea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 6941 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1820012549, session_epoch=6915, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.664 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69277.704590, idle connection 6895.000000, request 304999.948025
02/12/2026 04:32:10.664 7f56ff31bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69886.229980, idle connection 8696.000000, request 304397.333384
02/12/2026 04:32:10.665 7f56fde4fea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69276.988281, idle connection 6894.000000, request 304999.240160
02/12/2026 04:32:10.665 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7010
02/12/2026 04:32:10.665 7f56ff31bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.665 7f56ff31bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 7010 (603.3616065979004 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1929483605, topics=[])
02/12/2026 04:32:10.665 7f56ff31bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1929483605 with 0 response partitions (1 implied)
02/12/2026 04:32:10.689 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 359
02/12/2026 04:32:10.690 7f56ff31ba40 [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/12/2026 04:32:10.690 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee8ebb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
02/12/2026 04:32:10.690 7f56ff31ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:10.690 7f56ff31ba40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7014, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.690 7f56ff31ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 7030 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1620918480, session_epoch=7014, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.690 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69423.661377, idle connection 8405.000000, request 304999.949694
02/12/2026 04:32:10.691 7f56ff31ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69423.246094, idle connection 8404.000000, request 304999.541283
02/12/2026 04:32:10.903 7f56ff31b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71609.487549, idle connection 10518.000000, request 304398.806810
02/12/2026 04:32:10.904 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7283
02/12/2026 04:32:10.904 7f56ff31b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.904 7f56ff31b860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7283 (602.0185947418213 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1640977164, topics=[])
02/12/2026 04:32:10.904 7f56ff31b860 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1640977164 with 0 response partitions (1 implied)
02/12/2026 04:32:10.905 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 234
02/12/2026 04:32:10.905 7f56ff31bc20 [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/12/2026 04:32:10.905 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fee3e4f0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
02/12/2026 04:32:10.905 7f56ff31bc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
02/12/2026 04:32:10.905 7f56ff31bc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6972, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.905 7f56ff31bc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Request 6997 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1342925977, session_epoch=6972, topics=[], forgotten_topics_data=[])
02/12/2026 04:32:10.905 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68821.994873, idle connection 486396.000000, request 304999.931335
02/12/2026 04:32:10.906 7f56ff31bc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68821.453369, idle connection 486396.000000, request 304999.394417
02/12/2026 04:32:10.923 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66552.035889, idle connection 5781.000000, request 304398.982286
02/12/2026 04:32:10.924 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12485
02/12/2026 04:32:10.924 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:10.924 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12485 (601.8500328063965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=59375, last_stable_offset=59375, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe7\xec\x00\x00\x01\x04\x00\x00\x00\x00\x02\xafeY\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\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
02/12/2026 04:32:10.925 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 1 response partitions (0 implied)
02/12/2026 04:32:10.925 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 816 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 59372
02/12/2026 04:32:10.925 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 59372 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
02/12/2026 04:32:10.926 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 59375 (leader epoch 0)
02/12/2026 04:32:11.027 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59375
02/12/2026 04:32:11.027 7f56ffd402c0 [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/12/2026 04:32:11.027 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56fd918370> 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/12/2026 04:32:11.027 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:11.027 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12471, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59375, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:11.028 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12486 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12471, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59375, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:11.028 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66447.536133, idle connection 5676.000000, request 304999.943733
02/12/2026 04:32:11.028 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66446.964844, idle connection 5676.000000, request 304999.377489
02/12/2026 04:32:11.029 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12486
02/12/2026 04:32:11.029 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:11.029 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12486 (1.146078109741211 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=59377, last_stable_offset=59377, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\xe7\xef\x00\x00\x01\x04\x00\x00\x00\x00\x02'\xacS\xe3\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/12/2026 04:32:11.029 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 1 response partitions (0 implied)
02/12/2026 04:32:11.029 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 544 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 59375
02/12/2026 04:32:11.029 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 59375 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
02/12/2026 04:32:11.030 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 59377 (leader epoch 0)
02/12/2026 04:32:11.131 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59377
02/12/2026 04:32:11.131 7f56ffd402c0 [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/12/2026 04:32:11.131 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff0e2ee0> 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/12/2026 04:32:11.131 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:11.131 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12472, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59377, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:11.131 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12487 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12472, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59377, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:11.131 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66344.022461, idle connection 5573.000000, request 304999.946833
02/12/2026 04:32:11.132 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66343.212891, idle connection 5572.000000, request 304999.140739
02/12/2026 04:32:11.132 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 12487
02/12/2026 04:32:11.133 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:11.133 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Response 12487 (1.3632774353027344 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1762450541, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=59378, last_stable_offset=59378, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xe7\xf1\x00\x00\x01\x04\x00\x00\x00\x00\x02~u)\xa0\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/12/2026 04:32:11.133 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1762450541 with 1 response partitions (0 implied)
02/12/2026 04:32:11.133 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 59377
02/12/2026 04:32:11.133 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 59377 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
02/12/2026 04:32:11.133 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 59378 (leader epoch 0)
02/12/2026 04:32:11.210 7f56ff31bf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68306.136963, idle connection 245545.000000, request 304399.039030
02/12/2026 04:32:11.210 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7444
02/12/2026 04:32:11.210 7f56ff31bf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/12/2026 04:32:11.210 7f56ff31bf40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.23:9092 <connected> [IPv4 ('10.0.0.23', 9092)]>: Response 7444 (601.5112400054932 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1922371140, topics=[])
02/12/2026 04:32:11.210 7f56ff31bf40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1922371140 with 0 response partitions (1 implied)
02/12/2026 04:32:11.234 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 59378
02/12/2026 04:32:11.234 7f56ffd402c0 [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/12/2026 04:32:11.234 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f56ff10f3a0> 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/12/2026 04:32:11.234 7f56ffd402c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/12/2026 04:32:11.234 7f56ffd402c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12473, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59378, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:11.234 7f56ffd402c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.130:9092 <connected> [IPv4 ('10.0.0.130', 9092)]>: Request 12488 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1762450541, session_epoch=12473, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=59378, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
02/12/2026 04:32:11.234 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66240.971436, idle connection 5470.000000, request 304999.950409
02/12/2026 04:32:11.235 7f56ffd402c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66240.597656, idle connection 5469.000000, request 304999.583006