03/05/2026 04:29:58.345 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 934727119 with 0 response partitions (1 implied)
03/05/2026 04:29:58.394 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 420
03/05/2026 04:29:58.394 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/05/2026 04:29:58.394 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c22280> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/05/2026 04:29:58.394 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:58.394 7f941175a400 [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=1394114440, session_epoch=7477, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.395 7f941175a400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7494 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394114440, session_epoch=7477, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.395 7f941175a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64602.960693, idle connection 357554.000000, request 304999.932766
03/05/2026 04:29:58.395 7f941175a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64602.547363, idle connection 357553.000000, request 304999.526024
03/05/2026 04:29:58.404 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 3239
03/05/2026 04:29:58.404 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
03/05/2026 04:29:58.404 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410d06220> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
03/05/2026 04:29:58.404 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/05/2026 04:29:58.404 7f941175a680 [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=2130364103, session_epoch=8099, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.404 7f941175a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Request 8112 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2130364103, session_epoch=8099, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.405 7f941175a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71066.003174, idle connection 9524.000000, request 304999.950886
03/05/2026 04:29:58.405 7f941175a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 71065.564453, idle connection 9523.000000, request 304999.518394
03/05/2026 04:29:58.448 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 337
03/05/2026 04:29:58.448 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/05/2026 04:29:58.448 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410cea9d0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/05/2026 04:29:58.448 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:58.448 7f9410ca0a40 [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=554587936, session_epoch=7491, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.448 7f9410ca0a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7511 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=554587936, session_epoch=7491, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.448 7f9410ca0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67013.591309, idle connection 181129.000000, request 304999.952316
03/05/2026 04:29:58.449 7f9410ca0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67013.087158, idle connection 181129.000000, request 304999.454498
03/05/2026 04:29:58.479 7f941175a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68632.520508, idle connection 6251.000000, request 304395.981073
03/05/2026 04:29:58.479 7f941175a7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8091
03/05/2026 04:29:58.479 7f941175a7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:58.479 7f941175a7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 8091 (604.6721935272217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1809744751, topics=[])
03/05/2026 04:29:58.480 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1809744751 with 0 response partitions (1 implied)
03/05/2026 04:29:58.540 7f9410ca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68727.066406, idle connection 7493.000000, request 304397.903442
03/05/2026 04:29:58.540 7f9410ca0b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7510
03/05/2026 04:29:58.540 7f9410ca0b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:58.540 7f9410ca0b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Response 7510 (602.6313304901123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785999987, topics=[])
03/05/2026 04:29:58.540 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785999987 with 0 response partitions (1 implied)
03/05/2026 04:29:58.599 7f9410ca0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68809.872559, idle connection 7397.000000, request 304398.642778
03/05/2026 04:29:58.599 7f9410ca0e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7513
03/05/2026 04:29:58.599 7f9410ca0e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:58.600 7f9410ca0e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7513 (601.9468307495117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1105867292, topics=[])
03/05/2026 04:29:58.600 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1105867292 with 0 response partitions (1 implied)
03/05/2026 04:29:58.766 7f940f6642c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67276.903809, idle connection 244975.000000, request 304399.012566
03/05/2026 04:29:58.766 7f940f6642c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7696
03/05/2026 04:29:58.766 7f940f6642c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:58.767 7f940f6642c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7696 (601.5260219573975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=305707756, topics=[])
03/05/2026 04:29:58.767 7f940f6642c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 305707756 with 0 response partitions (1 implied)
03/05/2026 04:29:58.802 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 519
03/05/2026 04:29:58.802 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
03/05/2026 04:29:58.802 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c229d0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
03/05/2026 04:29:58.802 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/05/2026 04:29:58.803 7f9410ca0ea0 [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=2035970882, session_epoch=7483, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.803 7f9410ca0ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 7500 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2035970882, session_epoch=7483, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.803 7f9410ca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70467.250488, idle connection 8215.000000, request 304999.947309
03/05/2026 04:29:58.803 7f9410ca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70466.847900, idle connection 8214.000000, request 304999.553442
03/05/2026 04:29:58.946 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 943
03/05/2026 04:29:58.946 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
03/05/2026 04:29:58.946 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c71100> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
03/05/2026 04:29:58.946 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:58.946 7f9410ca0d60 [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=934727119, session_epoch=7640, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.946 7f9410ca0d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7657 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=934727119, session_epoch=7640, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:58.946 7f9410ca0d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65468.891602, idle connection 120725.000000, request 304999.949932
03/05/2026 04:29:58.947 7f9410ca0d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65468.463379, idle connection 120725.000000, request 304999.528885
03/05/2026 04:29:58.996 7f941175a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64001.918457, idle connection 356953.000000, request 304398.893118
03/05/2026 04:29:58.996 7f941175a400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7494
03/05/2026 04:29:58.996 7f941175a400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:58.996 7f941175a400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7494 (601.6690731048584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394114440, topics=[])
03/05/2026 04:29:58.996 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1394114440 with 0 response partitions (1 implied)
03/05/2026 04:29:59.005 7f941175a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 70465.076172, idle connection 8923.000000, request 304399.024487
03/05/2026 04:29:59.006 7f941175a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8112
03/05/2026 04:29:59.006 7f941175a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.006 7f941175a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Response 8112 (601.449728012085 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2130364103, topics=[])
03/05/2026 04:29:59.006 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2130364103 with 0 response partitions (1 implied)
03/05/2026 04:29:59.050 7f9410ca0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66412.458008, idle connection 180528.000000, request 304398.816109
03/05/2026 04:29:59.050 7f9410ca0a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7511
03/05/2026 04:29:59.050 7f9410ca0a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.050 7f9410ca0a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7511 (601.7520427703857 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=554587936, topics=[])
03/05/2026 04:29:59.050 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 554587936 with 0 response partitions (1 implied)
03/05/2026 04:29:59.081 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4690
03/05/2026 04:29:59.081 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
03/05/2026 04:29:59.081 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c06250> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
03/05/2026 04:29:59.081 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:59.081 7f941175a7c0 [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=1809744751, session_epoch=8079, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.081 7f941175a7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 8092 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1809744751, session_epoch=8079, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.082 7f941175a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68029.753662, idle connection 5648.000000, request 304999.948502
03/05/2026 04:29:59.082 7f941175a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68029.305176, idle connection 5648.000000, request 304999.508858
03/05/2026 04:29:59.144 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 280
03/05/2026 04:29:59.144 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
03/05/2026 04:29:59.144 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c71130> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
03/05/2026 04:29:59.144 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/05/2026 04:29:59.144 7f9410ca0b80 [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=1785999987, session_epoch=7494, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.145 7f9410ca0b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Request 7511 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1785999987, session_epoch=7494, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.145 7f9410ca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68121.992432, idle connection 6887.000000, request 304999.944448
03/05/2026 04:29:59.145 7f9410ca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68121.528320, idle connection 6887.000000, request 304999.485970
03/05/2026 04:29:59.200 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 516
03/05/2026 04:29:59.200 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
03/05/2026 04:29:59.201 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c4ab50> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
03/05/2026 04:29:59.201 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:59.201 7f9410ca0e00 [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=1105867292, session_epoch=7501, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.201 7f9410ca0e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7514 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1105867292, session_epoch=7501, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.201 7f9410ca0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68207.525879, idle connection 6794.000000, request 304999.937534
03/05/2026 04:29:59.202 7f9410ca0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 68207.111816, idle connection 6794.000000, request 304999.537468
03/05/2026 04:29:59.368 7f940f6642c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1561
03/05/2026 04:29:59.368 7f940f6642c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
03/05/2026 04:29:59.368 7f940f6642c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c4ae80> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
03/05/2026 04:29:59.368 7f940f6642c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:59.368 7f940f6642c0 [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=305707756, session_epoch=7680, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.368 7f940f6642c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7697 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=305707756, session_epoch=7680, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.369 7f940f6642c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66674.275879, idle connection 244372.000000, request 304999.933481
03/05/2026 04:29:59.369 7f940f6642c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66673.867432, idle connection 244372.000000, request 304999.533176
03/05/2026 04:29:59.405 7f9410ca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69865.521240, idle connection 7613.000000, request 304398.219347
03/05/2026 04:29:59.405 7f9410ca0ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7500
03/05/2026 04:29:59.405 7f9410ca0ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.405 7f9410ca0ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 7500 (602.515697479248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2035970882, topics=[])
03/05/2026 04:29:59.405 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2035970882 with 0 response partitions (1 implied)
03/05/2026 04:29:59.547 7f9410ca0d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64867.859619, idle connection 120124.000000, request 304398.916960
03/05/2026 04:29:59.548 7f9410ca0d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7657
03/05/2026 04:29:59.548 7f9410ca0d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.548 7f9410ca0d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7657 (601.6147136688232 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=934727119, topics=[])
03/05/2026 04:29:59.548 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 934727119 with 0 response partitions (1 implied)
03/05/2026 04:29:59.597 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 420
03/05/2026 04:29:59.597 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
03/05/2026 04:29:59.598 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c71e20> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
03/05/2026 04:29:59.598 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:59.598 7f941175a400 [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=1394114440, session_epoch=7478, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.598 7f941175a400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7495 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394114440, session_epoch=7478, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.598 7f941175a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63399.405518, idle connection 356350.000000, request 304999.912024
03/05/2026 04:29:59.599 7f941175a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63398.546875, idle connection 356349.000000, request 304999.069929
03/05/2026 04:29:59.608 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 3239
03/05/2026 04:29:59.608 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)}
03/05/2026 04:29:59.608 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c6a100> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)])
03/05/2026 04:29:59.608 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/05/2026 04:29:59.608 7f941175a680 [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=2130364103, session_epoch=8100, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.608 7f941175a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Request 8113 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2130364103, session_epoch=8100, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.608 7f941175a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69862.204590, idle connection 8320.000000, request 304999.943256
03/05/2026 04:29:59.609 7f941175a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69861.562012, idle connection 8319.000000, request 304999.309063
03/05/2026 04:29:59.651 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 337
03/05/2026 04:29:59.651 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
03/05/2026 04:29:59.651 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c6a370> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
03/05/2026 04:29:59.651 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:29:59.652 7f9410ca0a40 [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=554587936, session_epoch=7492, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.652 7f9410ca0a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7512 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=554587936, session_epoch=7492, topics=[], forgotten_topics_data=[])
03/05/2026 04:29:59.652 7f9410ca0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65810.121582, idle connection 179926.000000, request 304999.937534
03/05/2026 04:29:59.652 7f9410ca0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65809.628418, idle connection 179925.000000, request 304999.454975
03/05/2026 04:29:59.683 7f941175a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67428.096924, idle connection 5047.000000, request 304398.288012
03/05/2026 04:29:59.684 7f941175a7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8092
03/05/2026 04:29:59.684 7f941175a7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.684 7f941175a7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 8092 (602.3633480072021 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1809744751, topics=[])
03/05/2026 04:29:59.684 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1809744751 with 0 response partitions (1 implied)
03/05/2026 04:29:59.747 7f9410ca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67520.177490, idle connection 6286.000000, request 304398.122311
03/05/2026 04:29:59.747 7f9410ca0b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7511
03/05/2026 04:29:59.747 7f9410ca0b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.748 7f9410ca0b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Response 7511 (602.8358936309814 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1785999987, topics=[])
03/05/2026 04:29:59.748 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1785999987 with 0 response partitions (1 implied)
03/05/2026 04:29:59.803 7f9410ca0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67605.747314, idle connection 6193.000000, request 304398.157835
03/05/2026 04:29:59.804 7f9410ca0e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7514
03/05/2026 04:29:59.804 7f9410ca0e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.804 7f9410ca0e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7514 (602.6201248168945 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1105867292, topics=[])
03/05/2026 04:29:59.804 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1105867292 with 0 response partitions (1 implied)
03/05/2026 04:29:59.970 7f940f6642c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66073.315918, idle connection 243771.000000, request 304398.974419
03/05/2026 04:29:59.970 7f940f6642c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7697
03/05/2026 04:29:59.970 7f940f6642c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:29:59.970 7f940f6642c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7697 (601.6850471496582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=305707756, topics=[])
03/05/2026 04:29:59.970 7f940f6642c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 305707756 with 0 response partitions (1 implied)
03/05/2026 04:30:00.007 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 519
03/05/2026 04:30:00.007 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
03/05/2026 04:30:00.007 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f94115cfac0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
03/05/2026 04:30:00.007 7f9410ca0ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/05/2026 04:30:00.007 7f9410ca0ea0 [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=2035970882, session_epoch=7484, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.007 7f9410ca0ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 7501 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2035970882, session_epoch=7484, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.008 7f9410ca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69262.589355, idle connection 7010.000000, request 304999.948740
03/05/2026 04:30:00.008 7f9410ca0ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69262.156494, idle connection 7009.000000, request 304999.523878
03/05/2026 04:30:00.149 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 943
03/05/2026 04:30:00.149 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
03/05/2026 04:30:00.149 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410bfea00> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
03/05/2026 04:30:00.149 7f9410ca0d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:30:00.149 7f9410ca0d60 [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=934727119, session_epoch=7641, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.149 7f9410ca0d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7658 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=934727119, session_epoch=7641, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.149 7f9410ca0d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64265.852295, idle connection 119522.000000, request 304999.947309
03/05/2026 04:30:00.150 7f9410ca0d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64264.943848, idle connection 119521.000000, request 304999.047995
03/05/2026 04:30:00.200 7f941175a400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62797.766357, idle connection 355748.000000, request 304398.287058
03/05/2026 04:30:00.200 7f941175a400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7495
03/05/2026 04:30:00.200 7f941175a400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:30:00.200 7f941175a400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7495 (602.2307872772217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394114440, topics=[])
03/05/2026 04:30:00.201 7f941175a400 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1394114440 with 0 response partitions (1 implied)
03/05/2026 04:30:00.209 7f941175a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 69261.105713, idle connection 7719.000000, request 304398.847103
03/05/2026 04:30:00.210 7f941175a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8113
03/05/2026 04:30:00.210 7f941175a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:30:00.210 7f941175a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Response 8113 (601.8157005310059 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2130364103, topics=[])
03/05/2026 04:30:00.210 7f941175a680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2130364103 with 0 response partitions (1 implied)
03/05/2026 04:30:00.253 7f9410ca0a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65209.078369, idle connection 179325.000000, request 304398.897886
03/05/2026 04:30:00.253 7f9410ca0a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7512
03/05/2026 04:30:00.253 7f9410ca0a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/05/2026 04:30:00.253 7f9410ca0a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Response 7512 (601.599931716919 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=554587936, topics=[])
03/05/2026 04:30:00.254 7f9410ca0a40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 554587936 with 0 response partitions (1 implied)
03/05/2026 04:30:00.285 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4690
03/05/2026 04:30:00.285 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
03/05/2026 04:30:00.285 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410bfe190> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
03/05/2026 04:30:00.285 7f941175a7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:30:00.285 7f941175a7c0 [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=1809744751, session_epoch=8080, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.286 7f941175a7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 8093 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1809744751, session_epoch=8080, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.286 7f941175a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66825.637695, idle connection 4444.000000, request 304999.947786
03/05/2026 04:30:00.286 7f941175a7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66825.206299, idle connection 4444.000000, request 304999.524593
03/05/2026 04:30:00.349 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 280
03/05/2026 04:30:00.350 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
03/05/2026 04:30:00.350 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c6a6a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
03/05/2026 04:30:00.350 7f9410ca0b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/05/2026 04:30:00.350 7f9410ca0b80 [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=1785999987, session_epoch=7495, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.350 7f9410ca0b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.65:9092 <connected> [IPv4 ('10.0.0.65', 9092)]>: Request 7512 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1785999987, session_epoch=7495, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.350 7f9410ca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66916.292725, idle connection 5682.000000, request 304999.928951
03/05/2026 04:30:00.351 7f9410ca0b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 66915.714600, idle connection 5681.000000, request 304999.362230
03/05/2026 04:30:00.405 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 516
03/05/2026 04:30:00.405 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
03/05/2026 04:30:00.405 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f9410c4a520> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
03/05/2026 04:30:00.406 7f9410ca0e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/05/2026 04:30:00.406 7f9410ca0e00 [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=1105867292, session_epoch=7502, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.406 7f9410ca0e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.133:9092 <connected> [IPv4 ('10.0.0.133', 9092)]>: Request 7515 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1105867292, session_epoch=7502, topics=[], forgotten_topics_data=[])
03/05/2026 04:30:00.406 7f9410ca0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67002.841064, idle connection 5590.000000, request 304999.941349
03/05/2026 04:30:00.406 7f9410ca0e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 67002.392334, idle connection 5589.000000, request 304999.501705