03/02/2026 02:17:26.563 7f41128f12c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240967.452881, idle connection 116857.000000, request 304396.281719
03/02/2026 02:17:26.564 7f41115fc0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239534.595947, idle connection 116885.000000, request 304396.101236
03/02/2026 02:17:26.565 7f41115fc360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240362.507080, idle connection 117159.000000, request 304998.072386
03/02/2026 02:17:26.565 7f41128f12c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810
03/02/2026 02:17:26.565 7f41128f12c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.565 7f41128f12c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 810 (605.785608291626 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1525629134, topics=[])
03/02/2026 02:17:26.565 7f41128f12c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1525629134 with 0 response partitions (1 implied)
03/02/2026 02:17:26.565 7f41115fc0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 860
03/02/2026 02:17:26.565 7f41115fc0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.566 7f41115fc0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 860 (605.3464412689209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=890574808, topics=[])
03/02/2026 02:17:26.566 7f41115fc0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 890574808 with 0 response partitions (1 implied)
03/02/2026 02:17:26.573 7f41115fc9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240255.464355, idle connection 117528.000000, request 304398.872137
03/02/2026 02:17:26.573 7f41115fc9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 844
03/02/2026 02:17:26.573 7f41115fc9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.573 7f41115fc9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 844 (601.5899181365967 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1703524964, topics=[])
03/02/2026 02:17:26.573 7f41115fc9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1703524964 with 0 response partitions (1 implied)
03/02/2026 02:17:26.575 7f41128f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 39
03/02/2026 02:17:26.575 7f41128f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/02/2026 02:17:26.576 7f41128f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f4110c267f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/02/2026 02:17:26.576 7f41128f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/02/2026 02:17:26.576 7f41128f1b80 [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=337347123, session_epoch=803, topics=[], forgotten_topics_data=[])
03/02/2026 02:17:26.576 7f41128f1b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 808 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=337347123, session_epoch=803, topics=[], forgotten_topics_data=[])
03/02/2026 02:17:26.576 7f41128f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240361.894287, idle connection 116735.000000, request 304999.954700
03/02/2026 02:17:26.576 7f41128f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240361.514648, idle connection 116735.000000, request 304999.577522
03/02/2026 02:17:26.591 7f41129a67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240949.326660, idle connection 116504.000000, request 304396.067142
03/02/2026 02:17:26.592 7f41115fcae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240594.796387, idle connection 117652.000000, request 304397.036552
03/02/2026 02:17:26.592 7f41129a67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 814
03/02/2026 02:17:26.592 7f41129a67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.592 7f41129a67c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 814 (604.4912338256836 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515063755, topics=[])
03/02/2026 02:17:26.592 7f41129a67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 515063755 with 0 response partitions (1 implied)
03/02/2026 02:17:26.592 7f41115fcae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 868
03/02/2026 02:17:26.592 7f41115fcae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.593 7f41115fcae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 868 (603.8472652435303 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=62448366, topics=[])
03/02/2026 02:17:26.593 7f41115fcae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 62448366 with 0 response partitions (1 implied)
03/02/2026 02:17:26.593 7f410f6c9ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240099.409424, idle connection 116335.000000, request 304396.805286
03/02/2026 02:17:26.593 7f410f6c9ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 843
03/02/2026 02:17:26.593 7f410f6c9ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.593 7f410f6c9ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 843 (603.5006046295166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=736418178, topics=[])
03/02/2026 02:17:26.593 7f410f6c9ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 736418178 with 0 response partitions (1 implied)
03/02/2026 02:17:26.687 7f410f533ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240936.746094, idle connection 116523.000000, request 304396.942854
03/02/2026 02:17:26.688 7f410f533ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 806
03/02/2026 02:17:26.688 7f410f533ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.688 7f410f533ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 806 (603.5833358764648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=223991208, topics=[])
03/02/2026 02:17:26.688 7f410f533ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 223991208 with 0 response partitions (1 implied)
03/02/2026 02:17:26.688 7f41128f1180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239731.069824, idle connection 117242.000000, request 304396.915436
03/02/2026 02:17:26.688 7f41128f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239805.850098, idle connection 117141.000000, request 304398.058653
03/02/2026 02:17:26.688 7f41128f1180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 801
03/02/2026 02:17:26.688 7f41128f1180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.689 7f41128f1180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 801 (603.5571098327637 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=466563811, topics=[])
03/02/2026 02:17:26.689 7f41128f1180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 466563811 with 0 response partitions (1 implied)
03/02/2026 02:17:26.689 7f41128f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 809
03/02/2026 02:17:26.689 7f41128f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.689 7f41128f1040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 809 (602.7610301971436 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1130033141, topics=[])
03/02/2026 02:17:26.689 7f41128f1040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1130033141 with 0 response partitions (1 implied)
03/02/2026 02:17:26.749 7f41128f1680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 24
03/02/2026 02:17:26.749 7f41128f1680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
03/02/2026 02:17:26.749 7f41128f1680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f4110359430> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
03/02/2026 02:17:26.749 7f41128f1680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/02/2026 02:17:26.749 7f41128f1680 [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=539047078, session_epoch=803, topics=[], forgotten_topics_data=[])
03/02/2026 02:17:26.749 7f41128f1680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 808 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=539047078, session_epoch=803, topics=[], forgotten_topics_data=[])
03/02/2026 02:17:26.749 7f41128f1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240363.736084, idle connection 116655.000000, request 304999.946356
03/02/2026 02:17:26.750 7f41128f1680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240363.299805, idle connection 116655.000000, request 304999.517679
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239608.020264, idle connection 117198.000000, request 304398.981810
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1175
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 1175 (601.4373302459717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=15441021, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3877, last_stable_offset=3877, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f$\x00\x00\x01\x05\x00\x00\x00\x00\x02t\x96r%\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 15441021 with 1 response partitions (0 implied)
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3876
03/02/2026 02:17:26.758 7f410f6c9cc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3876 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
03/02/2026 02:17:26.759 7f410f6c9cc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3877 (leader epoch 0)
03/02/2026 02:17:26.769 7f410f6c9d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239726.736572, idle connection 116126.000000, request 304397.951126
03/02/2026 02:17:26.770 7f410f6c9d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 801
03/02/2026 02:17:26.770 7f410f6c9d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.770 7f410f6c9d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 801 (602.4508476257324 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=967389397, topics=[])
03/02/2026 02:17:26.770 7f410f6c9d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 967389397 with 0 response partitions (1 implied)
03/02/2026 02:17:26.770 7f41128f1860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240946.147461, idle connection 116715.000000, request 304397.979259
03/02/2026 02:17:26.770 7f41128f1860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 815
03/02/2026 02:17:26.770 7f41128f1860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.770 7f41128f1860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 815 (602.3457050323486 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2046617277, topics=[])
03/02/2026 02:17:26.771 7f41128f1860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2046617277 with 0 response partitions (1 implied)
03/02/2026 02:17:26.774 7f41115fc720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239563.497070, idle connection 116673.000000, request 304399.192333
03/02/2026 02:17:26.774 7f41115fc720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 821
03/02/2026 02:17:26.774 7f41115fc720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.774 7f41115fc720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 821 (601.1180877685547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1534991818, topics=[])
03/02/2026 02:17:26.774 7f41115fc720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1534991818 with 0 response partitions (1 implied)
03/02/2026 02:17:26.776 7f4110ccf540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239799.372070, idle connection 117389.000000, request 304399.240971
03/02/2026 02:17:26.776 7f4110ccf540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 806
03/02/2026 02:17:26.776 7f4110ccf540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/02/2026 02:17:26.776 7f4110ccf540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 806 (601.0556221008301 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1029284021, topics=[])
03/02/2026 02:17:26.776 7f4110ccf540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1029284021 with 0 response partitions (1 implied)