11/09/2026 04:21:21.493 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
11/09/2026 04:21:21.495 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc613bf40> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
11/09/2026 04:21:21.495 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:21.495 7fcfc655bcc0 [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=1133441616, session_epoch=6365, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.496 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6377 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1133441616, session_epoch=6365, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.496 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140191.127441, idle connection 79140.000000, request 304999.927998
11/09/2026 04:21:21.496 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140190.577393, idle connection 79140.000000, request 304999.387503
11/09/2026 04:21:21.597 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 102
11/09/2026 04:21:21.597 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
11/09/2026 04:21:21.597 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc8144670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
11/09/2026 04:21:21.597 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/09/2026 04:21:21.598 7fcfc655b7c0 [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=862102860, session_epoch=5633, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.598 7fcfc655b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Request 5654 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=862102860, session_epoch=5633, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.598 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141566.873291, idle connection 80789.000000, request 304999.896526
11/09/2026 04:21:21.599 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141566.090088, idle connection 80788.000000, request 304999.124527
11/09/2026 04:21:21.611 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140158.928467, idle connection 78892.000000, request 304398.952961
11/09/2026 04:21:21.611 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9077
11/09/2026 04:21:21.611 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:21.611 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 9077 (601.625919342041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2051684790, topics=[])
11/09/2026 04:21:21.612 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2051684790 with 0 response partitions (1 implied)
11/09/2026 04:21:21.767 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 142256.203125, idle connection 258208.000000, request 304398.539305
11/09/2026 04:21:21.768 7fcfc655ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5661
11/09/2026 04:21:21.768 7fcfc655ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:21.769 7fcfc655ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 5661 (602.4689674377441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=874175226, topics=[])
11/09/2026 04:21:21.769 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 874175226 with 0 response partitions (1 implied)
11/09/2026 04:21:21.890 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 232
11/09/2026 04:21:21.891 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
11/09/2026 04:21:21.891 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc600d670> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
11/09/2026 04:21:21.891 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:21.891 7fcfc655bb80 [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=1149908902, session_epoch=5650, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.891 7fcfc655bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 5663 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1149908902, session_epoch=5650, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.891 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 142877.866699, idle connection 80533.000000, request 304999.927044
11/09/2026 04:21:21.892 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 142877.365234, idle connection 80532.000000, request 304999.434233
11/09/2026 04:21:21.948 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 144936.289795, idle connection 83231.000000, request 304398.054123
11/09/2026 04:21:21.949 7fcfc655be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6118
11/09/2026 04:21:21.949 7fcfc655be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:21.949 7fcfc655be00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6118 (602.614164352417 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1537108334, topics=[])
11/09/2026 04:21:21.949 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1537108334 with 0 response partitions (1 implied)
11/09/2026 04:21:21.989 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 2660
11/09/2026 04:21:21.989 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
11/09/2026 04:21:21.989 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc80bf400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
11/09/2026 04:21:21.989 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/09/2026 04:21:21.990 7fcfc655b900 [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=2023761268, session_epoch=6012, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.990 7fcfc655b900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Request 6028 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2023761268, session_epoch=6012, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:21.990 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141075.828125, idle connection 433782.000000, request 304999.932289
11/09/2026 04:21:21.991 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141075.161133, idle connection 433781.000000, request 304999.267817
11/09/2026 04:21:22.028 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 57
11/09/2026 04:21:22.028 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
11/09/2026 04:21:22.029 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc600dd30> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/09/2026 04:21:22.029 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/09/2026 04:21:22.029 7fcfc97eea40 [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=896222004, session_epoch=5624, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.029 7fcfc97eea40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 5641 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=896222004, session_epoch=5624, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.029 7fcfc97eea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140434.410400, idle connection 78119.000000, request 304999.921322
11/09/2026 04:21:22.030 7fcfc97eea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140433.866455, idle connection 78119.000000, request 304999.382734
11/09/2026 04:21:22.099 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139588.141357, idle connection 78537.000000, request 304396.946192
11/09/2026 04:21:22.099 7fcfc655bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6377
11/09/2026 04:21:22.099 7fcfc655bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.099 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6377 (603.6376953125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1133441616, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=4656, last_stable_offset=4656, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x12.\x00\x00\x01\x0f\x00\x00\x00\x00\x02rS\x9d\xd1\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\xb8\x03\x00\x00\x00\xfa\x02ObjectGeneratorInfo:cn-jenkins-d...')])])
11/09/2026 04:21:22.100 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1133441616 with 1 response partitions (0 implied)
11/09/2026 04:21:22.100 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 566 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 4654
11/09/2026 04:21:22.100 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4654 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0)
11/09/2026 04:21:22.100 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 4656 (leader epoch 0)
11/09/2026 04:21:22.200 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140965.394775, idle connection 80188.000000, request 304398.416758
11/09/2026 04:21:22.200 7fcfc655b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5654
11/09/2026 04:21:22.200 7fcfc655b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.200 7fcfc655b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Response 5654 (602.241039276123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=862102860, topics=[])
11/09/2026 04:21:22.201 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 862102860 with 0 response partitions (1 implied)
11/09/2026 04:21:22.201 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4656
11/09/2026 04:21:22.201 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
11/09/2026 04:21:22.201 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc64a4040> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
11/09/2026 04:21:22.201 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:22.201 7fcfc655bcc0 [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=1133441616, session_epoch=6366, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4656, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:22.202 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6378 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1133441616, session_epoch=6366, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4656, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:22.202 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139485.085205, idle connection 78434.000000, request 304999.946594
11/09/2026 04:21:22.202 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139484.608398, idle connection 78434.000000, request 304999.474525
11/09/2026 04:21:22.212 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 11580
11/09/2026 04:21:22.212 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
11/09/2026 04:21:22.212 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc609aa90> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
11/09/2026 04:21:22.212 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:22.212 7fcfc655b540 [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=2051684790, session_epoch=9070, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.213 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 9078 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2051684790, session_epoch=9070, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.213 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139557.085205, idle connection 78290.000000, request 304999.948502
11/09/2026 04:21:22.213 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139556.682861, idle connection 78290.000000, request 304999.549866
11/09/2026 04:21:22.369 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 111
11/09/2026 04:21:22.370 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
11/09/2026 04:21:22.370 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc6272dc0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
11/09/2026 04:21:22.370 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:22.370 7fcfc655ba40 [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=874175226, session_epoch=5641, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.370 7fcfc655ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 5662 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=874175226, session_epoch=5641, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.370 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141653.392334, idle connection 257605.000000, request 304999.933004
11/09/2026 04:21:22.371 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141652.913818, idle connection 257605.000000, request 304999.463558
11/09/2026 04:21:22.492 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 142276.799072, idle connection 79932.000000, request 304398.859024
11/09/2026 04:21:22.493 7fcfc655bb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5663
11/09/2026 04:21:22.493 7fcfc655bb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.493 7fcfc655bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 5663 (601.733922958374 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1149908902, topics=[])
11/09/2026 04:21:22.493 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1149908902 with 0 response partitions (1 implied)
11/09/2026 04:21:22.550 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4101
11/09/2026 04:21:22.550 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
11/09/2026 04:21:22.550 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc600d9d0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
11/09/2026 04:21:22.550 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/09/2026 04:21:22.550 7fcfc655be00 [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=1537108334, session_epoch=6110, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.551 7fcfc655be00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1537108334, session_epoch=6110, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.551 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 144333.966553, idle connection 82629.000000, request 304999.939442
11/09/2026 04:21:22.551 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 144333.309814, idle connection 82628.000000, request 304999.288321
11/09/2026 04:21:22.592 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140474.418213, idle connection 433180.000000, request 304398.522854
11/09/2026 04:21:22.592 7fcfc655b900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6028
11/09/2026 04:21:22.592 7fcfc655b900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.592 7fcfc655b900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Response 6028 (602.3545265197754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2023761268, topics=[(topics='-uve-topic-20', partitions=[(partition=0, error_code=0, highwater_offset=2662, last_stable_offset=2662, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\nd\x00\x00\x01\xed\x00\x00\x00\x00\x02\x0f\x04\x8c9\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xb8\x03\x00\x00\x00\xfa\x02ObjectGeneratorInfo:cn-jenkins-d...')])])
11/09/2026 04:21:22.593 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2023761268 with 1 response partitions (0 implied)
11/09/2026 04:21:22.593 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 505 bytes of data for partition TopicPartition(topic='-uve-topic-20', partition=0) with offset 2660
11/09/2026 04:21:22.593 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2660 for assigned partition TopicPartition(topic='-uve-topic-20', partition=0)
11/09/2026 04:21:22.594 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-20', partition=0) to 2662 (leader epoch 0)
11/09/2026 04:21:22.630 7fcfc97eea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139833.178955, idle connection 77518.000000, request 304398.689508
11/09/2026 04:21:22.631 7fcfc97eea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5641
11/09/2026 04:21:22.631 7fcfc97eea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.631 7fcfc97eea40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 5641 (602.0035743713379 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=896222004, topics=[])
11/09/2026 04:21:22.631 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 896222004 with 0 response partitions (1 implied)
11/09/2026 04:21:22.695 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 2662
11/09/2026 04:21:22.695 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
11/09/2026 04:21:22.695 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc803a0a0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-20', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
11/09/2026 04:21:22.695 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/09/2026 04:21:22.695 7fcfc655b900 [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=2023761268, session_epoch=6013, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2662, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:22.695 7fcfc655b900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Request 6029 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2023761268, session_epoch=6013, topics=[(topic='-uve-topic-20', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2662, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:22.695 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140370.469971, idle connection 433076.000000, request 304999.936581
11/09/2026 04:21:22.696 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140370.003662, idle connection 433076.000000, request 304999.473810
11/09/2026 04:21:22.801 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 102
11/09/2026 04:21:22.801 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
11/09/2026 04:21:22.801 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc642cd00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
11/09/2026 04:21:22.801 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/09/2026 04:21:22.802 7fcfc655b7c0 [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=862102860, session_epoch=5634, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.802 7fcfc655b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Request 5655 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=862102860, session_epoch=5634, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:22.802 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140363.239014, idle connection 79585.000000, request 304999.938011
11/09/2026 04:21:22.802 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140362.735596, idle connection 79585.000000, request 304999.442816
11/09/2026 04:21:22.803 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138884.237305, idle connection 77833.000000, request 304399.103880
11/09/2026 04:21:22.803 7fcfc655bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6378
11/09/2026 04:21:22.803 7fcfc655bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.803 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6378 (601.285457611084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1133441616, topics=[])
11/09/2026 04:21:22.803 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1133441616 with 0 response partitions (1 implied)
11/09/2026 04:21:22.814 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138956.253418, idle connection 77689.000000, request 304399.113655
11/09/2026 04:21:22.814 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9078
11/09/2026 04:21:22.814 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.814 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 9078 (601.4039516448975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2051684790, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=11582, last_stable_offset=11582, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00-<\x00\x00\x01\x04\x00\x00\x00\x00\x02W\xdfZt\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...')])])
11/09/2026 04:21:22.814 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2051684790 with 1 response partitions (0 implied)
11/09/2026 04:21:22.815 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 556 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 11580
11/09/2026 04:21:22.815 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 11580 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
11/09/2026 04:21:22.815 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 11582 (leader epoch 0)
11/09/2026 04:21:22.916 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 11582
11/09/2026 04:21:22.916 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
11/09/2026 04:21:22.916 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc6589970> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
11/09/2026 04:21:22.916 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:22.916 7fcfc655b540 [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=2051684790, session_epoch=9071, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=11582, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:22.916 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 9079 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2051684790, session_epoch=9071, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=11582, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:22.917 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138853.186523, idle connection 77586.000000, request 304999.934912
11/09/2026 04:21:22.917 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138852.709229, idle connection 77586.000000, request 304999.462605
11/09/2026 04:21:22.971 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141052.317627, idle connection 257004.000000, request 304398.856640
11/09/2026 04:21:22.972 7fcfc655ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5662
11/09/2026 04:21:22.972 7fcfc655ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:22.972 7fcfc655ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 5662 (601.8145084381104 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=874175226, topics=[])
11/09/2026 04:21:22.972 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 874175226 with 0 response partitions (1 implied)
11/09/2026 04:21:23.098 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 232
11/09/2026 04:21:23.098 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
11/09/2026 04:21:23.098 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc7b9f070> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
11/09/2026 04:21:23.098 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:23.098 7fcfc655bb80 [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=1149908902, session_epoch=5651, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.098 7fcfc655bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 5664 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1149908902, session_epoch=5651, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.098 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141670.781494, idle connection 79326.000000, request 304999.944210
11/09/2026 04:21:23.101 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141668.470459, idle connection 79324.000000, request 304997.638226
11/09/2026 04:21:23.152 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 143732.628418, idle connection 82028.000000, request 304398.586512
11/09/2026 04:21:23.153 7fcfc655be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6119
11/09/2026 04:21:23.153 7fcfc655be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:23.153 7fcfc655be00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6119 (602.2293567657471 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1537108334, topics=[])
11/09/2026 04:21:23.153 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1537108334 with 0 response partitions (1 implied)
11/09/2026 04:21:23.232 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 57
11/09/2026 04:21:23.232 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
11/09/2026 04:21:23.232 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc7c18340> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/09/2026 04:21:23.232 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/09/2026 04:21:23.233 7fcfc97eea40 [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=896222004, session_epoch=5625, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.233 7fcfc97eea40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 5642 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=896222004, session_epoch=5625, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.233 7fcfc97eea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139230.659912, idle connection 76915.000000, request 304999.933004
11/09/2026 04:21:23.233 7fcfc97eea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139230.165039, idle connection 76915.000000, request 304999.446154
11/09/2026 04:21:23.297 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139769.329346, idle connection 432475.000000, request 304398.792267
11/09/2026 04:21:23.297 7fcfc655b900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6029
11/09/2026 04:21:23.297 7fcfc655b900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:23.297 7fcfc655b900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Response 6029 (601.8896102905273 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2023761268, topics=[])
11/09/2026 04:21:23.297 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2023761268 with 0 response partitions (1 implied)
11/09/2026 04:21:23.403 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139762.099121, idle connection 78984.000000, request 304398.795366
11/09/2026 04:21:23.403 7fcfc655b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5655
11/09/2026 04:21:23.404 7fcfc655b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:23.404 7fcfc655b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Response 5655 (601.8469333648682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=862102860, topics=[])
11/09/2026 04:21:23.404 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 862102860 with 0 response partitions (1 implied)
11/09/2026 04:21:23.404 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4656
11/09/2026 04:21:23.404 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
11/09/2026 04:21:23.404 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc608cdf0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
11/09/2026 04:21:23.404 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:23.404 7fcfc655bcc0 [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=1133441616, session_epoch=6367, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.405 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6379 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1133441616, session_epoch=6367, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.405 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138282.168701, idle connection 77231.000000, request 304999.946594
11/09/2026 04:21:23.405 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138281.708252, idle connection 77231.000000, request 304999.490261
11/09/2026 04:21:23.518 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138252.046143, idle connection 76985.000000, request 304398.790598
11/09/2026 04:21:23.518 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9079
11/09/2026 04:21:23.518 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:23.519 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 9079 (601.9911766052246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2051684790, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=11583, last_stable_offset=11583, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00->\x00\x00\x01\x05\x00\x00\x00\x00\x02\x83\\K\xfd\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...')])])
11/09/2026 04:21:23.519 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2051684790 with 1 response partitions (0 implied)
11/09/2026 04:21:23.519 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 11582
11/09/2026 04:21:23.519 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 11582 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
11/09/2026 04:21:23.519 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 11583 (leader epoch 0)
11/09/2026 04:21:23.576 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 111
11/09/2026 04:21:23.576 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
11/09/2026 04:21:23.576 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc642c190> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
11/09/2026 04:21:23.576 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:23.576 7fcfc655ba40 [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=874175226, session_epoch=5642, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.577 7fcfc655ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 5663 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=874175226, session_epoch=5642, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.577 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140446.948486, idle connection 256399.000000, request 304999.936581
11/09/2026 04:21:23.577 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140446.448242, idle connection 256398.000000, request 304999.444246
11/09/2026 04:21:23.620 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 11583
11/09/2026 04:21:23.620 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
11/09/2026 04:21:23.620 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc64f74f0> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
11/09/2026 04:21:23.620 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:23.621 7fcfc655b540 [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=2051684790, session_epoch=9072, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=11583, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:23.621 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 9080 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2051684790, session_epoch=9072, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=11583, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:23.621 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138148.842529, idle connection 76882.000000, request 304999.936342
11/09/2026 04:21:23.621 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138148.317627, idle connection 76881.000000, request 304999.419689
11/09/2026 04:21:23.702 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 141067.172852, idle connection 78722.000000, request 304396.267176
11/09/2026 04:21:23.702 7fcfc655bb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5664
11/09/2026 04:21:23.703 7fcfc655bb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:23.703 7fcfc655bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 5664 (604.4251918792725 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1149908902, topics=[])
11/09/2026 04:21:23.703 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1149908902 with 0 response partitions (1 implied)
11/09/2026 04:21:23.754 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4101
11/09/2026 04:21:23.754 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
11/09/2026 04:21:23.754 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc613bf40> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
11/09/2026 04:21:23.754 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
11/09/2026 04:21:23.754 7fcfc655be00 [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=1537108334, session_epoch=6111, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.755 7fcfc655be00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Request 6120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1537108334, session_epoch=6111, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.755 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 143130.040771, idle connection 81425.000000, request 304999.937296
11/09/2026 04:21:23.755 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 143129.568604, idle connection 81424.000000, request 304999.473810
11/09/2026 04:21:23.834 7fcfc97eea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138629.564697, idle connection 76314.000000, request 304398.837566
11/09/2026 04:21:23.834 7fcfc97eea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5642
11/09/2026 04:21:23.835 7fcfc97eea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:23.835 7fcfc97eea40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 5642 (601.7575263977051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=896222004, topics=[])
11/09/2026 04:21:23.835 7fcfc97eea40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 896222004 with 0 response partitions (1 implied)
11/09/2026 04:21:23.898 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 2662
11/09/2026 04:21:23.898 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
11/09/2026 04:21:23.898 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc7ba1d90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
11/09/2026 04:21:23.898 7fcfc655b900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/09/2026 04:21:23.898 7fcfc655b900 [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=2023761268, session_epoch=6014, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.899 7fcfc655b900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Request 6030 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2023761268, session_epoch=6014, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:23.899 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139167.158936, idle connection 431873.000000, request 304999.937534
11/09/2026 04:21:23.899 7fcfc655b900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139166.675781, idle connection 431872.000000, request 304999.463081
11/09/2026 04:21:24.004 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 102
11/09/2026 04:21:24.005 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
11/09/2026 04:21:24.005 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc613b700> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
11/09/2026 04:21:24.005 7fcfc655b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/09/2026 04:21:24.005 7fcfc655b7c0 [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=862102860, session_epoch=5635, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:24.005 7fcfc655b7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.248:9092 <connected> [IPv4 ('10.0.0.248', 9092)]>: Request 5656 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=862102860, session_epoch=5635, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:24.005 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139159.911133, idle connection 78382.000000, request 304999.928236
11/09/2026 04:21:24.006 7fcfc655b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139159.430908, idle connection 78382.000000, request 304999.456882
11/09/2026 04:21:24.006 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137681.032715, idle connection 76630.000000, request 304398.816586
11/09/2026 04:21:24.006 7fcfc655bcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6379
11/09/2026 04:21:24.006 7fcfc655bcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:24.006 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 6379 (601.752519607544 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1133441616, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=4658, last_stable_offset=4658, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x120\x00\x00\x02\x17\x00\x00\x00\x00\x02\n\x97\xa5\xc7\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
11/09/2026 04:21:24.007 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1133441616 with 1 response partitions (0 implied)
11/09/2026 04:21:24.007 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 4656
11/09/2026 04:21:24.007 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4656 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0)
11/09/2026 04:21:24.007 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 4658 (leader epoch 0)
11/09/2026 04:21:24.108 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4658
11/09/2026 04:21:24.108 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
11/09/2026 04:21:24.108 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc6f3b5e0> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
11/09/2026 04:21:24.108 7fcfc655bcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:24.108 7fcfc655bcc0 [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=1133441616, session_epoch=6368, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4658, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:24.109 7fcfc655bcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 6380 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1133441616, session_epoch=6368, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4658, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:24.109 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137578.218262, idle connection 76527.000000, request 304999.936581
11/09/2026 04:21:24.109 7fcfc655bcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137577.698486, idle connection 76527.000000, request 304999.425173
11/09/2026 04:21:24.178 7fcfc655ba40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 139845.725586, idle connection 255798.000000, request 304398.702860
11/09/2026 04:21:24.179 7fcfc655ba40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 5663
11/09/2026 04:21:24.179 7fcfc655ba40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:24.179 7fcfc655ba40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 5663 (602.1900177001953 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=874175226, topics=[])
11/09/2026 04:21:24.179 7fcfc655ba40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 874175226 with 0 response partitions (1 implied)
11/09/2026 04:21:24.222 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137547.709717, idle connection 76281.000000, request 304398.802519
11/09/2026 04:21:24.223 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9080
11/09/2026 04:21:24.223 7fcfc655b540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:24.223 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 9080 (601.9079685211182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2051684790, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=11584, last_stable_offset=11584, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00-?\x00\x00\x00\xff\x00\x00\x00\x00\x02\x8bm\xc8\x7f\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\x98\x03\x00\x00\x00\xda\x02ObjectDatabaseInfo:cn-jenkins-de...')])])
11/09/2026 04:21:24.223 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2051684790 with 1 response partitions (0 implied)
11/09/2026 04:21:24.223 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 267 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 11583
11/09/2026 04:21:24.223 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 11583 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
11/09/2026 04:21:24.224 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 11584 (leader epoch 0)
11/09/2026 04:21:24.303 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 232
11/09/2026 04:21:24.304 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
11/09/2026 04:21:24.304 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc608c790> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
11/09/2026 04:21:24.304 7fcfc655bb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:24.304 7fcfc655bb80 [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=1149908902, session_epoch=5652, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:24.304 7fcfc655bb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 5665 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1149908902, session_epoch=5652, topics=[], forgotten_topics_data=[])
11/09/2026 04:21:24.304 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140464.844482, idle connection 78120.000000, request 304999.936342
11/09/2026 04:21:24.305 7fcfc655bb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 140464.317627, idle connection 78119.000000, request 304999.418020
11/09/2026 04:21:24.324 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 11584
11/09/2026 04:21:24.324 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
11/09/2026 04:21:24.324 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcfc6963d00> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
11/09/2026 04:21:24.325 7fcfc655b540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
11/09/2026 04:21:24.325 7fcfc655b540 [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=2051684790, session_epoch=9073, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=11584, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:24.325 7fcfc655b540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 9081 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2051684790, session_epoch=9073, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=11584, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/09/2026 04:21:24.325 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137444.783691, idle connection 76178.000000, request 304999.943256
11/09/2026 04:21:24.325 7fcfc655b540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137444.326660, idle connection 76178.000000, request 304999.492168
11/09/2026 04:21:24.356 7fcfc655be00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 142528.983887, idle connection 80824.000000, request 304398.875237
11/09/2026 04:21:24.356 7fcfc655be00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6120
11/09/2026 04:21:24.356 7fcfc655be00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/09/2026 04:21:24.356 7fcfc655be00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.249:9092 <connected> [IPv4 ('10.0.0.249', 9092)]>: Response 6120 (601.7715930938721 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1537108334, topics=[])
11/09/2026 04:21:24.357 7fcfc655be00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1537108334 with 0 response partitions (1 implied)