11/17/2025 02:06:17.067 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205903.217285, idle connection 144984.000000, request 304999.963522
11/17/2025 02:06:17.068 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205973.362549, idle connection 145283.000000, request 304998.600721
11/17/2025 02:06:17.068 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206780.416504, idle connection 145244.000000, request 304395.885944
11/17/2025 02:06:17.069 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205889.851562, idle connection 145227.000000, request 304398.308516
11/17/2025 02:06:17.069 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205901.938721, idle connection 144983.000000, request 304998.688698
11/17/2025 02:06:17.069 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 337
11/17/2025 02:06:17.069 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.069 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 337 (604.9444675445557 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=872837317, topics=[])
11/17/2025 02:06:17.069 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 872837317 with 0 response partitions (1 implied)
11/17/2025 02:06:17.070 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342
11/17/2025 02:06:17.070 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.070 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 342 (602.8733253479004 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=593215620, topics=[])
11/17/2025 02:06:17.070 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 593215620 with 0 response partitions (1 implied)
11/17/2025 02:06:17.072 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206045.175781, idle connection 144860.000000, request 304399.336815
11/17/2025 02:06:17.072 7fda680cf2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329
11/17/2025 02:06:17.072 7fda680cf2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.072 7fda680cf2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 329 (600.9719371795654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=856417271, topics=[])
11/17/2025 02:06:17.072 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 856417271 with 0 response partitions (1 implied)
11/17/2025 02:06:17.074 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6
11/17/2025 02:06:17.074 7fda680cf4a0 [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/17/2025 02:06:17.074 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678c41f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
11/17/2025 02:06:17.074 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.074 7fda680cf4a0 [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=1601534485, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.074 7fda680cf4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1601534485, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.074 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206743.365479, idle connection 144898.000000, request 304999.943495
11/17/2025 02:06:17.075 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206742.966309, idle connection 144897.000000, request 304999.550581
11/17/2025 02:06:17.096 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 64
11/17/2025 02:06:17.097 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
11/17/2025 02:06:17.097 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678bf0d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
11/17/2025 02:06:17.097 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.097 7fda6727a720 [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=1725449652, session_epoch=344, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.097 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 347 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725449652, session_epoch=344, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.097 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206876.098877, idle connection 145116.000000, request 304999.948263
11/17/2025 02:06:17.097 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206875.664551, idle connection 145116.000000, request 304999.518871
11/17/2025 02:06:17.103 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206017.219727, idle connection 144846.000000, request 304398.050070
11/17/2025 02:06:17.103 7fda680cf0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329
11/17/2025 02:06:17.103 7fda680cf0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.103 7fda680cf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 329 (602.4165153503418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1080123118, topics=[])
11/17/2025 02:06:17.103 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1080123118 with 0 response partitions (1 implied)
11/17/2025 02:06:17.104 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205849.737061, idle connection 144973.000000, request 304397.969007
11/17/2025 02:06:17.104 7fda66c8e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332
11/17/2025 02:06:17.104 7fda66c8e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.104 7fda66c8e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 332 (602.3366451263428 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=120351257, topics=[])
11/17/2025 02:06:17.104 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 120351257 with 0 response partitions (1 implied)
11/17/2025 02:06:17.176 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206457.894531, idle connection 144727.000000, request 304398.894548
11/17/2025 02:06:17.176 7fda66e6df40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344
11/17/2025 02:06:17.176 7fda66e6df40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.176 7fda66e6df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 344 (601.6626358032227 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=640373379, topics=[])
11/17/2025 02:06:17.176 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 640373379 with 0 response partitions (1 implied)
11/17/2025 02:06:17.231 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206597.206787, idle connection 145254.000000, request 304398.879766
11/17/2025 02:06:17.231 7fda6940e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 363
11/17/2025 02:06:17.231 7fda6940e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.231 7fda6940e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 363 (601.6733646392822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1105040017, topics=[])
11/17/2025 02:06:17.232 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1105040017 with 0 response partitions (1 implied)
11/17/2025 02:06:17.257 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205771.056885, idle connection 145069.000000, request 304398.936749
11/17/2025 02:06:17.257 7fda680cfa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 348
11/17/2025 02:06:17.257 7fda680cfa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.257 7fda680cfa40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 348 (601.5915870666504 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1505373662, topics=[])
11/17/2025 02:06:17.257 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1505373662 with 0 response partitions (1 implied)
11/17/2025 02:06:17.257 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 210
11/17/2025 02:06:17.257 7fda6940e540 [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/17/2025 02:06:17.258 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678bbb20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
11/17/2025 02:06:17.258 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.258 7fda6940e540 [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=331337579, session_epoch=356, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.258 7fda6940e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 359 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=331337579, session_epoch=356, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.258 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205990.582031, idle connection 145178.000000, request 304999.957085
11/17/2025 02:06:17.258 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205990.167725, idle connection 145178.000000, request 304999.546528
11/17/2025 02:06:17.276 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206212.156250, idle connection 145196.000000, request 304398.976803
11/17/2025 02:06:17.276 7fda6940e860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361
11/17/2025 02:06:17.276 7fda6940e860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.276 7fda6940e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 361 (601.550817489624 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559399502, topics=[])
11/17/2025 02:06:17.276 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559399502 with 0 response partitions (1 implied)
11/17/2025 02:06:17.361 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206164.876709, idle connection 145162.000000, request 304398.956299
11/17/2025 02:06:17.361 7fda6940ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 356
11/17/2025 02:06:17.361 7fda6940ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.361 7fda6940ed60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 356 (601.7477512359619 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1453829896, topics=[])
11/17/2025 02:06:17.361 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1453829896 with 0 response partitions (1 implied)
11/17/2025 02:06:17.367 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
11/17/2025 02:06:17.368 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
11/17/2025 02:06:17.368 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f0640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
11/17/2025 02:06:17.368 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.368 7fda66e6db80 [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=411999081, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.368 7fda66e6db80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=411999081, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.368 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205450.398926, idle connection 144524.000000, request 304999.922991
11/17/2025 02:06:17.369 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 146
11/17/2025 02:06:17.369 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
11/17/2025 02:06:17.369 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785a2e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
11/17/2025 02:06:17.369 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.369 7fda6940e2c0 [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=1991185903, session_epoch=351, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.369 7fda6940e2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 354 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1991185903, session_epoch=351, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.369 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206177.613037, idle connection 145017.000000, request 304999.938488
11/17/2025 02:06:17.370 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205448.692383, idle connection 144522.000000, request 304998.226643
11/17/2025 02:06:17.370 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205938.044922, idle connection 144753.000000, request 304397.442818
11/17/2025 02:06:17.371 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206001.835693, idle connection 144809.000000, request 304398.359537
11/17/2025 02:06:17.371 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206176.139893, idle connection 145015.000000, request 304998.473167
11/17/2025 02:06:17.371 7fda6725b680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329
11/17/2025 02:06:17.372 7fda6725b680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.372 7fda6725b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 329 (603.8174629211426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=746145502, topics=[])
11/17/2025 02:06:17.372 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 746145502 with 0 response partitions (1 implied)
11/17/2025 02:06:17.372 7fda6727acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341
11/17/2025 02:06:17.372 7fda6727acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.372 7fda6727acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 341 (603.4631729125977 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1151354221, topics=[])
11/17/2025 02:06:17.373 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1151354221 with 0 response partitions (1 implied)
11/17/2025 02:06:17.407 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 32
11/17/2025 02:06:17.408 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
11/17/2025 02:06:17.408 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f4bb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
11/17/2025 02:06:17.408 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.408 7fda680cfe00 [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=411690286, session_epoch=332, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.408 7fda680cfe00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 335 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=411690286, session_epoch=332, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.408 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205506.756592, idle connection 144872.000000, request 304999.926567
11/17/2025 02:06:17.409 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 39
11/17/2025 02:06:17.409 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
11/17/2025 02:06:17.409 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678ec640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
11/17/2025 02:06:17.409 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.409 7fda680cf680 [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=1453043869, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.409 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1453043869, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.409 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205527.458008, idle connection 144818.000000, request 304999.946833
11/17/2025 02:06:17.410 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205505.227783, idle connection 144870.000000, request 304998.408318
11/17/2025 02:06:17.410 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205526.539062, idle connection 144817.000000, request 304999.034405
11/17/2025 02:06:17.415 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 31
11/17/2025 02:06:17.415 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
11/17/2025 02:06:17.415 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda679969d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
11/17/2025 02:06:17.415 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.415 7fda680cfcc0 [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=203108210, session_epoch=335, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.416 7fda680cfcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=203108210, session_epoch=335, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.416 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205945.088379, idle connection 144848.000000, request 304999.936819
11/17/2025 02:06:17.416 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205894.778076, idle connection 144724.000000, request 304396.497488
11/17/2025 02:06:17.416 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206532.121338, idle connection 144831.000000, request 304396.972895
11/17/2025 02:06:17.417 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205944.111328, idle connection 144847.000000, request 304998.967171
11/17/2025 02:06:17.417 7fda66bad0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329
11/17/2025 02:06:17.417 7fda66bad0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.417 7fda66bad0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 329 (604.7019958496094 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=834020125, topics=[])
11/17/2025 02:06:17.417 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 834020125 with 0 response partitions (1 implied)
11/17/2025 02:06:17.418 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338
11/17/2025 02:06:17.418 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.418 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 338 (604.8247814178467 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927368660, topics=[])
11/17/2025 02:06:17.418 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927368660 with 0 response partitions (1 implied)
11/17/2025 02:06:17.461 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206614.008301, idle connection 144953.000000, request 304398.234844
11/17/2025 02:06:17.461 7fda6940e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 360
11/17/2025 02:06:17.461 7fda6940e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.461 7fda6940e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 360 (602.4386882781982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=154805069, topics=[])
11/17/2025 02:06:17.462 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 154805069 with 0 response partitions (1 implied)
11/17/2025 02:06:17.488 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205321.245361, idle connection 144626.000000, request 304396.898985
11/17/2025 02:06:17.488 7fda66c8e0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
11/17/2025 02:06:17.488 7fda66c8e0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.488 7fda66c8e0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 330 (603.7905216217041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426841805, topics=[])
11/17/2025 02:06:17.488 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426841805 with 0 response partitions (1 implied)
11/17/2025 02:06:17.489 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206112.120117, idle connection 144881.000000, request 304396.605492
11/17/2025 02:06:17.489 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206342.080811, idle connection 144999.000000, request 304397.195339
11/17/2025 02:06:17.489 7fda6940e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 349
11/17/2025 02:06:17.489 7fda6940e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.489 7fda6940e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 349 (603.8424968719482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1642745414, topics=[])
11/17/2025 02:06:17.489 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1642745414 with 0 response partitions (1 implied)
11/17/2025 02:06:17.489 7fda6940e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 355
11/17/2025 02:06:17.489 7fda6940e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.490 7fda6940e7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 355 (603.5637855529785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050535284, topics=[])
11/17/2025 02:06:17.490 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1050535284 with 0 response partitions (1 implied)
11/17/2025 02:06:17.560 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4
11/17/2025 02:06:17.560 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
11/17/2025 02:06:17.560 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cb20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
11/17/2025 02:06:17.560 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.560 7fda66c8e680 [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=2042266674, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.560 7fda66c8e680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2042266674, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.560 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205381.697998, idle connection 144509.000000, request 304999.943495
11/17/2025 02:06:17.561 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205381.084229, idle connection 144509.000000, request 304999.336004
11/17/2025 02:06:17.638 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205239.304199, idle connection 144271.000000, request 304398.787737
11/17/2025 02:06:17.638 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 496
11/17/2025 02:06:17.639 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.639 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 496 (601.8517017364502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182050876, topics=[])
11/17/2025 02:06:17.639 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182050876 with 0 response partitions (1 implied)
11/17/2025 02:06:17.669 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205372.139404, idle connection 144682.000000, request 304397.361517
11/17/2025 02:06:17.670 7fda6940e040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357
11/17/2025 02:06:17.670 7fda6940e040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.670 7fda6940e040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 357 (603.4538745880127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1166507884, topics=[])
11/17/2025 02:06:17.670 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1166507884 with 0 response partitions (1 implied)
11/17/2025 02:06:17.671 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 37
11/17/2025 02:06:17.671 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
11/17/2025 02:06:17.671 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67964520> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
11/17/2025 02:06:17.671 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.671 7fda680cf720 [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=872837317, session_epoch=335, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.671 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=872837317, session_epoch=335, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.672 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206177.171631, idle connection 144641.000000, request 304999.945641
11/17/2025 02:06:17.672 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 45
11/17/2025 02:06:17.672 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
11/17/2025 02:06:17.672 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67903a30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
11/17/2025 02:06:17.672 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.672 7fda680cfb80 [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=593215620, session_epoch=340, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.672 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 343 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=593215620, session_epoch=340, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.672 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205285.956055, idle connection 144623.000000, request 304999.955177
11/17/2025 02:06:17.673 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205298.069824, idle connection 144379.000000, request 304394.816875
11/17/2025 02:06:17.673 7fda66c8e9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332
11/17/2025 02:06:17.673 7fda66c8e9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.673 7fda66c8e9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 332 (605.736494064331 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817443853, topics=[])
11/17/2025 02:06:17.673 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1817443853 with 0 response partitions (1 implied)
11/17/2025 02:06:17.674 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
11/17/2025 02:06:17.674 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
11/17/2025 02:06:17.674 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
11/17/2025 02:06:17.674 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.674 7fda680cf2c0 [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=856417271, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.674 7fda680cf2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=856417271, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.674 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205442.707275, idle connection 144258.000000, request 304999.947786
11/17/2025 02:06:17.675 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206173.756836, idle connection 144637.000000, request 304996.534824
11/17/2025 02:06:17.675 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205282.878662, idle connection 144620.000000, request 304996.881247
11/17/2025 02:06:17.676 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206141.802979, idle connection 144296.000000, request 304398.382902
11/17/2025 02:06:17.676 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205440.947510, idle connection 144256.000000, request 304998.189688
11/17/2025 02:06:17.677 7fda680cf4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332
11/17/2025 02:06:17.677 7fda680cf4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.677 7fda680cf4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 332 (602.7224063873291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1601534485, topics=[])
11/17/2025 02:06:17.677 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1601534485 with 0 response partitions (1 implied)
11/17/2025 02:06:17.698 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206275.094482, idle connection 144515.000000, request 304398.940802
11/17/2025 02:06:17.699 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 347
11/17/2025 02:06:17.699 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.699 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 347 (601.76682472229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725449652, topics=[])
11/17/2025 02:06:17.699 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725449652 with 0 response partitions (1 implied)
11/17/2025 02:06:17.704 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
11/17/2025 02:06:17.705 7fda680cf0e0 [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/17/2025 02:06:17.705 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c940> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/17/2025 02:06:17.705 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.705 7fda680cf0e0 [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=1080123118, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.705 7fda680cf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1080123118, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.705 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205414.936768, idle connection 144244.000000, request 304999.944925
11/17/2025 02:06:17.705 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 6
11/17/2025 02:06:17.705 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
11/17/2025 02:06:17.705 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678bfeb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
11/17/2025 02:06:17.706 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.706 7fda66c8e540 [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=120351257, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.706 7fda66c8e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=120351257, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.706 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205247.538330, idle connection 144371.000000, request 304999.963284
11/17/2025 02:06:17.706 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205413.730469, idle connection 144243.000000, request 304998.747587
11/17/2025 02:06:17.707 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205246.741699, idle connection 144370.000000, request 304999.170065
11/17/2025 02:06:17.777 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 69
11/17/2025 02:06:17.777 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
11/17/2025 02:06:17.777 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6787a3d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
11/17/2025 02:06:17.777 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.777 7fda66e6df40 [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=640373379, session_epoch=342, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.777 7fda66e6df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 345 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=640373379, session_epoch=342, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.778 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205856.077393, idle connection 144125.000000, request 304999.944448
11/17/2025 02:06:17.778 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205855.453369, idle connection 144124.000000, request 304999.322891
11/17/2025 02:06:17.832 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 316
11/17/2025 02:06:17.832 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
11/17/2025 02:06:17.833 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c580> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
11/17/2025 02:06:17.833 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.833 7fda6940e5e0 [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=1105040017, session_epoch=361, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.833 7fda6940e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1105040017, session_epoch=361, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.833 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205994.761230, idle connection 144651.000000, request 304999.903202
11/17/2025 02:06:17.834 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205994.003662, idle connection 144651.000000, request 304999.158144
11/17/2025 02:06:17.858 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 136
11/17/2025 02:06:17.858 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
11/17/2025 02:06:17.858 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785a640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
11/17/2025 02:06:17.858 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.858 7fda680cfa40 [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=1505373662, session_epoch=346, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.858 7fda680cfa40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1505373662, session_epoch=346, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.858 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205169.116943, idle connection 144467.000000, request 304999.940395
11/17/2025 02:06:17.859 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205389.738037, idle connection 144577.000000, request 304399.113417
11/17/2025 02:06:17.859 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205168.222412, idle connection 144466.000000, request 304999.053955
11/17/2025 02:06:17.860 7fda6940e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 359
11/17/2025 02:06:17.860 7fda6940e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.860 7fda6940e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 359 (601.9577980041504 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=331337579, topics=[])
11/17/2025 02:06:17.860 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 331337579 with 0 response partitions (1 implied)
11/17/2025 02:06:17.877 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 210
11/17/2025 02:06:17.877 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
11/17/2025 02:06:17.877 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785aaf0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
11/17/2025 02:06:17.877 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.877 7fda6940e860 [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=559399502, session_epoch=359, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.877 7fda6940e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 362 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559399502, session_epoch=359, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.878 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205610.327637, idle connection 144594.000000, request 304999.946594
11/17/2025 02:06:17.878 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205609.854980, idle connection 144594.000000, request 304999.481440
11/17/2025 02:06:17.962 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 190
11/17/2025 02:06:17.962 7fda6940ed60 [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/17/2025 02:06:17.962 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cb50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
11/17/2025 02:06:17.962 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.963 7fda6940ed60 [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=1453829896, session_epoch=354, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.963 7fda6940ed60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1453829896, session_epoch=354, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.963 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205562.423340, idle connection 144559.000000, request 304999.913931
11/17/2025 02:06:17.964 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205561.898193, idle connection 144559.000000, request 304999.407053
11/17/2025 02:06:17.972 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204846.372803, idle connection 143920.000000, request 304395.899057
11/17/2025 02:06:17.973 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
11/17/2025 02:06:17.973 7fda6725b680 [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/17/2025 02:06:17.973 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67927a00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
11/17/2025 02:06:17.973 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.973 7fda6725b680 [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=746145502, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.973 7fda6725b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=746145502, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.974 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205334.791992, idle connection 144150.000000, request 304999.942064
11/17/2025 02:06:17.974 7fda66e6db80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
11/17/2025 02:06:17.974 7fda66e6db80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.974 7fda66e6db80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 330 (605.8847904205322 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=411999081, topics=[])
11/17/2025 02:06:17.974 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 411999081 with 0 response partitions (1 implied)
11/17/2025 02:06:17.975 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 40
11/17/2025 02:06:17.975 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
11/17/2025 02:06:17.975 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678bbfd0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
11/17/2025 02:06:17.975 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:17.975 7fda6727acc0 [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=1151354221, session_epoch=339, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.975 7fda6727acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1151354221, session_epoch=339, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:17.975 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205396.947754, idle connection 144204.000000, request 304999.942303
11/17/2025 02:06:17.976 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205571.291016, idle connection 144411.000000, request 304393.621922
11/17/2025 02:06:17.976 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205332.010254, idle connection 144147.000000, request 304997.163773
11/17/2025 02:06:17.977 7fda6940e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 354
11/17/2025 02:06:17.977 7fda6940e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:17.977 7fda6940e2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 354 (607.4726581573486 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1991185903, topics=[])
11/17/2025 02:06:17.977 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1991185903 with 0 response partitions (1 implied)
11/17/2025 02:06:17.978 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205394.854492, idle connection 144202.000000, request 304997.856379
11/17/2025 02:06:18.011 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204903.933105, idle connection 144269.000000, request 304397.101402
11/17/2025 02:06:18.012 7fda680cfe00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 335
11/17/2025 02:06:18.012 7fda680cfe00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.012 7fda680cfe00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 335 (603.623628616333 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=411690286, topics=[])
11/17/2025 02:06:18.012 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 411690286 with 0 response partitions (1 implied)
11/17/2025 02:06:18.013 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204924.436279, idle connection 144215.000000, request 304396.929264
11/17/2025 02:06:18.013 7fda680cf680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339
11/17/2025 02:06:18.013 7fda680cf680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.013 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 339 (603.4400463104248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1453043869, topics=[])
11/17/2025 02:06:18.013 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1453043869 with 0 response partitions (1 implied)
11/17/2025 02:06:18.018 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
11/17/2025 02:06:18.019 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
11/17/2025 02:06:18.019 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678ec490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
11/17/2025 02:06:18.019 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.019 7fda66bad0e0 [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=834020125, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.019 7fda66bad0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=834020125, session_epoch=327, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.019 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205291.693359, idle connection 144121.000000, request 304999.943972
11/17/2025 02:06:18.020 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205291.182617, idle connection 144121.000000, request 304999.439955
11/17/2025 02:06:18.020 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34
11/17/2025 02:06:18.020 7fda680cf5e0 [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/17/2025 02:06:18.020 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6787a8b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
11/17/2025 02:06:18.020 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.020 7fda680cf5e0 [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=1927368660, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.020 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1927368660, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.021 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205927.882080, idle connection 144227.000000, request 304999.956131
11/17/2025 02:06:18.021 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205340.069824, idle connection 144243.000000, request 304394.922733
11/17/2025 02:06:18.021 7fda680cfcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338
11/17/2025 02:06:18.021 7fda680cfcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.021 7fda680cfcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 338 (605.5881977081299 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=203108210, topics=[])
11/17/2025 02:06:18.021 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 203108210 with 0 response partitions (1 implied)
11/17/2025 02:06:18.022 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205926.623291, idle connection 144226.000000, request 304998.702049
11/17/2025 02:06:18.062 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 180
11/17/2025 02:06:18.062 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
11/17/2025 02:06:18.062 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678e4880> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
11/17/2025 02:06:18.062 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.063 7fda6940e720 [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=154805069, session_epoch=358, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.063 7fda6940e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 361 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=154805069, session_epoch=358, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.063 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206011.611328, idle connection 144350.000000, request 304999.902725
11/17/2025 02:06:18.064 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206010.973389, idle connection 144350.000000, request 304999.273300
11/17/2025 02:06:18.089 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
11/17/2025 02:06:18.089 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
11/17/2025 02:06:18.089 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785a490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
11/17/2025 02:06:18.089 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.090 7fda66c8e0e0 [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=426841805, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.090 7fda66c8e0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426841805, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.090 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204718.667725, idle connection 144023.000000, request 304999.931097
11/17/2025 02:06:18.092 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 147
11/17/2025 02:06:18.092 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
11/17/2025 02:06:18.092 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6787a040> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
11/17/2025 02:06:18.093 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.093 7fda6940e400 [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=1642745414, session_epoch=347, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.093 7fda6940e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1642745414, session_epoch=347, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.093 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205507.651367, idle connection 144277.000000, request 304999.934673
11/17/2025 02:06:18.093 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 201
11/17/2025 02:06:18.093 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
11/17/2025 02:06:18.093 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f7a60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
11/17/2025 02:06:18.094 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.094 7fda6940e7c0 [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=1050535284, session_epoch=353, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.094 7fda6940e7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050535284, session_epoch=353, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.095 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205736.332764, idle connection 144394.000000, request 304999.329090
11/17/2025 02:06:18.095 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204713.436768, idle connection 144018.000000, request 304994.708300
11/17/2025 02:06:18.097 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205504.034912, idle connection 144273.000000, request 304996.328115
11/17/2025 02:06:18.097 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205733.597900, idle connection 144391.000000, request 304996.604443
11/17/2025 02:06:18.162 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204780.468018, idle connection 143908.000000, request 304398.708582
11/17/2025 02:06:18.162 7fda66c8e680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333
11/17/2025 02:06:18.162 7fda66c8e680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.162 7fda66c8e680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 333 (601.9256114959717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2042266674, topics=[])
11/17/2025 02:06:18.162 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2042266674 with 0 response partitions (1 implied)
11/17/2025 02:06:18.240 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4056
11/17/2025 02:06:18.241 7fda66e6dea0 [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/17/2025 02:06:18.241 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678c4100> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
11/17/2025 02:06:18.241 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.241 7fda66e6dea0 [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=182050876, session_epoch=494, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.241 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 497 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182050876, session_epoch=494, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.241 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204636.132812, idle connection 143667.000000, request 304999.937773
11/17/2025 02:06:18.242 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204635.619873, idle connection 143667.000000, request 304999.434471
11/17/2025 02:06:18.271 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 161
11/17/2025 02:06:18.271 7fda6940e040 [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/17/2025 02:06:18.271 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678a8e80> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
11/17/2025 02:06:18.271 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.271 7fda6940e040 [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=1166507884, session_epoch=355, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.272 7fda6940e040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1166507884, session_epoch=355, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.272 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204769.559326, idle connection 144079.000000, request 304999.931335
11/17/2025 02:06:18.273 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204768.910156, idle connection 144078.000000, request 304999.292612
11/17/2025 02:06:18.274 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 7
11/17/2025 02:06:18.274 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
11/17/2025 02:06:18.274 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6787aa00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
11/17/2025 02:06:18.274 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.274 7fda66c8e9a0 [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=1817443853, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.274 7fda66c8e9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817443853, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.274 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204696.219238, idle connection 143777.000000, request 304999.957085
11/17/2025 02:06:18.275 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204695.886963, idle connection 143776.000000, request 304999.627590
11/17/2025 02:06:18.277 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205572.176758, idle connection 144036.000000, request 304394.953728
11/17/2025 02:06:18.277 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338
11/17/2025 02:06:18.277 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.277 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 338 (605.4503917694092 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=872837317, topics=[])
11/17/2025 02:06:18.277 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 872837317 with 0 response partitions (1 implied)
11/17/2025 02:06:18.277 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204680.906006, idle connection 144018.000000, request 304394.908667
11/17/2025 02:06:18.278 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 343
11/17/2025 02:06:18.278 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.278 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 343 (605.5088043212891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=593215620, topics=[(topics='-uve-topic-18', partitions=[(partition=0, error_code=0, highwater_offset=46, last_stable_offset=46, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00-\x00\x00\x01\x83\x00\x00\x00\x00\x02\xa3V\xf9\xac\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\xa0\x05\x00\x00\x00\xe2\x04ObjectVMITable:default-domain:te...')])])
11/17/2025 02:06:18.278 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 593215620 with 1 response partitions (0 implied)
11/17/2025 02:06:18.278 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 399 bytes of data for partition TopicPartition(topic='-uve-topic-18', partition=0) with offset 45
11/17/2025 02:06:18.278 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 45 for assigned partition TopicPartition(topic='-uve-topic-18', partition=0)
11/17/2025 02:06:18.279 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-18', partition=0) to 46 (leader epoch 0)
11/17/2025 02:06:18.279 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6
11/17/2025 02:06:18.279 7fda680cf4a0 [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/17/2025 02:06:18.279 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f7370> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
11/17/2025 02:06:18.279 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.279 7fda680cf4a0 [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=1601534485, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.279 7fda680cf4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1601534485, session_epoch=330, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.279 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205538.209717, idle connection 143693.000000, request 304999.942303
11/17/2025 02:06:18.280 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204837.498535, idle connection 143653.000000, request 304394.742250
11/17/2025 02:06:18.280 7fda680cf2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
11/17/2025 02:06:18.280 7fda680cf2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.280 7fda680cf2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 330 (605.5748462677002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=856417271, topics=[])
11/17/2025 02:06:18.280 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 856417271 with 0 response partitions (1 implied)
11/17/2025 02:06:18.280 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205537.188232, idle connection 143692.000000, request 304998.929501
11/17/2025 02:06:18.299 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 64
11/17/2025 02:06:18.300 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
11/17/2025 02:06:18.300 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678c4520> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
11/17/2025 02:06:18.300 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.300 7fda6727a720 [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=1725449652, session_epoch=345, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.300 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 348 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725449652, session_epoch=345, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.300 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205672.918945, idle connection 143913.000000, request 304999.942303
11/17/2025 02:06:18.301 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205672.425537, idle connection 143913.000000, request 304999.453306
11/17/2025 02:06:18.307 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204812.916992, idle connection 143642.000000, request 304397.922993
11/17/2025 02:06:18.307 7fda680cf0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
11/17/2025 02:06:18.308 7fda680cf0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.308 7fda680cf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 330 (602.5891304016113 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1080123118, topics=[])
11/17/2025 02:06:18.308 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1080123118 with 0 response partitions (1 implied)
11/17/2025 02:06:18.308 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204645.346191, idle connection 143769.000000, request 304397.768736
11/17/2025 02:06:18.308 7fda66c8e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333
11/17/2025 02:06:18.308 7fda66c8e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.308 7fda66c8e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 333 (602.6408672332764 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=120351257, topics=[])
11/17/2025 02:06:18.309 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 120351257 with 0 response partitions (1 implied)
11/17/2025 02:06:18.379 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205254.774170, idle connection 143524.000000, request 304398.638487
11/17/2025 02:06:18.379 7fda66e6df40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345
11/17/2025 02:06:18.379 7fda66e6df40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.380 7fda66e6df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 345 (602.0083427429199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=640373379, topics=[])
11/17/2025 02:06:18.380 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 640373379 with 0 response partitions (1 implied)
11/17/2025 02:06:18.380 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 46
11/17/2025 02:06:18.380 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
11/17/2025 02:06:18.380 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785be20> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-18', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
11/17/2025 02:06:18.380 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.380 7fda680cfb80 [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=593215620, session_epoch=341, topics=[(topic='-uve-topic-18', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=46, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:18.381 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 344 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=593215620, session_epoch=341, topics=[(topic='-uve-topic-18', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=46, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:18.381 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204577.595215, idle connection 143914.000000, request 304999.950647
11/17/2025 02:06:18.381 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204577.130859, idle connection 143914.000000, request 304999.490976
11/17/2025 02:06:18.435 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205393.284668, idle connection 144050.000000, request 304398.434162
11/17/2025 02:06:18.435 7fda6940e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 364
11/17/2025 02:06:18.435 7fda6940e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.435 7fda6940e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 364 (602.1687984466553 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1105040017, topics=[])
11/17/2025 02:06:18.436 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1105040017 with 0 response partitions (1 implied)
11/17/2025 02:06:18.460 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 210
11/17/2025 02:06:18.461 7fda6940e540 [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/17/2025 02:06:18.461 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785a820> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
11/17/2025 02:06:18.461 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.461 7fda6940e540 [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=331337579, session_epoch=357, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.461 7fda6940e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 360 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=331337579, session_epoch=357, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.461 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204787.343506, idle connection 143975.000000, request 304999.947071
11/17/2025 02:06:18.461 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204566.142822, idle connection 143864.000000, request 304396.971941
11/17/2025 02:06:18.462 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204786.714111, idle connection 143974.000000, request 304999.326229
11/17/2025 02:06:18.462 7fda680cfa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 349
11/17/2025 02:06:18.462 7fda680cfa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.462 7fda680cfa40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 349 (603.7847995758057 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1505373662, topics=[])
11/17/2025 02:06:18.462 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1505373662 with 0 response partitions (1 implied)
11/17/2025 02:06:18.479 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205009.346680, idle connection 143993.000000, request 304398.963690
11/17/2025 02:06:18.479 7fda6940e860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362
11/17/2025 02:06:18.479 7fda6940e860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.479 7fda6940e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 362 (601.6242504119873 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559399502, topics=[])
11/17/2025 02:06:18.479 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559399502 with 0 response partitions (1 implied)
11/17/2025 02:06:18.564 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204961.214111, idle connection 143958.000000, request 304398.714781
11/17/2025 02:06:18.565 7fda6940ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357
11/17/2025 02:06:18.565 7fda6940ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.565 7fda6940ed60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 357 (601.8822193145752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1453829896, topics=[])
11/17/2025 02:06:18.565 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1453829896 with 0 response partitions (1 implied)
11/17/2025 02:06:18.575 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
11/17/2025 02:06:18.575 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
11/17/2025 02:06:18.575 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c0d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
11/17/2025 02:06:18.575 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.575 7fda66e6db80 [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=411999081, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.575 7fda66e6db80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=411999081, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.576 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204243.197998, idle connection 143317.000000, request 304999.945164
11/17/2025 02:06:18.576 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204242.635010, idle connection 143316.000000, request 304999.386787
11/17/2025 02:06:18.577 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 146
11/17/2025 02:06:18.578 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
11/17/2025 02:06:18.578 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785ad90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
11/17/2025 02:06:18.578 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.578 7fda6940e2c0 [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=1991185903, session_epoch=352, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.578 7fda6940e2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1991185903, session_epoch=352, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.578 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204968.953125, idle connection 143808.000000, request 304999.956608
11/17/2025 02:06:18.578 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204730.046875, idle connection 143545.000000, request 304395.203352
11/17/2025 02:06:18.578 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204793.923828, idle connection 143601.000000, request 304396.926403
11/17/2025 02:06:18.579 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204968.293457, idle connection 143808.000000, request 304999.300718
11/17/2025 02:06:18.579 7fda6725b680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
11/17/2025 02:06:18.579 7fda6725b680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.579 7fda6725b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 330 (605.6258678436279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=746145502, topics=[])
11/17/2025 02:06:18.579 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 746145502 with 0 response partitions (1 implied)
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 342 (604.2706966400146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1151354221, topics=[(topics='-uve-topic-12', partitions=[(partition=0, error_code=0, highwater_offset=41, last_stable_offset=41, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00(\x00\x00\x01\x84\x00\x00\x00\x00\x02\xef\r\x96\xed\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\x05\x00\x00\x00\xe4\x04ObjectVMITable:default-domain:te...')])])
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1151354221 with 1 response partitions (0 implied)
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 400 bytes of data for partition TopicPartition(topic='-uve-topic-12', partition=0) with offset 40
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 40 for assigned partition TopicPartition(topic='-uve-topic-12', partition=0)
11/17/2025 02:06:18.580 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-12', partition=0) to 41 (leader epoch 0)
11/17/2025 02:06:18.613 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 32
11/17/2025 02:06:18.613 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
11/17/2025 02:06:18.613 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c970> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
11/17/2025 02:06:18.613 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.613 7fda680cfe00 [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=411690286, session_epoch=333, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.613 7fda680cfe00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 336 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=411690286, session_epoch=333, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.613 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204301.717041, idle connection 143667.000000, request 304999.944687
11/17/2025 02:06:18.614 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 39
11/17/2025 02:06:18.614 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
11/17/2025 02:06:18.614 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f7760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
11/17/2025 02:06:18.614 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.614 7fda680cf680 [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=1453043869, session_epoch=337, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.614 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1453043869, session_epoch=337, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.614 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204322.640137, idle connection 143613.000000, request 304999.959230
11/17/2025 02:06:18.615 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204300.519287, idle connection 143665.000000, request 304998.756170
11/17/2025 02:06:18.615 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204321.945801, idle connection 143613.000000, request 304999.271154
11/17/2025 02:06:18.621 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204689.573730, idle connection 143519.000000, request 304397.827864
11/17/2025 02:06:18.622 7fda66bad0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
11/17/2025 02:06:18.622 7fda66bad0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.622 7fda66bad0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 330 (602.6482582092285 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=834020125, topics=[])
11/17/2025 02:06:18.622 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 834020125 with 0 response partitions (1 implied)
11/17/2025 02:06:18.622 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 31
11/17/2025 02:06:18.622 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
11/17/2025 02:06:18.622 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f4bb0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
11/17/2025 02:06:18.622 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.623 7fda680cfcc0 [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=203108210, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.623 7fda680cfcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=203108210, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.623 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204738.032959, idle connection 143641.000000, request 304999.957800
11/17/2025 02:06:18.623 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205325.442139, idle connection 143625.000000, request 304397.520304
11/17/2025 02:06:18.623 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339
11/17/2025 02:06:18.623 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.623 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 339 (602.9164791107178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927368660, topics=[])
11/17/2025 02:06:18.624 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927368660 with 0 response partitions (1 implied)
11/17/2025 02:06:18.624 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204736.887695, idle connection 143640.000000, request 304998.816490
11/17/2025 02:06:18.665 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205410.083740, idle connection 143749.000000, request 304398.380995
11/17/2025 02:06:18.665 7fda6940e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361
11/17/2025 02:06:18.665 7fda6940e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.665 7fda6940e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 361 (602.2181510925293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=154805069, topics=[])
11/17/2025 02:06:18.665 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 154805069 with 0 response partitions (1 implied)
11/17/2025 02:06:18.681 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 41
11/17/2025 02:06:18.681 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
11/17/2025 02:06:18.681 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785a670> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-12', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
11/17/2025 02:06:18.681 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.681 7fda6727acc0 [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=1151354221, session_epoch=340, topics=[(topic='-uve-topic-12', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=41, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:18.681 7fda6727acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 343 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1151354221, session_epoch=340, topics=[(topic='-uve-topic-12', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=41, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:18.682 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204690.821777, idle connection 143498.000000, request 304999.942303
11/17/2025 02:06:18.682 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204690.323242, idle connection 143498.000000, request 304999.450922
11/17/2025 02:06:18.698 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204110.948975, idle connection 143415.000000, request 304392.216682
11/17/2025 02:06:18.698 7fda66c8e0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331
11/17/2025 02:06:18.698 7fda66c8e0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.698 7fda66c8e0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 331 (608.3500385284424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426841805, topics=[])
11/17/2025 02:06:18.699 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426841805 with 0 response partitions (1 implied)
11/17/2025 02:06:18.699 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204901.871338, idle connection 143671.000000, request 304394.164324
11/17/2025 02:06:18.699 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205131.788086, idle connection 143789.000000, request 304394.795179
11/17/2025 02:06:18.699 7fda6940e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350
11/17/2025 02:06:18.699 7fda6940e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.699 7fda6940e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 350 (606.3132286071777 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1642745414, topics=[])
11/17/2025 02:06:18.700 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1642745414 with 0 response partitions (1 implied)
11/17/2025 02:06:18.700 7fda6940e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 356
11/17/2025 02:06:18.700 7fda6940e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.700 7fda6940e7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 356 (606.0066223144531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050535284, topics=[])
11/17/2025 02:06:18.700 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1050535284 with 0 response partitions (1 implied)
11/17/2025 02:06:18.763 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4
11/17/2025 02:06:18.763 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
11/17/2025 02:06:18.763 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678c4790> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
11/17/2025 02:06:18.763 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.763 7fda66c8e680 [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=2042266674, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.763 7fda66c8e680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2042266674, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.764 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204178.420898, idle connection 143306.000000, request 304999.948502
11/17/2025 02:06:18.764 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204177.962402, idle connection 143306.000000, request 304999.497652
11/17/2025 02:06:18.842 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204034.918457, idle connection 143066.000000, request 304398.722649
11/17/2025 02:06:18.843 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 497
11/17/2025 02:06:18.843 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.843 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 497 (602.0431518554688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182050876, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4063, last_stable_offset=4063, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\xd8\x00\x00\x01\x04\x00\x00\x00\x00\x02\xfe\xf0\x02\x8e\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/17/2025 02:06:18.843 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182050876 with 1 response partitions (0 implied)
11/17/2025 02:06:18.844 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 1922 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4056
11/17/2025 02:06:18.844 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4056 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
11/17/2025 02:06:18.844 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4063 (leader epoch 0)
11/17/2025 02:06:18.873 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204168.342773, idle connection 143478.000000, request 304398.715496
11/17/2025 02:06:18.874 7fda6940e040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358
11/17/2025 02:06:18.874 7fda6940e040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.874 7fda6940e040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 358 (601.9115447998047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1166507884, topics=[])
11/17/2025 02:06:18.874 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1166507884 with 0 response partitions (1 implied)
11/17/2025 02:06:18.875 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204095.509521, idle connection 143176.000000, request 304399.245024
11/17/2025 02:06:18.875 7fda66c8e9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333
11/17/2025 02:06:18.876 7fda66c8e9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.876 7fda66c8e9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 333 (601.1495590209961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817443853, topics=[])
11/17/2025 02:06:18.876 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1817443853 with 0 response partitions (1 implied)
11/17/2025 02:06:18.877 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 37
11/17/2025 02:06:18.878 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
11/17/2025 02:06:18.878 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678588e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
11/17/2025 02:06:18.878 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.878 7fda680cf720 [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=872837317, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.878 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=872837317, session_epoch=336, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.878 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204970.719727, idle connection 143434.000000, request 304999.951601
11/17/2025 02:06:18.878 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204970.334717, idle connection 143434.000000, request 304999.571323
11/17/2025 02:06:18.881 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
11/17/2025 02:06:18.881 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
11/17/2025 02:06:18.881 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67885280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
11/17/2025 02:06:18.881 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.881 7fda680cf2c0 [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=856417271, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.882 7fda680cf2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=856417271, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.882 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204235.363037, idle connection 143051.000000, request 304999.960661
11/17/2025 02:06:18.882 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204935.619629, idle connection 143090.000000, request 304397.360325
11/17/2025 02:06:18.882 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204234.874756, idle connection 143050.000000, request 304999.475718
11/17/2025 02:06:18.883 7fda680cf4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 333
11/17/2025 02:06:18.883 7fda680cf4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.883 7fda680cf4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 333 (603.3935546875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1601534485, topics=[])
11/17/2025 02:06:18.883 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1601534485 with 0 response partitions (1 implied)
11/17/2025 02:06:18.901 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205071.766357, idle connection 143312.000000, request 304398.787737
11/17/2025 02:06:18.902 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 348
11/17/2025 02:06:18.902 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.902 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 348 (602.0052433013916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725449652, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=65, last_stable_offset=65, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00@\x00\x00\x01\x84\x00\x00\x00\x00\x02\x08Vz\xd3\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\x05\x00\x00\x00\xe4\x04ObjectVMITable:default-domain:te...')])])
11/17/2025 02:06:18.903 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725449652 with 1 response partitions (0 implied)
11/17/2025 02:06:18.903 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 400 bytes of data for partition TopicPartition(topic='-uve-topic-13', partition=0) with offset 64
11/17/2025 02:06:18.903 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 64 for assigned partition TopicPartition(topic='-uve-topic-13', partition=0)
11/17/2025 02:06:18.904 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-13', partition=0) to 65 (leader epoch 0)
11/17/2025 02:06:18.908 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
11/17/2025 02:06:18.908 7fda680cf0e0 [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/17/2025 02:06:18.909 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678587c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/17/2025 02:06:18.909 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.909 7fda680cf0e0 [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=1080123118, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.909 7fda680cf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1080123118, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.909 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204210.738037, idle connection 143040.000000, request 304999.938726
11/17/2025 02:06:18.910 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 6
11/17/2025 02:06:18.910 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
11/17/2025 02:06:18.910 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda679033d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
11/17/2025 02:06:18.910 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.910 7fda66c8e540 [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=120351257, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.910 7fda66c8e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=120351257, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.910 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204043.239258, idle connection 143167.000000, request 304999.954224
11/17/2025 02:06:18.911 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204209.442139, idle connection 143038.000000, request 304998.649597
11/17/2025 02:06:18.913 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204040.327637, idle connection 143164.000000, request 304997.046947
11/17/2025 02:06:18.945 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4063
11/17/2025 02:06:18.945 7fda66e6dea0 [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/17/2025 02:06:18.946 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c790> 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)])
11/17/2025 02:06:18.946 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.946 7fda66e6dea0 [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=182050876, session_epoch=495, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4063, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:18.946 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 498 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182050876, session_epoch=495, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4063, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:18.946 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203931.208740, idle connection 142963.000000, request 304999.942541
11/17/2025 02:06:18.947 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203930.635986, idle connection 142962.000000, request 304999.376774
11/17/2025 02:06:18.980 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 69
11/17/2025 02:06:18.980 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
11/17/2025 02:06:18.980 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cb80> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
11/17/2025 02:06:18.980 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:18.981 7fda66e6df40 [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=640373379, session_epoch=343, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.981 7fda66e6df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 346 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=640373379, session_epoch=343, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:18.981 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204652.753662, idle connection 142921.000000, request 304999.940634
11/17/2025 02:06:18.981 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204652.305908, idle connection 142921.000000, request 304999.503613
11/17/2025 02:06:18.982 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203976.773926, idle connection 143314.000000, request 304399.134398
11/17/2025 02:06:18.982 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344
11/17/2025 02:06:18.982 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:18.982 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 344 (601.3760566711426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=593215620, topics=[])
11/17/2025 02:06:18.982 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 593215620 with 0 response partitions (1 implied)
11/17/2025 02:06:19.004 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 65
11/17/2025 02:06:19.004 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
11/17/2025 02:06:19.004 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f7370> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-13', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
11/17/2025 02:06:19.005 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.005 7fda6727a720 [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=1725449652, session_epoch=346, topics=[(topic='-uve-topic-13', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=65, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.005 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725449652, session_epoch=346, topics=[(topic='-uve-topic-13', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=65, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.005 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204968.014160, idle connection 143208.000000, request 304999.936104
11/17/2025 02:06:19.006 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204967.294434, idle connection 143207.000000, request 304999.223709
11/17/2025 02:06:19.007 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 349
11/17/2025 02:06:19.007 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.007 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 349 (1.6536712646484375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725449652, topics=[(topics='-uve-topic-13', partitions=[(partition=0, error_code=0, highwater_offset=66, last_stable_offset=66, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00A\x00\x00\x01{\x00\x00\x00\x00\x02\xc7W\x00`\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\x90\x05\x00\x00\x00\xd2\x04ObjectVMITable:default-domain:te...')])])
11/17/2025 02:06:19.007 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725449652 with 1 response partitions (0 implied)
11/17/2025 02:06:19.007 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 391 bytes of data for partition TopicPartition(topic='-uve-topic-13', partition=0) with offset 65
11/17/2025 02:06:19.007 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 65 for assigned partition TopicPartition(topic='-uve-topic-13', partition=0)
11/17/2025 02:06:19.008 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-13', partition=0) to 66 (leader epoch 0)
11/17/2025 02:06:19.036 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 316
11/17/2025 02:06:19.036 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
11/17/2025 02:06:19.036 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785ab20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
11/17/2025 02:06:19.036 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.036 7fda6940e5e0 [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=1105040017, session_epoch=362, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.037 7fda6940e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 365 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1105040017, session_epoch=362, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.037 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204791.281494, idle connection 143448.000000, request 304999.944687
11/17/2025 02:06:19.037 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204790.596191, idle connection 143447.000000, request 304999.263287
11/17/2025 02:06:19.063 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 136
11/17/2025 02:06:19.063 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
11/17/2025 02:06:19.063 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67858640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
11/17/2025 02:06:19.063 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.063 7fda680cfa40 [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=1505373662, session_epoch=347, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.064 7fda680cfa40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1505373662, session_epoch=347, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.064 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203963.965576, idle connection 143262.000000, request 304999.945641
11/17/2025 02:06:19.064 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204184.615234, idle connection 143372.000000, request 304397.225380
11/17/2025 02:06:19.064 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203963.281494, idle connection 143261.000000, request 304999.269962
11/17/2025 02:06:19.065 7fda6940e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 360
11/17/2025 02:06:19.065 7fda6940e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.065 7fda6940e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 360 (603.6083698272705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=331337579, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=212, last_stable_offset=212, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xd2\x00\x00\x02\x0f\x00\x00\x00\x00\x02\xc2VB\xda\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\xda\x03\x00\x00\x00\x9c\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
11/17/2025 02:06:19.065 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 331337579 with 1 response partitions (0 implied)
11/17/2025 02:06:19.065 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 539 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 210
11/17/2025 02:06:19.065 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 210 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0)
11/17/2025 02:06:19.066 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 212 (leader epoch 0)
11/17/2025 02:06:19.081 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 210
11/17/2025 02:06:19.081 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
11/17/2025 02:06:19.081 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67858280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
11/17/2025 02:06:19.082 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.082 7fda6940e860 [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=559399502, session_epoch=360, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.082 7fda6940e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 363 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559399502, session_epoch=360, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.083 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204404.746582, idle connection 143388.000000, request 304999.869108
11/17/2025 02:06:19.084 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204403.985107, idle connection 143388.000000, request 304999.121189
11/17/2025 02:06:19.108 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 66
11/17/2025 02:06:19.109 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
11/17/2025 02:06:19.109 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678582e0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-13', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
11/17/2025 02:06:19.109 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.109 7fda6727a720 [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=1725449652, session_epoch=347, topics=[(topic='-uve-topic-13', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=66, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.109 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725449652, session_epoch=347, topics=[(topic='-uve-topic-13', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=66, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.109 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204864.033447, idle connection 143104.000000, request 304999.941587
11/17/2025 02:06:19.110 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204863.594238, idle connection 143104.000000, request 304999.511242
11/17/2025 02:06:19.166 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 190
11/17/2025 02:06:19.166 7fda6940ed60 [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/17/2025 02:06:19.166 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c940> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
11/17/2025 02:06:19.166 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.166 7fda6940ed60 [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=1453829896, session_epoch=355, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.166 7fda6940ed60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1453829896, session_epoch=355, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.167 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204358.873047, idle connection 143356.000000, request 304999.943256
11/17/2025 02:06:19.167 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 212
11/17/2025 02:06:19.167 7fda6940e540 [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/17/2025 02:06:19.167 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cb20> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
11/17/2025 02:06:19.167 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.167 7fda6940e540 [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=331337579, session_epoch=358, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=212, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.167 7fda6940e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 361 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=331337579, session_epoch=358, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=212, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.168 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204080.897217, idle connection 143269.000000, request 304999.956608
11/17/2025 02:06:19.168 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204357.231934, idle connection 143354.000000, request 304998.311520
11/17/2025 02:06:19.168 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204080.049561, idle connection 143268.000000, request 304999.114513
11/17/2025 02:06:19.177 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203642.086914, idle connection 142716.000000, request 304398.830175
11/17/2025 02:06:19.177 7fda66e6db80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331
11/17/2025 02:06:19.177 7fda66e6db80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.177 7fda66e6db80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 331 (601.8116474151611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=411999081, topics=[])
11/17/2025 02:06:19.178 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 411999081 with 0 response partitions (1 implied)
11/17/2025 02:06:19.180 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
11/17/2025 02:06:19.180 7fda6725b680 [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/17/2025 02:06:19.180 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c3a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
11/17/2025 02:06:19.180 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.180 7fda6725b680 [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=746145502, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.180 7fda6725b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=746145502, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.180 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204128.043701, idle connection 142943.000000, request 304999.948263
11/17/2025 02:06:19.181 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204127.613770, idle connection 142943.000000, request 304999.524117
11/17/2025 02:06:19.182 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204365.163330, idle connection 143204.000000, request 304396.168709
11/17/2025 02:06:19.182 7fda6940e2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 355
11/17/2025 02:06:19.182 7fda6940e2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.182 7fda6940e2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 355 (604.3615341186523 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1991185903, topics=[])
11/17/2025 02:06:19.183 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1991185903 with 0 response partitions (1 implied)
11/17/2025 02:06:19.215 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203699.716309, idle connection 143065.000000, request 304397.943258
11/17/2025 02:06:19.216 7fda680cfe00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 336
11/17/2025 02:06:19.216 7fda680cfe00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.216 7fda680cfe00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 336 (602.5919914245605 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=411690286, topics=[])
11/17/2025 02:06:19.216 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 411690286 with 0 response partitions (1 implied)
11/17/2025 02:06:19.216 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203720.526855, idle connection 143011.000000, request 304397.848845
11/17/2025 02:06:19.217 7fda680cf680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340
11/17/2025 02:06:19.217 7fda680cf680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.217 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 340 (602.654218673706 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1453043869, topics=[])
11/17/2025 02:06:19.217 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1453043869 with 0 response partitions (1 implied)
11/17/2025 02:06:19.222 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
11/17/2025 02:06:19.222 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
11/17/2025 02:06:19.222 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678f7a30> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
11/17/2025 02:06:19.223 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.223 7fda66bad0e0 [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=834020125, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.223 7fda66bad0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=834020125, session_epoch=328, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.223 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204087.824951, idle connection 142917.000000, request 304999.919653
11/17/2025 02:06:19.224 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204087.189209, idle connection 142917.000000, request 304999.292850
11/17/2025 02:06:19.224 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 34
11/17/2025 02:06:19.224 7fda680cf5e0 [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/17/2025 02:06:19.224 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67885be0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
11/17/2025 02:06:19.224 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.224 7fda680cf5e0 [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=1927368660, session_epoch=337, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.224 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1927368660, session_epoch=337, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.224 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204723.908447, idle connection 143023.000000, request 304999.959707
11/17/2025 02:06:19.225 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204135.977295, idle connection 143039.000000, request 304397.904873
11/17/2025 02:06:19.225 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204723.277588, idle connection 143023.000000, request 304999.329090
11/17/2025 02:06:19.225 7fda680cfcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339
11/17/2025 02:06:19.226 7fda680cfcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.226 7fda680cfcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 339 (602.8957366943359 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=203108210, topics=[])
11/17/2025 02:06:19.226 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 203108210 with 0 response partitions (1 implied)
11/17/2025 02:06:19.226 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340
11/17/2025 02:06:19.226 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.226 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 340 (1.928567886352539 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927368660, topics=[(topics='-uve-topic-15', partitions=[(partition=0, error_code=0, highwater_offset=35, last_stable_offset=35, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00"\x00\x00\x01|\x00\x00\x00\x00\x02\x1a}\xbb\x82\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x92\x05\x00\x00\x00\xd4\x04ObjectVMITable:default-domain:te...')])])
11/17/2025 02:06:19.227 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927368660 with 1 response partitions (0 implied)
11/17/2025 02:06:19.227 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 392 bytes of data for partition TopicPartition(topic='-uve-topic-15', partition=0) with offset 34
11/17/2025 02:06:19.227 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 34 for assigned partition TopicPartition(topic='-uve-topic-15', partition=0)
11/17/2025 02:06:19.227 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-15', partition=0) to 35 (leader epoch 0)
11/17/2025 02:06:19.266 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 180
11/17/2025 02:06:19.266 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
11/17/2025 02:06:19.266 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678a8d00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
11/17/2025 02:06:19.266 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.266 7fda6940e720 [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=154805069, session_epoch=359, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.266 7fda6940e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 362 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=154805069, session_epoch=359, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.267 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204808.087402, idle connection 143147.000000, request 304999.937057
11/17/2025 02:06:19.267 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204807.596191, idle connection 143146.000000, request 304999.456644
11/17/2025 02:06:19.283 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204089.790039, idle connection 142897.000000, request 304398.908615
11/17/2025 02:06:19.283 7fda6727acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 343
11/17/2025 02:06:19.283 7fda6727acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.283 7fda6727acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 343 (601.6504764556885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1151354221, topics=[])
11/17/2025 02:06:19.283 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1151354221 with 0 response partitions (1 implied)
11/17/2025 02:06:19.299 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 2
11/17/2025 02:06:19.299 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
11/17/2025 02:06:19.299 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678e4fd0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
11/17/2025 02:06:19.299 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.300 7fda66c8e0e0 [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=426841805, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.300 7fda66c8e0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=426841805, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.300 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203508.753906, idle connection 142813.000000, request 304999.921083
11/17/2025 02:06:19.300 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 147
11/17/2025 02:06:19.300 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
11/17/2025 02:06:19.301 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cfa0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
11/17/2025 02:06:19.301 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.301 7fda6940e400 [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=1642745414, session_epoch=348, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.301 7fda6940e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1642745414, session_epoch=348, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.301 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204299.701416, idle connection 143069.000000, request 304999.951601
11/17/2025 02:06:19.301 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 201
11/17/2025 02:06:19.301 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
11/17/2025 02:06:19.301 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67913190> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
11/17/2025 02:06:19.301 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.301 7fda6940e7c0 [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=1050535284, session_epoch=354, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.302 7fda6940e7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050535284, session_epoch=354, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.302 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204528.590576, idle connection 143186.000000, request 304999.948502
11/17/2025 02:06:19.303 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203506.116211, idle connection 142811.000000, request 304997.292042
11/17/2025 02:06:19.304 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204296.711670, idle connection 143066.000000, request 304996.967077
11/17/2025 02:06:19.304 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204526.361572, idle connection 143184.000000, request 304997.726202
11/17/2025 02:06:19.328 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 35
11/17/2025 02:06:19.328 7fda680cf5e0 [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/17/2025 02:06:19.328 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67d6bd60> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-15', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
11/17/2025 02:06:19.328 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.328 7fda680cf5e0 [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=1927368660, session_epoch=338, topics=[(topic='-uve-topic-15', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=35, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.328 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1927368660, session_epoch=338, topics=[(topic='-uve-topic-15', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=35, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.329 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204619.876953, idle connection 142919.000000, request 304999.852657
11/17/2025 02:06:19.329 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204619.149414, idle connection 142918.000000, request 304999.211788
11/17/2025 02:06:19.365 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203577.420410, idle connection 142705.000000, request 304398.945332
11/17/2025 02:06:19.365 7fda66c8e680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334
11/17/2025 02:06:19.365 7fda66c8e680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.365 7fda66c8e680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 334 (601.6683578491211 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2042266674, topics=[])
11/17/2025 02:06:19.365 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2042266674 with 0 response partitions (1 implied)
11/17/2025 02:06:19.474 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 161
11/17/2025 02:06:19.475 7fda6940e040 [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/17/2025 02:06:19.475 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda679011f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
11/17/2025 02:06:19.475 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.475 7fda6940e040 [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=1166507884, session_epoch=356, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.475 7fda6940e040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 359 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1166507884, session_epoch=356, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.475 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203566.247559, idle connection 142876.000000, request 304999.939442
11/17/2025 02:06:19.476 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203565.795898, idle connection 142875.000000, request 304999.497414
11/17/2025 02:06:19.476 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 7
11/17/2025 02:06:19.476 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
11/17/2025 02:06:19.476 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c610> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
11/17/2025 02:06:19.476 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.477 7fda66c8e9a0 [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=1817443853, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.477 7fda66c8e9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1817443853, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.477 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203493.769531, idle connection 142574.000000, request 304999.954939
11/17/2025 02:06:19.477 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203493.427734, idle connection 142574.000000, request 304999.615431
11/17/2025 02:06:19.479 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204369.966309, idle connection 142834.000000, request 304399.201632
11/17/2025 02:06:19.479 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 339
11/17/2025 02:06:19.479 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.479 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 339 (601.2039184570312 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=872837317, topics=[(topics='-uve-topic-19', partitions=[(partition=0, error_code=0, highwater_offset=38, last_stable_offset=38, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00%\x00\x00\x01\x83\x00\x00\x00\x00\x02\xbe\xc8T\x18\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\xa0\x05\x00\x00\x00\xe2\x04ObjectVMITable:default-domain:te...')])])
11/17/2025 02:06:19.479 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 872837317 with 1 response partitions (0 implied)
11/17/2025 02:06:19.480 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 399 bytes of data for partition TopicPartition(topic='-uve-topic-19', partition=0) with offset 37
11/17/2025 02:06:19.480 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 37 for assigned partition TopicPartition(topic='-uve-topic-19', partition=0)
11/17/2025 02:06:19.480 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-19', partition=0) to 38 (leader epoch 0)
11/17/2025 02:06:19.483 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6
11/17/2025 02:06:19.483 7fda680cf4a0 [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/17/2025 02:06:19.483 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda679030a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
11/17/2025 02:06:19.483 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.484 7fda680cf4a0 [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=1601534485, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.484 7fda680cf4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1601534485, session_epoch=331, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.484 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204333.794434, idle connection 142488.000000, request 304999.957085
11/17/2025 02:06:19.484 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203633.078369, idle connection 142448.000000, request 304397.675991
11/17/2025 02:06:19.484 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204333.249023, idle connection 142488.000000, request 304999.416351
11/17/2025 02:06:19.485 7fda680cf2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331
11/17/2025 02:06:19.485 7fda680cf2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.485 7fda680cf2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 331 (603.1453609466553 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=856417271, topics=[])
11/17/2025 02:06:19.485 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 856417271 with 0 response partitions (1 implied)
11/17/2025 02:06:19.514 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203605.791748, idle connection 142435.000000, request 304394.986153
11/17/2025 02:06:19.515 7fda680cf0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331
11/17/2025 02:06:19.515 7fda680cf0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.515 7fda680cf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 331 (605.6954860687256 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1080123118, topics=[])
11/17/2025 02:06:19.515 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1080123118 with 0 response partitions (1 implied)
11/17/2025 02:06:19.515 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203438.003906, idle connection 142561.000000, request 304394.645214
11/17/2025 02:06:19.516 7fda66c8e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334
11/17/2025 02:06:19.516 7fda66c8e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.516 7fda66c8e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 334 (605.7267189025879 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=120351257, topics=[])
11/17/2025 02:06:19.516 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 120351257 with 0 response partitions (1 implied)
11/17/2025 02:06:19.547 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203330.064941, idle connection 142361.000000, request 304398.794889
11/17/2025 02:06:19.548 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 498
11/17/2025 02:06:19.548 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.548 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 498 (601.8178462982178 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182050876, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4078, last_stable_offset=4078, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\xdf\x00\x00\x01\x07\x00\x00\x00\x00\x02\xcdk\x16\xdf\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\xa8\x03\x00\x00\x00\xea\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])])
11/17/2025 02:06:19.548 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182050876 with 1 response partitions (0 implied)
11/17/2025 02:06:19.548 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 4000 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4063
11/17/2025 02:06:19.548 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4063 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
11/17/2025 02:06:19.550 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4078 (leader epoch 0)
11/17/2025 02:06:19.580 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 38
11/17/2025 02:06:19.581 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
11/17/2025 02:06:19.581 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c910> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-19', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
11/17/2025 02:06:19.581 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.581 7fda680cf720 [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=872837317, session_epoch=337, topics=[(topic='-uve-topic-19', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=38, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.581 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=872837317, session_epoch=337, topics=[(topic='-uve-topic-19', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=38, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.581 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204267.631836, idle connection 142731.000000, request 304999.943972
11/17/2025 02:06:19.582 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204267.183838, idle connection 142731.000000, request 304999.504328
11/17/2025 02:06:19.584 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204050.058105, idle connection 142319.000000, request 304397.255182
11/17/2025 02:06:19.584 7fda66e6df40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 346
11/17/2025 02:06:19.584 7fda66e6df40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.584 7fda66e6df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 346 (603.1589508056641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=640373379, topics=[])
11/17/2025 02:06:19.584 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 640373379 with 0 response partitions (1 implied)
11/17/2025 02:06:19.584 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 46
11/17/2025 02:06:19.584 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
11/17/2025 02:06:19.584 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786c9d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
11/17/2025 02:06:19.585 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.585 7fda680cfb80 [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=593215620, session_epoch=342, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.585 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 345 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=593215620, session_epoch=342, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.585 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203373.528320, idle connection 142710.000000, request 304999.957561
11/17/2025 02:06:19.585 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203373.165771, idle connection 142710.000000, request 304999.600649
11/17/2025 02:06:19.638 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204189.870850, idle connection 142846.000000, request 304398.532152
11/17/2025 02:06:19.639 7fda6940e5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 365
11/17/2025 02:06:19.639 7fda6940e5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.639 7fda6940e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 365 (602.1132469177246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1105040017, topics=[])
11/17/2025 02:06:19.639 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1105040017 with 0 response partitions (1 implied)
11/17/2025 02:06:19.650 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4078
11/17/2025 02:06:19.651 7fda66e6dea0 [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/17/2025 02:06:19.651 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678587c0> 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)])
11/17/2025 02:06:19.651 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.651 7fda66e6dea0 [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=182050876, session_epoch=496, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4078, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.651 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 499 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182050876, session_epoch=496, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4078, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.651 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203226.091553, idle connection 142257.000000, request 304999.933958
11/17/2025 02:06:19.652 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203225.567627, idle connection 142257.000000, request 304999.420404
11/17/2025 02:06:19.668 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203359.546143, idle connection 142658.000000, request 304395.523071
11/17/2025 02:06:19.668 7fda680cfa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350
11/17/2025 02:06:19.669 7fda680cfa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.669 7fda680cfa40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 350 (605.036735534668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1505373662, topics=[])
11/17/2025 02:06:19.669 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1505373662 with 0 response partitions (1 implied)
11/17/2025 02:06:19.684 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203803.453369, idle connection 142787.000000, request 304398.579121
11/17/2025 02:06:19.685 7fda6940e860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 363
11/17/2025 02:06:19.685 7fda6940e860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.685 7fda6940e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 363 (602.1881103515625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559399502, topics=[(topics='-uve-topic-27', partitions=[(partition=0, error_code=0, highwater_offset=211, last_stable_offset=211, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xd2\x00\x00\x01P\x00\x00\x00\x00\x02\xf4\xfaOz\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\xba\x04\x00\x00\x00\xfc\x03ObjectSITable:default-domain:tem...')])])
11/17/2025 02:06:19.686 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559399502 with 1 response partitions (0 implied)
11/17/2025 02:06:19.686 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 348 bytes of data for partition TopicPartition(topic='-uve-topic-27', partition=0) with offset 210
11/17/2025 02:06:19.686 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 210 for assigned partition TopicPartition(topic='-uve-topic-27', partition=0)
11/17/2025 02:06:19.686 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-27', partition=0) to 211 (leader epoch 0)
11/17/2025 02:06:19.710 7fda6727a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204263.002930, idle connection 142503.000000, request 304398.908615
11/17/2025 02:06:19.711 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350
11/17/2025 02:06:19.711 7fda6727a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.711 7fda6727a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 350 (601.6445159912109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725449652, topics=[])
11/17/2025 02:06:19.711 7fda6727a720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725449652 with 0 response partitions (1 implied)
11/17/2025 02:06:19.769 7fda6940ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203756.456055, idle connection 142753.000000, request 304397.523642
11/17/2025 02:06:19.769 7fda6940ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358
11/17/2025 02:06:19.769 7fda6940ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.770 7fda6940ed60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 358 (603.1053066253662 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1453829896, topics=[])
11/17/2025 02:06:19.770 7fda6940ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1453829896 with 0 response partitions (1 implied)
11/17/2025 02:06:19.770 7fda6940e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203478.502930, idle connection 142666.000000, request 304397.563219
11/17/2025 02:06:19.770 7fda6940e540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 361
11/17/2025 02:06:19.770 7fda6940e540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.770 7fda6940e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 361 (602.8416156768799 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=331337579, topics=[])
11/17/2025 02:06:19.771 7fda6940e540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 331337579 with 0 response partitions (1 implied)
11/17/2025 02:06:19.778 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
11/17/2025 02:06:19.778 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
11/17/2025 02:06:19.778 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cd60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
11/17/2025 02:06:19.779 7fda66e6db80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.779 7fda66e6db80 [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=411999081, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.779 7fda66e6db80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=411999081, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.779 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203039.679688, idle connection 142113.000000, request 304999.926090
11/17/2025 02:06:19.780 7fda66e6db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203038.897217, idle connection 142112.000000, request 304999.152422
11/17/2025 02:06:19.781 7fda6725b680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203527.207031, idle connection 142342.000000, request 304399.110794
11/17/2025 02:06:19.782 7fda6725b680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331
11/17/2025 02:06:19.782 7fda6725b680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.782 7fda6725b680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 331 (601.8214225769043 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=746145502, topics=[])
11/17/2025 02:06:19.782 7fda6725b680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 746145502 with 0 response partitions (1 implied)
11/17/2025 02:06:19.784 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 146
11/17/2025 02:06:19.784 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
11/17/2025 02:06:19.784 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cb50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
11/17/2025 02:06:19.784 7fda6940e2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.784 7fda6940e2c0 [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=1991185903, session_epoch=353, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.784 7fda6940e2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1991185903, session_epoch=353, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.785 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203762.462891, idle connection 142602.000000, request 304999.926567
11/17/2025 02:06:19.785 7fda6940e2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203761.730957, idle connection 142601.000000, request 304999.202251
11/17/2025 02:06:19.787 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 211
11/17/2025 02:06:19.787 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
11/17/2025 02:06:19.787 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678ae1f0> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-27', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
11/17/2025 02:06:19.787 7fda6940e860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.787 7fda6940e860 [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=559399502, session_epoch=361, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=211, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.787 7fda6940e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559399502, session_epoch=361, topics=[(topic='-uve-topic-27', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=211, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.788 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203700.321289, idle connection 142684.000000, request 304999.955654
11/17/2025 02:06:19.788 7fda6940e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203699.771240, idle connection 142684.000000, request 304999.409199
11/17/2025 02:06:19.818 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 32
11/17/2025 02:06:19.818 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
11/17/2025 02:06:19.818 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786cf40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
11/17/2025 02:06:19.818 7fda680cfe00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.818 7fda680cfe00 [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=411690286, session_epoch=334, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.819 7fda680cfe00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 337 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=411690286, session_epoch=334, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.819 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203096.481689, idle connection 142461.000000, request 304999.946117
11/17/2025 02:06:19.819 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 39
11/17/2025 02:06:19.819 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
11/17/2025 02:06:19.819 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67858c70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
11/17/2025 02:06:19.819 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.819 7fda680cf680 [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=1453043869, session_epoch=338, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.819 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 341 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1453043869, session_epoch=338, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.819 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203117.527100, idle connection 142408.000000, request 304999.962091
11/17/2025 02:06:19.834 7fda680cfe00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203080.719727, idle connection 142446.000000, request 304984.180927
11/17/2025 02:06:19.835 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203101.934326, idle connection 142393.000000, request 304984.366655
11/17/2025 02:06:19.835 7fda66bad0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203475.410889, idle connection 142305.000000, request 304387.510538
11/17/2025 02:06:19.836 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 31
11/17/2025 02:06:19.836 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
11/17/2025 02:06:19.836 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678b6130> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
11/17/2025 02:06:19.836 7fda680cfcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.836 7fda680cfcc0 [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=203108210, session_epoch=337, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.836 7fda680cfcc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=203108210, session_epoch=337, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.837 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203524.229736, idle connection 142427.000000, request 304999.933720
11/17/2025 02:06:19.846 7fda680cf680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341
11/17/2025 02:06:19.846 7fda680cf680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.846 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 341 (26.50594711303711 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1453043869, topics=[(topics='-uve-topic-14', partitions=[(partition=0, error_code=0, highwater_offset=40, last_stable_offset=40, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x00'\x00\x00\x01{\x00\x00\x00\x00\x02\x8e\xf2;\xd5\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\x90\x05\x00\x00\x00\xd2\x04ObjectVMITable:default-domain:te...")])])
11/17/2025 02:06:19.846 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1453043869 with 1 response partitions (0 implied)
11/17/2025 02:06:19.846 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 391 bytes of data for partition TopicPartition(topic='-uve-topic-14', partition=0) with offset 39
11/17/2025 02:06:19.847 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 39 for assigned partition TopicPartition(topic='-uve-topic-14', partition=0)
11/17/2025 02:06:19.847 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-14', partition=0) to 40 (leader epoch 0)
11/17/2025 02:06:19.847 7fda66bad0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331
11/17/2025 02:06:19.848 7fda66bad0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.848 7fda66bad0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 331 (624.7835159301758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=834020125, topics=[])
11/17/2025 02:06:19.848 7fda66bad0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 834020125 with 0 response partitions (1 implied)
11/17/2025 02:06:19.850 7fda680cfcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203510.397217, idle connection 142413.000000, request 304986.098766
11/17/2025 02:06:19.868 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204207.011963, idle connection 142546.000000, request 304398.859978
11/17/2025 02:06:19.868 7fda6940e720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362
11/17/2025 02:06:19.868 7fda6940e720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.868 7fda6940e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 362 (601.881742477417 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=154805069, topics=[(topics='-uve-topic-25', partitions=[(partition=0, error_code=0, highwater_offset=181, last_stable_offset=181, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x00\xb4\x00\x00\x01L\x00\x00\x00\x00\x02\xd9b{L\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\xb2\x04\x00\x00\x00\xf4\x03ObjectSITable:default-domain:tem...')])])
11/17/2025 02:06:19.869 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 154805069 with 1 response partitions (0 implied)
11/17/2025 02:06:19.869 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 344 bytes of data for partition TopicPartition(topic='-uve-topic-25', partition=0) with offset 180
11/17/2025 02:06:19.869 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 180 for assigned partition TopicPartition(topic='-uve-topic-25', partition=0)
11/17/2025 02:06:19.870 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-25', partition=0) to 181 (leader epoch 0)
11/17/2025 02:06:19.884 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 41
11/17/2025 02:06:19.884 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
11/17/2025 02:06:19.884 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda679969d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
11/17/2025 02:06:19.884 7fda6727acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.884 7fda6727acc0 [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=1151354221, session_epoch=341, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.885 7fda6727acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 344 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1151354221, session_epoch=341, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.885 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203487.612549, idle connection 142295.000000, request 304999.927044
11/17/2025 02:06:19.885 7fda6727acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203487.011475, idle connection 142294.000000, request 304999.336481
11/17/2025 02:06:19.905 7fda66c8e0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202903.732422, idle connection 142208.000000, request 304394.898415
11/17/2025 02:06:19.905 7fda66c8e0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332
11/17/2025 02:06:19.906 7fda66c8e0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.906 7fda66c8e0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 332 (605.8712005615234 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=426841805, topics=[])
11/17/2025 02:06:19.906 7fda66c8e0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 426841805 with 0 response partitions (1 implied)
11/17/2025 02:06:19.906 7fda6940e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203694.497314, idle connection 142464.000000, request 304394.751072
11/17/2025 02:06:19.906 7fda6940e7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203924.438721, idle connection 142582.000000, request 304395.802975
11/17/2025 02:06:19.907 7fda6940e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 351
11/17/2025 02:06:19.907 7fda6940e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.907 7fda6940e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 351 (605.7047843933105 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1642745414, topics=[])
11/17/2025 02:06:19.907 7fda6940e400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1642745414 with 0 response partitions (1 implied)
11/17/2025 02:06:19.907 7fda6940e7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357
11/17/2025 02:06:19.907 7fda6940e7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.907 7fda6940e7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 357 (604.9900054931641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050535284, topics=[])
11/17/2025 02:06:19.907 7fda6940e7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1050535284 with 0 response partitions (1 implied)
11/17/2025 02:06:19.930 7fda680cf5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204018.338379, idle connection 142318.000000, request 304398.389578
11/17/2025 02:06:19.931 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341
11/17/2025 02:06:19.931 7fda680cf5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:19.931 7fda680cf5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 341 (602.4332046508789 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1927368660, topics=[])
11/17/2025 02:06:19.931 7fda680cf5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1927368660 with 0 response partitions (1 implied)
11/17/2025 02:06:19.948 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 40
11/17/2025 02:06:19.948 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
11/17/2025 02:06:19.948 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67888040> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-14', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
11/17/2025 02:06:19.948 7fda680cf680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.948 7fda680cf680 [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=1453043869, session_epoch=339, topics=[(topic='-uve-topic-14', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=40, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.949 7fda680cf680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 342 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1453043869, session_epoch=339, topics=[(topic='-uve-topic-14', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=40, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.949 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202988.014893, idle connection 142279.000000, request 304999.916792
11/17/2025 02:06:19.950 7fda680cf680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202987.147461, idle connection 142278.000000, request 304999.057770
11/17/2025 02:06:19.966 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4
11/17/2025 02:06:19.966 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
11/17/2025 02:06:19.966 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67858490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
11/17/2025 02:06:19.966 7fda66c8e680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.967 7fda66c8e680 [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=2042266674, session_epoch=332, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.967 7fda66c8e680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 335 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2042266674, session_epoch=332, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:19.967 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202974.798340, idle connection 142102.000000, request 304999.902487
11/17/2025 02:06:19.968 7fda66c8e680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202974.168701, idle connection 142102.000000, request 304999.288082
11/17/2025 02:06:19.970 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 181
11/17/2025 02:06:19.970 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
11/17/2025 02:06:19.970 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda67888730> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-25', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
11/17/2025 02:06:19.970 7fda6940e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:19.971 7fda6940e720 [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=154805069, session_epoch=360, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=181, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.971 7fda6940e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 363 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=154805069, session_epoch=360, topics=[(topic='-uve-topic-25', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=181, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
11/17/2025 02:06:19.971 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204103.772705, idle connection 142443.000000, request 304999.953270
11/17/2025 02:06:19.971 7fda6940e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204103.353516, idle connection 142442.000000, request 304999.539137
11/17/2025 02:06:20.076 7fda6940e040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202965.197266, idle connection 142275.000000, request 304398.883581
11/17/2025 02:06:20.077 7fda6940e040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 359
11/17/2025 02:06:20.077 7fda6940e040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:20.077 7fda6940e040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 359 (601.7582416534424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1166507884, topics=[])
11/17/2025 02:06:20.077 7fda6940e040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1166507884 with 0 response partitions (1 implied)
11/17/2025 02:06:20.078 7fda66c8e9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202893.016602, idle connection 141974.000000, request 304399.200916
11/17/2025 02:06:20.078 7fda66c8e9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334
11/17/2025 02:06:20.078 7fda66c8e9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:20.078 7fda66c8e9a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 334 (601.1595726013184 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1817443853, topics=[])
11/17/2025 02:06:20.078 7fda66c8e9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1817443853 with 0 response partitions (1 implied)
11/17/2025 02:06:20.086 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
11/17/2025 02:06:20.086 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
11/17/2025 02:06:20.086 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda678c42b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
11/17/2025 02:06:20.086 7fda680cf2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:20.086 7fda680cf2c0 [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=856417271, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.086 7fda680cf2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=856417271, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.086 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203030.927979, idle connection 141846.000000, request 304999.945164
11/17/2025 02:06:20.087 7fda680cf4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203731.072266, idle connection 141885.000000, request 304397.232533
11/17/2025 02:06:20.087 7fda680cf2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203030.020752, idle connection 141845.000000, request 304999.043703
11/17/2025 02:06:20.087 7fda680cf4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334
11/17/2025 02:06:20.088 7fda680cf4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:20.088 7fda680cf4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 334 (603.9221286773682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1601534485, topics=[])
11/17/2025 02:06:20.088 7fda680cf4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1601534485 with 0 response partitions (1 implied)
11/17/2025 02:06:20.117 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 0
11/17/2025 02:06:20.117 7fda680cf0e0 [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/17/2025 02:06:20.117 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786ca00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
11/17/2025 02:06:20.118 7fda680cf0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:20.118 7fda680cf0e0 [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=1080123118, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.118 7fda680cf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1080123118, session_epoch=329, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.118 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203001.914062, idle connection 141831.000000, request 304999.914408
11/17/2025 02:06:20.118 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 6
11/17/2025 02:06:20.119 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
11/17/2025 02:06:20.119 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6786caf0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
11/17/2025 02:06:20.119 7fda66c8e540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:20.119 7fda66c8e540 [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=120351257, session_epoch=332, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.119 7fda66c8e540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 335 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=120351257, session_epoch=332, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.119 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202833.893799, idle connection 141957.000000, request 304999.932528
11/17/2025 02:06:20.120 7fda680cf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202999.978271, idle connection 141829.000000, request 304997.988939
11/17/2025 02:06:20.121 7fda66c8e540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202832.860840, idle connection 141956.000000, request 304998.912334
11/17/2025 02:06:20.182 7fda680cf720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203666.584229, idle connection 142130.000000, request 304398.893833
11/17/2025 02:06:20.183 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 340
11/17/2025 02:06:20.183 7fda680cf720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:20.183 7fda680cf720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 340 (601.7248630523682 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=872837317, topics=[])
11/17/2025 02:06:20.183 7fda680cf720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 872837317 with 0 response partitions (1 implied)
11/17/2025 02:06:20.187 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 69
11/17/2025 02:06:20.187 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
11/17/2025 02:06:20.187 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6787a250> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
11/17/2025 02:06:20.187 7fda66e6df40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:20.187 7fda66e6df40 [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=640373379, session_epoch=344, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.187 7fda66e6df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 347 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=640373379, session_epoch=344, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.187 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203446.114990, idle connection 141715.000000, request 304999.948025
11/17/2025 02:06:20.188 7fda680cfb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202770.614502, idle connection 142107.000000, request 304397.042036
11/17/2025 02:06:20.188 7fda66e6df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203445.415527, idle connection 141714.000000, request 304999.256134
11/17/2025 02:06:20.188 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345
11/17/2025 02:06:20.188 7fda680cfb80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:20.189 7fda680cfb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 345 (603.8129329681396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=593215620, topics=[])
11/17/2025 02:06:20.189 7fda680cfb80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 593215620 with 0 response partitions (1 implied)
11/17/2025 02:06:20.239 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 316
11/17/2025 02:06:20.240 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
11/17/2025 02:06:20.240 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6785af40> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
11/17/2025 02:06:20.240 7fda6940e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:20.240 7fda6940e5e0 [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=1105040017, session_epoch=363, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.240 7fda6940e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 366 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1105040017, session_epoch=363, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.241 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203587.443848, idle connection 142244.000000, request 304999.927044
11/17/2025 02:06:20.241 7fda6940e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203586.737305, idle connection 142243.000000, request 304999.236345
11/17/2025 02:06:20.252 7fda66e6dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202624.863525, idle connection 141656.000000, request 304398.706436
11/17/2025 02:06:20.253 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 499
11/17/2025 02:06:20.253 7fda66e6dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
11/17/2025 02:06:20.253 7fda66e6dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Response 499 (602.0042896270752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182050876, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4090, last_stable_offset=4090, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0f\xee\x00\x00\x01\xdd\x00\x00\x00\x00\x02\x0b\x95\xf5s\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\xa8\x03\x00\x00\x00\xea\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])])
11/17/2025 02:06:20.254 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182050876 with 1 response partitions (0 implied)
11/17/2025 02:06:20.254 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 3117 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4078
11/17/2025 02:06:20.254 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4078 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
11/17/2025 02:06:20.255 7fda66e6dea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4090 (leader epoch 0)
11/17/2025 02:06:20.270 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 136
11/17/2025 02:06:20.271 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
11/17/2025 02:06:20.271 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fda6787a1f0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
11/17/2025 02:06:20.271 7fda680cfa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
11/17/2025 02:06:20.271 7fda680cfa40 [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=1505373662, session_epoch=348, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.271 7fda680cfa40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.41:9092 <connected> [IPv4 ('10.0.0.41', 9092)]>: Request 351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1505373662, session_epoch=348, topics=[], forgotten_topics_data=[])
11/17/2025 02:06:20.271 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202756.426514, idle connection 142055.000000, request 304999.936342
11/17/2025 02:06:20.272 7fda680cfa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202755.751953, idle connection 142054.000000, request 304999.272585