02/02/2026 02:16:20.558 7f2a53af00e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 805 (602.1158695220947 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1632603468, topics=[])
02/02/2026 02:16:20.560 7f2a53af00e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1632603468 with 0 response partitions (1 implied)
02/02/2026 02:16:20.566 7f2a53d9d7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240108.121338, idle connection 117010.000000, request 304399.065495
02/02/2026 02:16:20.566 7f2a53d9d7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 840
02/02/2026 02:16:20.566 7f2a53d9d7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.566 7f2a53d9d7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 840 (601.4752388000488 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=689591738, topics=[])
02/02/2026 02:16:20.566 7f2a53d9d7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 689591738 with 0 response partitions (1 implied)
02/02/2026 02:16:20.568 7f2a57085f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 243
02/02/2026 02:16:20.569 7f2a57085f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
02/02/2026 02:16:20.569 7f2a57085f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a54445c70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
02/02/2026 02:16:20.569 7f2a57085f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.569 7f2a57085f40 [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=1393165611, session_epoch=846, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.569 7f2a57085f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 851 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1393165611, session_epoch=846, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.569 7f2a57085f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241324.126709, idle connection 117360.000000, request 304999.952316
02/02/2026 02:16:20.569 7f2a53ac2900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 44
02/02/2026 02:16:20.569 7f2a53ac2900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
02/02/2026 02:16:20.569 7f2a53ac2900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a544368b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
02/02/2026 02:16:20.570 7f2a53ac2900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.570 7f2a53ac2900 [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=315520117, session_epoch=804, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.570 7f2a53ac2900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 809 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=315520117, session_epoch=804, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.570 7f2a53ac2900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240394.288086, idle connection 117800.000000, request 304999.959707
02/02/2026 02:16:20.570 7f2a57085c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240274.811279, idle connection 117471.000000, request 304397.334814
02/02/2026 02:16:20.570 7f2a57085f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241322.698975, idle connection 117358.000000, request 304998.525381
02/02/2026 02:16:20.571 7f2a57085c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 837
02/02/2026 02:16:20.571 7f2a57085c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.571 7f2a57085c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 837 (603.5468578338623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=814073748, topics=[])
02/02/2026 02:16:20.571 7f2a57085c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 814073748 with 0 response partitions (1 implied)
02/02/2026 02:16:20.571 7f2a53ac2900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240392.695312, idle connection 117798.000000, request 304998.368263
02/02/2026 02:16:20.617 7f2a53a9a360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239617.902832, idle connection 117142.000000, request 304398.783684
02/02/2026 02:16:20.618 7f2a53a9a360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1188
02/02/2026 02:16:20.618 7f2a53a9a360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.618 7f2a53a9a360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 1188 (601.8362045288086 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=82199603, topics=[])
02/02/2026 02:16:20.618 7f2a53a9a360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 82199603 with 0 response partitions (1 implied)
02/02/2026 02:16:20.653 7f2a55b2c2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240315.336914, idle connection 117718.000000, request 304398.725748
02/02/2026 02:16:20.653 7f2a55b2c2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 836
02/02/2026 02:16:20.653 7f2a55b2c2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.653 7f2a55b2c2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 836 (601.8524169921875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=594866476, topics=[])
02/02/2026 02:16:20.653 7f2a55b2c2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 594866476 with 0 response partitions (1 implied)
02/02/2026 02:16:20.672 7f2a57085a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241778.882812, idle connection 117130.000000, request 304395.115376
02/02/2026 02:16:20.673 7f2a57085a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 858
02/02/2026 02:16:20.673 7f2a57085a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.673 7f2a57085a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 858 (605.4611206054688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=205885634, topics=[])
02/02/2026 02:16:20.673 7f2a57085a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 205885634 with 0 response partitions (1 implied)
02/02/2026 02:16:20.673 7f2a570852c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240293.063965, idle connection 117111.000000, request 304394.870758
02/02/2026 02:16:20.674 7f2a570852c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 862
02/02/2026 02:16:20.674 7f2a570852c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.674 7f2a570852c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 862 (605.5014133453369 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=524106616, topics=[])
02/02/2026 02:16:20.674 7f2a570852c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 524106616 with 0 response partitions (1 implied)
02/02/2026 02:16:20.685 7f2a541794a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240831.365723, idle connection 117621.000000, request 304395.546913
02/02/2026 02:16:20.685 7f2a55b2c7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240792.427002, idle connection 117200.000000, request 304396.265268
02/02/2026 02:16:20.685 7f2a541794a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 822
02/02/2026 02:16:20.686 7f2a541794a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.686 7f2a541794a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 822 (605.0286293029785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=36235495, topics=[])
02/02/2026 02:16:20.686 7f2a541794a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 36235495 with 0 response partitions (1 implied)
02/02/2026 02:16:20.686 7f2a55b2c7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 852
02/02/2026 02:16:20.686 7f2a55b2c7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.686 7f2a55b2c7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 852 (604.6924591064453 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1082055048, topics=[])
02/02/2026 02:16:20.686 7f2a55b2c7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1082055048 with 0 response partitions (1 implied)
02/02/2026 02:16:20.767 7f2a55b2cae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240969.298096, idle connection 117117.000000, request 304394.715786
02/02/2026 02:16:20.768 7f2a55b2cae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 812
02/02/2026 02:16:20.768 7f2a55b2cae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.768 7f2a55b2cae0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 812 (605.8921813964844 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1558522030, topics=[])
02/02/2026 02:16:20.768 7f2a55b2cae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1558522030 with 0 response partitions (1 implied)
02/02/2026 02:16:20.768 7f2a53d9dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 10
02/02/2026 02:16:20.769 7f2a53d9dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
02/02/2026 02:16:20.769 7f2a53d9dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a544ac790> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
02/02/2026 02:16:20.769 7f2a53d9dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.769 7f2a53d9dea0 [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=1918178334, session_epoch=799, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.769 7f2a53d9dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 804 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1918178334, session_epoch=799, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.769 7f2a53d9dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240361.235840, idle connection 116461.000000, request 304999.952316
02/02/2026 02:16:20.769 7f2a53d9dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240360.797363, idle connection 116461.000000, request 304999.518633
02/02/2026 02:16:20.771 7f2a53d9de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240973.244385, idle connection 116830.000000, request 304392.223835
02/02/2026 02:16:20.772 7f2a53d9de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 805
02/02/2026 02:16:20.772 7f2a53d9de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.772 7f2a53d9de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 805 (608.1714630126953 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1620515641, topics=[])
02/02/2026 02:16:20.772 7f2a53d9de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1620515641 with 0 response partitions (1 implied)
02/02/2026 02:16:20.773 7f2a53d9dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239769.194824, idle connection 116146.000000, request 304392.558575
02/02/2026 02:16:20.774 7f2a53d9dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 813
02/02/2026 02:16:20.774 7f2a53d9dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.774 7f2a53d9dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 813 (607.7861785888672 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=916040571, topics=[])
02/02/2026 02:16:20.774 7f2a53d9dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 916040571 with 0 response partitions (1 implied)
02/02/2026 02:16:20.774 7f2a53d9da40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0
02/02/2026 02:16:20.774 7f2a53d9da40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
02/02/2026 02:16:20.774 7f2a53d9da40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a5443a460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
02/02/2026 02:16:20.775 7f2a53d9da40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.775 7f2a53d9da40 [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=1356854669, session_epoch=796, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.775 7f2a53d9da40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 801 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1356854669, session_epoch=796, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.775 7f2a53d9da40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240357.880127, idle connection 116479.000000, request 304999.954462
02/02/2026 02:16:20.775 7f2a53d9da40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240357.510010, idle connection 116479.000000, request 304999.587297
02/02/2026 02:16:20.775 7f2a57085400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 77
02/02/2026 02:16:20.776 7f2a57085400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
02/02/2026 02:16:20.776 7f2a57085400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a5443a5b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
02/02/2026 02:16:20.776 7f2a57085400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.776 7f2a57085400 [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=1330468468, session_epoch=817, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.776 7f2a57085400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 822 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1330468468, session_epoch=817, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.776 7f2a57085400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240401.236328, idle connection 117174.000000, request 304999.961615
02/02/2026 02:16:20.776 7f2a54136360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 69
02/02/2026 02:16:20.776 7f2a54136360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
02/02/2026 02:16:20.777 7f2a54136360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a54613a60> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
02/02/2026 02:16:20.777 7f2a54136360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.777 7f2a54136360 [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=1440567404, session_epoch=813, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.777 7f2a54136360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 818 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1440567404, session_epoch=813, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.777 7f2a54136360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240435.005127, idle connection 117319.000000, request 304999.961615
02/02/2026 02:16:20.777 7f2a57085e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241576.171875, idle connection 117567.000000, request 304391.997099
02/02/2026 02:16:20.777 7f2a57085b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240530.478271, idle connection 117847.000000, request 304393.081427
02/02/2026 02:16:20.777 7f2a57085400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240399.767090, idle connection 117172.000000, request 304998.495579
02/02/2026 02:16:20.778 7f2a57085e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 856
02/02/2026 02:16:20.778 7f2a57085e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.778 7f2a57085e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 856 (608.7872982025146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2126703863, topics=[])
02/02/2026 02:16:20.778 7f2a57085e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2126703863 with 0 response partitions (1 implied)
02/02/2026 02:16:20.778 7f2a57085b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 828
02/02/2026 02:16:20.778 7f2a57085b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.778 7f2a57085b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 828 (608.1044673919678 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1876625115, topics=[])
02/02/2026 02:16:20.779 7f2a57085b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1876625115 with 0 response partitions (1 implied)
02/02/2026 02:16:20.779 7f2a54136360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240433.051025, idle connection 117317.000000, request 304998.008490
02/02/2026 02:16:20.838 7f2a53d9dd60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 241007.016846, idle connection 116649.000000, request 304398.815632
02/02/2026 02:16:20.838 7f2a53d9dd60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 810
02/02/2026 02:16:20.838 7f2a53d9dd60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.838 7f2a53d9dd60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 810 (601.8753051757812 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=598323724, topics=[])
02/02/2026 02:16:20.839 7f2a53d9dd60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 598323724 with 0 response partitions (1 implied)
02/02/2026 02:16:20.854 7f2a54196d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240893.711914, idle connection 117300.000000, request 304398.804426
02/02/2026 02:16:20.855 7f2a54196d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 855
02/02/2026 02:16:20.855 7f2a54196d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.855 7f2a54196d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 855 (601.9792556762695 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1159374152, topics=[])
02/02/2026 02:16:20.855 7f2a54196d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1159374152 with 0 response partitions (1 implied)
02/02/2026 02:16:20.950 7f2a53d9d540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 35
02/02/2026 02:16:20.950 7f2a53d9d540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
02/02/2026 02:16:20.950 7f2a53d9d540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a54445280> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
02/02/2026 02:16:20.950 7f2a53d9d540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.950 7f2a53d9d540 [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=1288006257, session_epoch=809, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.950 7f2a53d9d540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 814 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1288006257, session_epoch=809, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.951 7f2a53d9d540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240390.666992, idle connection 116355.000000, request 304999.940395
02/02/2026 02:16:20.951 7f2a53d9d5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239755.954102, idle connection 116932.000000, request 304396.899462
02/02/2026 02:16:20.951 7f2a53d9d540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240390.011230, idle connection 116354.000000, request 304999.295712
02/02/2026 02:16:20.952 7f2a53d9d5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 801
02/02/2026 02:16:20.952 7f2a53d9d5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:20.952 7f2a53d9d5e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 801 (603.8925647735596 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=338382404, topics=[])
02/02/2026 02:16:20.952 7f2a53d9d5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 338382404 with 0 response partitions (1 implied)
02/02/2026 02:16:20.998 7f2a55b2c400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 207
02/02/2026 02:16:20.998 7f2a55b2c400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
02/02/2026 02:16:20.998 7f2a55b2c400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a5442e460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
02/02/2026 02:16:20.998 7f2a55b2c400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:20.999 7f2a55b2c400 [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=946637140, session_epoch=837, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.999 7f2a55b2c400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 842 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=946637140, session_epoch=837, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:20.999 7f2a55b2c400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240638.771484, idle connection 117209.000000, request 304999.940157
02/02/2026 02:16:20.999 7f2a55b2c400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240638.288574, idle connection 117209.000000, request 304999.465227
02/02/2026 02:16:21.042 7f2a57085180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239779.799561, idle connection 116162.000000, request 304398.790121
02/02/2026 02:16:21.043 7f2a57085180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 808
02/02/2026 02:16:21.043 7f2a57085180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:21.043 7f2a57085180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 808 (601.8104553222656 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1048333662, topics=[])
02/02/2026 02:16:21.043 7f2a57085180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1048333662 with 0 response partitions (1 implied)
02/02/2026 02:16:21.102 7f2a57085540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239722.220459, idle connection 116985.000000, request 304398.835897
02/02/2026 02:16:21.102 7f2a57085540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 805
02/02/2026 02:16:21.102 7f2a57085540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:21.103 7f2a57085540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 805 (601.811408996582 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=138266009, topics=[])
02/02/2026 02:16:21.103 7f2a57085540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 138266009 with 0 response partitions (1 implied)
02/02/2026 02:16:21.105 7f2a57085220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239720.431885, idle connection 116985.000000, request 304398.445845
02/02/2026 02:16:21.106 7f2a57085220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 807
02/02/2026 02:16:21.106 7f2a57085220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:21.106 7f2a57085220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 807 (601.919412612915 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=526113565, topics=[])
02/02/2026 02:16:21.106 7f2a57085220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 526113565 with 0 response partitions (1 implied)
02/02/2026 02:16:21.106 7f2a57085cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 242179.414062, idle connection 117107.000000, request 304398.914099
02/02/2026 02:16:21.106 7f2a57085cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 813
02/02/2026 02:16:21.106 7f2a57085cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:21.106 7f2a57085cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 813 (601.4454364776611 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=768333968, topics=[])
02/02/2026 02:16:21.107 7f2a57085cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 768333968 with 0 response partitions (1 implied)
02/02/2026 02:16:21.148 7f2a53ac2860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 50
02/02/2026 02:16:21.149 7f2a53ac2860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
02/02/2026 02:16:21.149 7f2a53ac2860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a54445250> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
02/02/2026 02:16:21.149 7f2a53ac2860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:21.149 7f2a53ac2860 [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=2091054323, session_epoch=807, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.149 7f2a53ac2860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 812 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2091054323, session_epoch=807, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.149 7f2a53ac2860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240395.204834, idle connection 116219.000000, request 304999.943495
02/02/2026 02:16:21.150 7f2a53ac2860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240394.721436, idle connection 116219.000000, request 304999.467611
02/02/2026 02:16:21.160 7f2a53af00e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 24
02/02/2026 02:16:21.160 7f2a53af00e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
02/02/2026 02:16:21.161 7f2a53af00e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a5450a640> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
02/02/2026 02:16:21.161 7f2a53af00e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:21.161 7f2a53af00e0 [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=1632603468, session_epoch=801, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.161 7f2a53af00e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 806 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1632603468, session_epoch=801, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.161 7f2a53af00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240403.848633, idle connection 116573.000000, request 304999.945641
02/02/2026 02:16:21.161 7f2a53af00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240403.368652, idle connection 116572.000000, request 304999.468327
02/02/2026 02:16:21.167 7f2a53d9d7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 198
02/02/2026 02:16:21.167 7f2a53d9d7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
02/02/2026 02:16:21.167 7f2a53d9d7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a545da580> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
02/02/2026 02:16:21.167 7f2a53d9d7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:21.167 7f2a53d9d7c0 [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=689591738, session_epoch=836, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.167 7f2a53d9d7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=689591738, session_epoch=836, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.167 7f2a53d9d7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239506.465088, idle connection 116408.000000, request 304999.953508
02/02/2026 02:16:21.168 7f2a53d9d7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239506.088135, idle connection 116408.000000, request 304999.578714
02/02/2026 02:16:21.171 7f2a57085c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 183
02/02/2026 02:16:21.171 7f2a57085c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
02/02/2026 02:16:21.171 7f2a57085c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f2a54464490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
02/02/2026 02:16:21.172 7f2a57085c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
02/02/2026 02:16:21.172 7f2a57085c20 [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=814073748, session_epoch=833, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.172 7f2a57085c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Request 838 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=814073748, session_epoch=833, topics=[], forgotten_topics_data=[])
02/02/2026 02:16:21.172 7f2a57085c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239672.918701, idle connection 116869.000000, request 304999.956846
02/02/2026 02:16:21.172 7f2a57085f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 240721.056396, idle connection 116757.000000, request 304396.884441
02/02/2026 02:16:21.172 7f2a53ac2900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239791.818848, idle connection 117197.000000, request 304397.492170
02/02/2026 02:16:21.173 7f2a57085c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 239672.177002, idle connection 116868.000000, request 304999.217987
02/02/2026 02:16:21.173 7f2a57085f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 851
02/02/2026 02:16:21.173 7f2a57085f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:21.173 7f2a57085f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 851 (604.0496826171875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1393165611, topics=[])
02/02/2026 02:16:21.173 7f2a57085f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1393165611 with 0 response partitions (1 implied)
02/02/2026 02:16:21.173 7f2a53ac2900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 809
02/02/2026 02:16:21.174 7f2a53ac2900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
02/02/2026 02:16:21.174 7f2a53ac2900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.19:9092 <connected> [IPv4 ('10.0.0.19', 9092)]>: Response 809 (603.8076877593994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=315520117, topics=[])
02/02/2026 02:16:21.174 7f2a53ac2900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 315520117 with 0 response partitions (1 implied)