01/01/2026 01:58:00.733 7fcc0998ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.734 7fcc0998ee00 [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=1331360241, session_epoch=331, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.734 7fcc0998ee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1331360241, session_epoch=331, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.734 7fcc0998ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207839.885498, idle connection 146399.000000, request 304999.952793
01/01/2026 01:58:00.734 7fcc0998e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207096.452881, idle connection 146042.000000, request 304397.337675
01/01/2026 01:58:00.735 7fcc0998ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207839.348877, idle connection 146399.000000, request 304999.421597
01/01/2026 01:58:00.735 7fcc0998e400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328
01/01/2026 01:58:00.735 7fcc0998e400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.735 7fcc0998e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 328 (603.3251285552979 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=364720034, topics=[])
01/01/2026 01:58:00.735 7fcc0998e400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 364720034 with 0 response partitions (1 implied)
01/01/2026 01:58:00.740 7fcc0ba049a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 422
01/01/2026 01:58:00.740 7fcc0ba049a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
01/01/2026 01:58:00.740 7fcc0ba049a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc0915ae80> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
01/01/2026 01:58:00.740 7fcc0ba049a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.740 7fcc0ba049a0 [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=873976709, session_epoch=382, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=422, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
01/01/2026 01:58:00.740 7fcc0ba049a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 385 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=873976709, session_epoch=382, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=422, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
01/01/2026 01:58:00.740 7fcc0ba049a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208288.504883, idle connection 146577.000000, request 304999.946117
01/01/2026 01:58:00.741 7fcc0ba049a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208288.132324, idle connection 146577.000000, request 304999.576807
01/01/2026 01:58:00.741 7fcc0ba04e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207644.540283, idle connection 146602.000000, request 304398.408651
01/01/2026 01:58:00.741 7fcc0ba04e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332
01/01/2026 01:58:00.741 7fcc0ba04e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.741 7fcc0ba04e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 332 (601.959228515625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1241722687, topics=[])
01/01/2026 01:58:00.741 7fcc0ba04e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1241722687 with 0 response partitions (1 implied)
01/01/2026 01:58:00.742 7fcc08b8c0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 1
01/01/2026 01:58:00.742 7fcc08b8c0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
01/01/2026 01:58:00.742 7fcc08b8c0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091ba310> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
01/01/2026 01:58:00.742 7fcc08b8c0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.743 7fcc08b8c0e0 [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=635515918, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.743 7fcc08b8c0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=635515918, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.743 7fcc08b8c0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207922.557129, idle connection 146214.000000, request 304999.961853
01/01/2026 01:58:00.743 7fcc08b8c0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207922.243164, idle connection 146213.000000, request 304999.650955
01/01/2026 01:58:00.797 7fcc0998e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207533.922119, idle connection 146275.000000, request 304398.739338
01/01/2026 01:58:00.798 7fcc0998e900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 349
01/01/2026 01:58:00.798 7fcc0998e900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.798 7fcc0998e900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 349 (602.1203994750977 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2039385810, topics=[])
01/01/2026 01:58:00.798 7fcc0998e900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2039385810 with 0 response partitions (1 implied)
01/01/2026 01:58:00.806 7fcc0998ef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207560.020996, idle connection 146326.000000, request 304398.991346
01/01/2026 01:58:00.806 7fcc0998ef40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 347
01/01/2026 01:58:00.806 7fcc0998ef40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.807 7fcc0998ef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 347 (601.5698909759521 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=557445624, topics=[])
01/01/2026 01:58:00.807 7fcc0998ef40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 557445624 with 0 response partitions (1 implied)
01/01/2026 01:58:00.807 7fcc0ba047c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 251
01/01/2026 01:58:00.807 7fcc0ba047c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
01/01/2026 01:58:00.807 7fcc0ba047c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091bd7c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
01/01/2026 01:58:00.807 7fcc0ba047c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.808 7fcc0ba047c0 [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=1422042923, session_epoch=359, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.808 7fcc0ba047c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1422042923, session_epoch=359, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.808 7fcc0ba047c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207802.815918, idle connection 146513.000000, request 304999.937534
01/01/2026 01:58:00.808 7fcc0ba047c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207802.382812, idle connection 146512.000000, request 304999.514341
01/01/2026 01:58:00.816 7fcc0ba04040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 164
01/01/2026 01:58:00.816 7fcc0ba04040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
01/01/2026 01:58:00.816 7fcc0ba04040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091b15e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
01/01/2026 01:58:00.816 7fcc0ba04040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.816 7fcc0ba04040 [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=1744049114, session_epoch=355, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.817 7fcc0ba04040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1744049114, session_epoch=355, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.817 7fcc0ba04040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207434.125977, idle connection 146351.000000, request 304999.940395
01/01/2026 01:58:00.817 7fcc0ba04040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207433.696045, idle connection 146350.000000, request 304999.520779
01/01/2026 01:58:00.826 7fcc08b8c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207150.553223, idle connection 146158.000000, request 304399.016380
01/01/2026 01:58:00.826 7fcc08b8c180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328
01/01/2026 01:58:00.826 7fcc08b8c180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.826 7fcc08b8c180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 328 (601.6182899475098 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=332005942, topics=[])
01/01/2026 01:58:00.826 7fcc08b8c180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 332005942 with 0 response partitions (1 implied)
01/01/2026 01:58:00.827 7fcc08bcf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207151.100586, idle connection 146175.000000, request 304399.195194
01/01/2026 01:58:00.827 7fcc08bcf0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 328
01/01/2026 01:58:00.827 7fcc08bcf0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.827 7fcc08bcf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 328 (601.2096405029297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1022338529, topics=[])
01/01/2026 01:58:00.827 7fcc08bcf0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1022338529 with 0 response partitions (1 implied)
01/01/2026 01:58:00.831 7fcc0998e220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207265.041992, idle connection 145970.000000, request 304398.374557
01/01/2026 01:58:00.831 7fcc0998e220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329
01/01/2026 01:58:00.831 7fcc0998e220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.831 7fcc0998e220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 329 (602.2324562072754 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1566451555, topics=[])
01/01/2026 01:58:00.832 7fcc0998e220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1566451555 with 0 response partitions (1 implied)
01/01/2026 01:58:00.842 7fcc08befb80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 66
01/01/2026 01:58:00.842 7fcc08befb80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
01/01/2026 01:58:00.842 7fcc08befb80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc09227a90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
01/01/2026 01:58:00.842 7fcc08befb80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.842 7fcc08befb80 [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=1444583142, session_epoch=343, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.842 7fcc08befb80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1444583142, session_epoch=343, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.843 7fcc08befb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206971.629639, idle connection 146212.000000, request 304999.935865
01/01/2026 01:58:00.843 7fcc08befb80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206971.066650, idle connection 146211.000000, request 304999.383926
01/01/2026 01:58:00.931 7fcc0998e720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 185
01/01/2026 01:58:00.931 7fcc0998e720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
01/01/2026 01:58:00.931 7fcc0998e720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc0915a3a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
01/01/2026 01:58:00.931 7fcc0998e720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.931 7fcc0998e720 [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=870913620, session_epoch=350, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.931 7fcc0998e720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 353 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=870913620, session_epoch=350, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.932 7fcc0998e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207346.929688, idle connection 146199.000000, request 304999.924898
01/01/2026 01:58:00.932 7fcc0998e720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207346.259277, idle connection 146198.000000, request 304999.270678
01/01/2026 01:58:00.937 7fcc0ba04180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 153
01/01/2026 01:58:00.938 7fcc0ba04180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
01/01/2026 01:58:00.938 7fcc0ba04180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091878b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
01/01/2026 01:58:00.938 7fcc0ba04180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.938 7fcc0ba04180 [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=1398151180, session_epoch=347, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.938 7fcc0ba04180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1398151180, session_epoch=347, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.938 7fcc0ba04180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207669.967285, idle connection 146257.000000, request 304999.952078
01/01/2026 01:58:00.939 7fcc0ba04180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207669.578125, idle connection 146257.000000, request 304999.568701
01/01/2026 01:58:00.940 7fcc0ba044a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207649.716064, idle connection 146301.000000, request 304398.040056
01/01/2026 01:58:00.941 7fcc0ba044a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 354
01/01/2026 01:58:00.941 7fcc0ba044a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.941 7fcc0ba044a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 354 (602.3519039154053 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2026748883, topics=[])
01/01/2026 01:58:00.941 7fcc0ba044a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2026748883 with 0 response partitions (1 implied)
01/01/2026 01:58:00.941 7fcc0ba04360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207116.878906, idle connection 146313.000000, request 304397.957087
01/01/2026 01:58:00.941 7fcc0ba04360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 357
01/01/2026 01:58:00.941 7fcc0ba04360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.941 7fcc0ba04360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 357 (602.3650169372559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=516762048, topics=[])
01/01/2026 01:58:00.942 7fcc0ba04360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 516762048 with 0 response partitions (1 implied)
01/01/2026 01:58:00.942 7fcc0ba04b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 126
01/01/2026 01:58:00.942 7fcc0ba04b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
01/01/2026 01:58:00.942 7fcc0ba04b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091876d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
01/01/2026 01:58:00.942 7fcc0ba04b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:00.942 7fcc0ba04b80 [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=608191760, session_epoch=352, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.942 7fcc0ba04b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=608191760, session_epoch=352, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:00.942 7fcc0ba04b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207071.563232, idle connection 146349.000000, request 304999.962330
01/01/2026 01:58:00.943 7fcc0ba04b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207071.233887, idle connection 146348.000000, request 304999.635935
01/01/2026 01:58:00.979 7fcc0ba04540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207109.322754, idle connection 146270.000000, request 304398.801088
01/01/2026 01:58:00.979 7fcc0ba04540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 341
01/01/2026 01:58:00.979 7fcc0ba04540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:00.980 7fcc0ba04540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 341 (601.9089221954346 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=116535183, topics=[])
01/01/2026 01:58:00.980 7fcc0ba04540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 116535183 with 0 response partitions (1 implied)
01/01/2026 01:58:01.012 7fcc08b4ea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207799.514648, idle connection 146011.000000, request 304398.989677
01/01/2026 01:58:01.013 7fcc08b4ea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338
01/01/2026 01:58:01.013 7fcc08b4ea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.013 7fcc08b4ea40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 338 (601.6707420349121 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1330499949, topics=[])
01/01/2026 01:58:01.013 7fcc08b4ea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1330499949 with 0 response partitions (1 implied)
01/01/2026 01:58:01.040 7fcc08babd60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4
01/01/2026 01:58:01.041 7fcc08babd60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
01/01/2026 01:58:01.041 7fcc08babd60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091b1790> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
01/01/2026 01:58:01.041 7fcc08babd60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.041 7fcc08babd60 [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=1952432588, session_epoch=328, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.041 7fcc08babd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1952432588, session_epoch=328, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.041 7fcc08babd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207052.602295, idle connection 145885.000000, request 304999.942780
01/01/2026 01:58:01.041 7fcc08bab4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207720.265381, idle connection 145902.000000, request 304397.109747
01/01/2026 01:58:01.042 7fcc08babd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207051.700928, idle connection 145884.000000, request 304999.053001
01/01/2026 01:58:01.042 7fcc08bab4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
01/01/2026 01:58:01.042 7fcc08bab4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.043 7fcc08bab4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 330 (603.9059162139893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=133327330, topics=[])
01/01/2026 01:58:01.043 7fcc08bab4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 133327330 with 0 response partitions (1 implied)
01/01/2026 01:58:01.056 7fcc08b7a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206461.029785, idle connection 145654.000000, request 304398.507595
01/01/2026 01:58:01.057 7fcc08b7a900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 509
01/01/2026 01:58:01.057 7fcc08b7a900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.057 7fcc08b7a900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 509 (602.1027565002441 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=163744413, topics=[])
01/01/2026 01:58:01.057 7fcc08b7a900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 163744413 with 0 response partitions (1 implied)
01/01/2026 01:58:01.104 7fcc086e3f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 64
01/01/2026 01:58:01.104 7fcc086e3f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
01/01/2026 01:58:01.104 7fcc086e3f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091999a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
01/01/2026 01:58:01.104 7fcc086e3f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.104 7fcc086e3f40 [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=633172106, session_epoch=339, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.104 7fcc086e3f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=633172106, session_epoch=339, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.105 7fcc086e3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206514.936523, idle connection 145645.000000, request 304999.846458
01/01/2026 01:58:01.105 7fcc086e3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206514.366211, idle connection 145645.000000, request 304999.284744
01/01/2026 01:58:01.110 7fcc0998e5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 5
01/01/2026 01:58:01.110 7fcc0998e5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
01/01/2026 01:58:01.110 7fcc0998e5e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc09160c10> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
01/01/2026 01:58:01.110 7fcc0998e5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.110 7fcc0998e5e0 [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=1119269387, session_epoch=328, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.110 7fcc0998e5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1119269387, session_epoch=328, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.110 7fcc0998e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206646.124756, idle connection 145705.000000, request 304999.947309
01/01/2026 01:58:01.111 7fcc0998e5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206645.727539, idle connection 145704.000000, request 304999.556541
01/01/2026 01:58:01.129 7fcc0998e4a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206731.903809, idle connection 145975.000000, request 304398.688078
01/01/2026 01:58:01.129 7fcc0998e4a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 336
01/01/2026 01:58:01.129 7fcc0998e4a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.129 7fcc0998e4a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 336 (602.0445823669434 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=59828724, topics=[])
01/01/2026 01:58:01.130 7fcc0998e4a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 59828724 with 0 response partitions (1 implied)
01/01/2026 01:58:01.136 7fcc0998e860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207227.900635, idle connection 145765.000000, request 304399.108648
01/01/2026 01:58:01.136 7fcc0998e860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330
01/01/2026 01:58:01.136 7fcc0998e860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.136 7fcc0998e860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 330 (601.5517711639404 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1876536359, topics=[])
01/01/2026 01:58:01.136 7fcc0998e860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1876536359 with 0 response partitions (1 implied)
01/01/2026 01:58:01.330 7fcc08bef900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 52
01/01/2026 01:58:01.330 7fcc08bef900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
01/01/2026 01:58:01.330 7fcc08bef900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091ba790> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
01/01/2026 01:58:01.330 7fcc08bef900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.330 7fcc08bef900 [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=1835148210, session_epoch=336, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.331 7fcc08bef900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1835148210, session_epoch=336, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.331 7fcc08bef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207283.683350, idle connection 145735.000000, request 304999.942780
01/01/2026 01:58:01.331 7fcc086e3e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
01/01/2026 01:58:01.331 7fcc086e3e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
01/01/2026 01:58:01.331 7fcc086e3e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc0926d9d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
01/01/2026 01:58:01.331 7fcc086e3e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.331 7fcc086e3e00 [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=816173481, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.331 7fcc086e3e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=816173481, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.331 7fcc086e3e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206496.522217, idle connection 145390.000000, request 304999.962807
01/01/2026 01:58:01.332 7fcc0998eae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206508.237061, idle connection 145785.000000, request 304396.032572
01/01/2026 01:58:01.332 7fcc08bef900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207282.442383, idle connection 145733.000000, request 304998.713017
01/01/2026 01:58:01.332 7fcc0998eae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334
01/01/2026 01:58:01.332 7fcc0998eae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.332 7fcc0998eae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 334 (604.6791076660156 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=384064593, topics=[])
01/01/2026 01:58:01.333 7fcc0998eae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 384064593 with 0 response partitions (1 implied)
01/01/2026 01:58:01.333 7fcc086e3e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206495.066162, idle connection 145389.000000, request 304998.509884
01/01/2026 01:58:01.336 7fcc0998e400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
01/01/2026 01:58:01.336 7fcc0998e400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
01/01/2026 01:58:01.336 7fcc0998e400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091ba0d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
01/01/2026 01:58:01.336 7fcc0998e400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.336 7fcc0998e400 [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=364720034, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.336 7fcc0998e400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=364720034, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.337 7fcc0998e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206494.123535, idle connection 145439.000000, request 304999.958992
01/01/2026 01:58:01.337 7fcc0998ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207237.142334, idle connection 145797.000000, request 304397.213936
01/01/2026 01:58:01.337 7fcc0998e400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206493.656250, idle connection 145439.000000, request 304999.495983
01/01/2026 01:58:01.337 7fcc0998ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 334
01/01/2026 01:58:01.337 7fcc0998ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.337 7fcc0998ee00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 334 (603.4247875213623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1331360241, topics=[])
01/01/2026 01:58:01.338 7fcc0998ee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1331360241 with 0 response partitions (1 implied)
01/01/2026 01:58:01.341 7fcc0ba049a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207687.725098, idle connection 145976.000000, request 304399.167776
01/01/2026 01:58:01.341 7fcc0ba049a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 385
01/01/2026 01:58:01.341 7fcc0ba049a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.341 7fcc0ba049a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 385 (601.17506980896 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=873976709, topics=[])
01/01/2026 01:58:01.341 7fcc0ba049a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 873976709 with 0 response partitions (1 implied)
01/01/2026 01:58:01.343 7fcc0ba04e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 17
01/01/2026 01:58:01.343 7fcc0ba04e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
01/01/2026 01:58:01.343 7fcc0ba04e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc09186760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
01/01/2026 01:58:01.343 7fcc0ba04e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.343 7fcc0ba04e00 [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=1241722687, session_epoch=330, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.343 7fcc0ba04e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=1241722687, session_epoch=330, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.343 7fcc0ba04e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207042.018311, idle connection 146000.000000, request 304999.962807
01/01/2026 01:58:01.344 7fcc08b8c0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207321.613037, idle connection 145613.000000, request 304399.018526
01/01/2026 01:58:01.344 7fcc0ba04e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207041.549072, idle connection 145999.000000, request 304999.495983
01/01/2026 01:58:01.344 7fcc08b8c0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329
01/01/2026 01:58:01.344 7fcc08b8c0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.344 7fcc08b8c0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 329 (601.5791893005371 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=635515918, topics=[])
01/01/2026 01:58:01.344 7fcc08b8c0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 635515918 with 0 response partitions (1 implied)
01/01/2026 01:58:01.399 7fcc0998e900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 76
01/01/2026 01:58:01.399 7fcc0998e900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
01/01/2026 01:58:01.399 7fcc0998e900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091f1e20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
01/01/2026 01:58:01.399 7fcc0998e900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.399 7fcc0998e900 [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=2039385810, session_epoch=347, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.400 7fcc0998e900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=2039385810, session_epoch=347, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.400 7fcc0998e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206931.356201, idle connection 145672.000000, request 304999.943018
01/01/2026 01:58:01.400 7fcc0998e900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206930.866455, idle connection 145671.000000, request 304999.459982
01/01/2026 01:58:01.407 7fcc0998ef40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 139
01/01/2026 01:58:01.407 7fcc0998ef40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
01/01/2026 01:58:01.407 7fcc0998ef40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc091f3b50> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
01/01/2026 01:58:01.407 7fcc0998ef40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.407 7fcc0998ef40 [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=557445624, session_epoch=345, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.408 7fcc0998ef40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 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=557445624, session_epoch=345, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.408 7fcc0998ef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206958.240723, idle connection 145724.000000, request 304999.950886
01/01/2026 01:58:01.408 7fcc0998ef40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206957.839600, idle connection 145724.000000, request 304999.550819
01/01/2026 01:58:01.409 7fcc0ba047c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207202.061035, idle connection 145912.000000, request 304399.189472
01/01/2026 01:58:01.409 7fcc0ba047c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 362
01/01/2026 01:58:01.409 7fcc0ba047c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.409 7fcc0ba047c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 362 (601.2382507324219 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1422042923, topics=[])
01/01/2026 01:58:01.409 7fcc0ba047c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1422042923 with 0 response partitions (1 implied)
01/01/2026 01:58:01.418 7fcc0ba04040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206833.248291, idle connection 145750.000000, request 304399.065971
01/01/2026 01:58:01.418 7fcc0ba04040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 358
01/01/2026 01:58:01.418 7fcc0ba04040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
01/01/2026 01:58:01.418 7fcc0ba04040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Response 358 (601.3884544372559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1744049114, topics=[])
01/01/2026 01:58:01.418 7fcc0ba04040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1744049114 with 0 response partitions (1 implied)
01/01/2026 01:58:01.427 7fcc08b8c180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0
01/01/2026 01:58:01.427 7fcc08b8c180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
01/01/2026 01:58:01.427 7fcc08b8c180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc0915a460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
01/01/2026 01:58:01.427 7fcc08b8c180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.427 7fcc08b8c180 [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=332005942, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.427 7fcc08b8c180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=332005942, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.428 7fcc08b8c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206548.512695, idle connection 145556.000000, request 304999.930382
01/01/2026 01:58:01.428 7fcc08bcf0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 0
01/01/2026 01:58:01.428 7fcc08bcf0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
01/01/2026 01:58:01.428 7fcc08bcf0e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fcc0915aca0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
01/01/2026 01:58:01.428 7fcc08bcf0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
01/01/2026 01:58:01.428 7fcc08bcf0e0 [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=1022338529, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.428 7fcc08bcf0e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.61:9092 <connected> [IPv4 ('10.0.0.61', 9092)]>: Request 329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1022338529, session_epoch=326, topics=[], forgotten_topics_data=[])
01/01/2026 01:58:01.428 7fcc08bcf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206549.537109, idle connection 145573.000000, request 304999.965429
01/01/2026 01:58:01.429 7fcc08b8c180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206547.344971, idle connection 145555.000000, request 304998.771429
01/01/2026 01:58:01.429 7fcc08bcf0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206548.748779, idle connection 145572.000000, request 304999.178410
01/01/2026 01:58:01.432 7fcc0998e220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 2
01/01/2026 01:58:01.432 7fcc0998e220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}